Gate per-node ContainerLogV2 coverage check behind PER_NODE_LOG_COVERAGE env var

Author: zanejohnson-azure

test/ginkgo-e2e/querylogs/querylogs_suite_test.go

@@ -18,6 +18,7 @@ var LogsClient *azquery.LogsClient
 var AKSResourceId string
 var RetinaNetworkFlowLogsEnabled string
 var GenevaIntegrationEnabled string
+var PerNodeLogCoverageEnabled string
 var Cfg *rest.Config
 
 func TestQuerylogs(t *testing.T) {
@@ -34,6 +35,7 @@ var _ = BeforeSuite(func() {
 	RetinaNetworkFlowLogsEnabled, err = utils.IsRetinaNetworkFlowLogsEnabled(K8sClient, "kube-system", "component", "ama-logs-agent", "ama-logs")
 	Expect(err).NotTo(HaveOccurred())
 	GenevaIntegrationEnabled = os.Getenv("GENEVA_INTEGRATION")
+	PerNodeLogCoverageEnabled = os.Getenv("PER_NODE_LOG_COVERAGE")
 	LogsClient, err = utils.SetupLogsClient()
 	Expect(err).NotTo(HaveOccurred())
 })

test/ginkgo-e2e/querylogs/querylogs_test.go

@@ -43,6 +43,9 @@ var _ = Describe("When querying the logs for the table", func() {
 
 var _ = Describe("When querying ContainerLogV2 per node", func() {
 	It("Every node hosting an ama-logs DaemonSet pod should have ContainerLogV2 rows", func() {
+		if PerNodeLogCoverageEnabled != "true" {
+			Skip("Per-node ContainerLogV2 coverage skipped because PER_NODE_LOG_COVERAGE is not set to 'true'")
+		}
 		if GenevaIntegrationEnabled == "true" {
 			Skip("ContainerLogV2 per-node coverage skipped because GENEVA_INTEGRATION is set to 'true'")
 		}