create "persistent" test group (#769)

* initial marking of tests

* specific labels in patching tests, no longer delete istio-system on test suite start

* rename test group to Persistent

* add addtl test to persistent group

* only delete istio-system if using persistent group

pkg/tests/ossm/bug_istiopods_test.go

@@ -34,7 +34,7 @@ import (
 )
 
 func TestIstiodPodFailsAfterRestarts(t *testing.T) {
-	NewTest(t).Id("T35").Groups(Full, Disconnected, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T35").Groups(Full, Disconnected, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("Verify that Istio pod not get stuck with probes failure after restart")
 		t.Log("References: \n- https://issues.redhat.com/browse/OSSM-2340\n- https://issues.redhat.com/browse/OSSM-2434")
 		namespaces := util.GenerateStrings("test-", 50)
@@ -52,7 +52,7 @@ func TestIstiodPodFailsAfterRestarts(t *testing.T) {
 
 		t.LogStep("Delete Istio pod 10 times and check that it is running and ready after the deletions")
 		for i := 0; i < 10; i++ {
-			istiodPod := pod.MatchingSelector("app=istiod", meshNamespace)
+			istiodPod := pod.MatchingSelector(fmt.Sprintf("app=istiod,maistra-control-plane=%s", meshNamespace), meshNamespace)
 			oc.DeletePod(t, istiodPod)
 			oc.WaitPodRunning(t, istiodPod)
 			oc.WaitPodReady(t, istiodPod)
@@ -61,7 +61,7 @@ func TestIstiodPodFailsAfterRestarts(t *testing.T) {
 }
 
 func TestControllerFailsToUpdatePod(t *testing.T) {
-	NewTest(t).Groups(Full, ARM).Run(func(t TestHelper) {
+	NewTest(t).Groups(Full, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("Verify that the controller does not fails to update the pod when the member controller couldn't add the member-of label")
 		t.Log("References: \n- https://issues.redhat.com/browse/OSSM-2169\n- https://issues.redhat.com/browse/OSSM-2420")
 
@@ -134,7 +134,7 @@ func TestIstiodPodFailsWithValidationMessages(t *testing.T) {
 			oc.RecreateNamespace(t, meshNamespace)
 		})
 
-		istiodPod := pod.MatchingSelector("app=istiod", meshNamespace)
+		istiodPod := pod.MatchingSelector(fmt.Sprintf("app=istiod,maistra-control-plane=%s", meshNamespace), meshNamespace)
 		oc.WaitPodRunning(t, istiodPod)
 		retry.UntilSuccessWithOptions(t, retry.Options().MaxAttempts(10), func(t TestHelper) {
 			oc.LogsFromPods(t, meshNamespace, "app=istiod", assert.OutputContains(

pkg/tests/ossm/bug_rolebinding_test.go

@@ -31,7 +31,7 @@ type namespaceResources struct {
 }
 
 func TestMissingRoleBinding(t *testing.T) {
-	NewTest(t).Groups(Full, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Groups(Full, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 		t.Log("Verify that role and role binding is detected with SMMR namespace with gateway")
 		t.Log("Reference: https://issues.redhat.com/browse/OSSM-2143")
 

pkg/tests/ossm/operator/operator_deadlock_test.go

@@ -26,7 +26,7 @@ import (
 )
 
 func TestOperatorCanReconcileSMCPWhenIstiodOffline(t *testing.T) {
-	test.NewTest(t).Groups(test.Full, test.Disconnected, test.ARM).Run(func(t test.TestHelper) {
+	test.NewTest(t).Groups(test.Full, test.Disconnected, test.ARM, test.Persistent).Run(func(t test.TestHelper) {
 		t.Log("This test checks if the operator can reconcile an SMCP even if the istiod pod is missing")
 		t.Log("See https://issues.redhat.com/browse/OSSM-3235")
 

pkg/tests/ossm/operator/operator_readiness_test.go

@@ -29,7 +29,7 @@ import (
 )
 
 func TestOperatorPodHonorsReadinessProbe(t *testing.T) {
-	test.NewTest(t).Groups(test.Full, test.Disconnected, test.ARM).MinVersion(version.SMCP_2_4).Run(func(t test.TestHelper) {
+	test.NewTest(t).Groups(test.Full, test.Disconnected, test.ARM, test.Persistent).MinVersion(version.SMCP_2_4).Run(func(t test.TestHelper) {
 		t.Log("This test checks if the operator correctly reports its readiness status")
 
 		meshNamespace := env.GetDefaultMeshNamespace()

pkg/tests/ossm/ratelimit_test.go

@@ -41,7 +41,7 @@ var (
 )
 
 func TestRateLimiting(t *testing.T) {
-	NewTest(t).Id("T28").Groups(Full, ARM).MaxVersion(version.SMCP_2_2).Run(func(t TestHelper) {
+	NewTest(t).Id("T28").Groups(Full, ARM, Persistent).MaxVersion(version.SMCP_2_2).Run(func(t TestHelper) {
 		nsRedis := "redis"
 
 		DeployControlPlane(t)

pkg/tests/ossm/route_prevent_additional_ingress_test.go

@@ -29,7 +29,7 @@ import (
 )
 
 func TestRoutePreventAdditionalIngress(t *testing.T) {
-	NewTest(t).Id("T48").Groups(Full, ARM, Disconnected).MaxVersion(version.SMCP_2_5).Run(func(t TestHelper) {
+	NewTest(t).Id("T48").Groups(Full, ARM, Disconnected, Persistent).MaxVersion(version.SMCP_2_5).Run(func(t TestHelper) {
 
 		meshValues := map[string]interface{}{
 			"Version": env.GetSMCPVersion().String(),

pkg/tests/ossm/smcp_annotation_test.go

@@ -26,7 +26,7 @@ import (
 )
 
 func TestSMCPAnnotations(t *testing.T) {
-	test.NewTest(t).Id("T29").Groups(test.Full, test.ARM).Run(func(t test.TestHelper) {
+	test.NewTest(t).Id("T29").Groups(test.Full, test.ARM, test.Persistent).Run(func(t test.TestHelper) {
 		t.Log("Test annotations: verify deployment with sidecar.maistra.io/proxyEnv annotations and Enable automatic injection in SMCP to propagate the annotations to the sidecar")
 		t.Log("See https://issues.redhat.com/browse/OSSM-1074")
 

pkg/tests/ossm/smcp_logging_test.go

@@ -25,7 +25,7 @@ import (
 )
 
 func TestLogging(t *testing.T) {
-	NewTest(t).Groups(Full, Disconnected, ARM).Run(func(t TestHelper) {
+	NewTest(t).Groups(Full, Disconnected, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("This test verifies allowed logging levels for the control plane")
 		t.Log("See https://issues.redhat.com/browse/OSSM-6331")
 

pkg/tests/ossm/smcp_must_gather_test.go

@@ -34,7 +34,7 @@ import (
 )
 
 func TestMustGather(t *testing.T) {
-	NewTest(t).Id("T30").Groups(Full, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T30").Groups(Full, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("This test verifies must-gather log collection")
 
 		t.Cleanup(func() {

pkg/tests/ossm/smcp_secret_test.go

@@ -25,7 +25,7 @@ import (
 )
 
 func TestSMCPSecret(t *testing.T) {
-	NewTest(t).Id("T52").Groups(Full, Disconnected, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T52").Groups(Full, Disconnected, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("Verify that secret begins with $2a$, indicating it's been hashed with bcrypt")
 		t.Log("Reference: https://issues.redhat.com/browse/OSSM-1094")
 

pkg/tests/ossm/smcp_tls_ssl_test.go

@@ -21,7 +21,7 @@ import (
 )
 
 func TestTLSVersionSMCP(t *testing.T) {
-	NewTest(t).Id("T26").Groups(Full, ARM, InterOp, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T26").Groups(Full, ARM, InterOp, Disconnected, Persistent).Run(func(t TestHelper) {
 		t.Log("This test checks if the SMCP updated the tls.minProtocolVersion to TLSv1_0, TLSv1_1, and tls.maxProtocolVersion to TLSv1_3.")
 		t.Cleanup(func() {
 			oc.Patch(t, meshNamespace,

pkg/tests/ossm/smm_test.go

@@ -29,7 +29,7 @@ import (
 )
 
 func TestSMMRAutoCreationAndDeletion(t *testing.T) {
-	NewTest(t).Id("T39").Groups(Full, Disconnected, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T39").Groups(Full, Disconnected, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("This test verifies what happens to the SMMR when SMM is created and deleted")
 
 		t.Cleanup(func() {

pkg/tests/ossm/testssl_test.go

@@ -27,7 +27,7 @@ import (
 )
 
 func TestSSL(t *testing.T) {
-	NewTest(t).Id("T27").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T27").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		t.Cleanup(func() {
 			oc.Patch(t, meshNamespace, "smcp", smcpName, "json", `[{"op": "remove", "path": "/spec/security/controlPlane/tls"}]`)
 			oc.Patch(t, meshNamespace, "smcp", smcpName, "merge", `

pkg/tests/tasks/injection/native_sidecars_test.go

@@ -32,7 +32,7 @@ import (
 )
 
 func TestNativeSidecars(t *testing.T) {
-	NewTest(t).Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 		if version.ParseVersion(oc.GetOCPVersion(t)).LessThan(version.OCP_4_16) || env.GetSMCPVersion().LessThan(version.SMCP_2_6) {
 			t.Skip("Native sidecars are only supported in OpenShift 4.16+ and OSSM 2.6+")
 		}

pkg/tests/tasks/security/authentication/auth_test.go

@@ -35,7 +35,7 @@ import (
 )
 
 func TestAuthPolicy(t *testing.T) {
-	NewTest(t).Id("T18").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T18").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		meshNamespace := env.GetDefaultMeshNamespace()
 
 		t.Log("This test validates authentication policies.")

pkg/tests/tasks/security/authentication/mtls_migration_test.go

@@ -29,7 +29,7 @@ import (
 )
 
 func TestMTlsMigration(t *testing.T) {
-	NewTest(t).Id("T19").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T19").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 		meshNamespace := env.GetDefaultMeshNamespace()
 
 		t.Cleanup(func() {

pkg/tests/tasks/security/authorization/deny_test.go

@@ -25,7 +25,7 @@ import (
 )
 
 func TestAuthorizationDenyAllow(t *testing.T) {
-	NewTest(t).Id("T23").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T23").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 		ns := "foo"
 		curlOptsAdmin := app.CurlOpts{Headers: []string{"x-token: admin"}}
 		curlOptsGuest := app.CurlOpts{Headers: []string{"x-token: guest"}}

pkg/tests/tasks/security/authorization/ext_auth_test.go

@@ -29,7 +29,7 @@ import (
 )
 
 func TestEnvoyExtAuthzHttpExtensionProvider(t *testing.T) {
-	NewTest(t).Id("T37").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T37").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		if env.GetSMCPVersion().LessThan(version.SMCP_2_3) {
 			t.Skip("extensionProviders.envoyExtAuthzHttp was added in v2.3")
 		}
@@ -137,7 +137,7 @@ spec:
 }
 
 func TestEnvoyExtAuthzGrpcExtensionProvider(t *testing.T) {
-	NewTest(t).Id("T42").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T42").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		if env.GetSMCPVersion().LessThan(version.SMCP_2_3) {
 			t.Skip("extensionProviders.envoyExtAuthzGrpc is not supported in versions below v2.3")
 		}

pkg/tests/tasks/security/authorization/http_test.go

@@ -29,7 +29,7 @@ import (
 
 // TestAuthorizationHTTPTraffic validates authorization policies for HTTP traffic.
 func TestAuthorizationHTTPTraffic(t *testing.T) {
-	NewTest(t).Id("T20").Groups(Full, ARM, InterOp, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T20").Groups(Full, ARM, InterOp, Disconnected, Persistent).Run(func(t TestHelper) {
 		ns := "bookinfo"
 		t.Cleanup(func() {
 			oc.Patch(t,

pkg/tests/tasks/security/authorization/jwt_test.go

@@ -26,7 +26,7 @@ import (
 )
 
 func TestAuthorizationJWT(t *testing.T) {
-	test.NewTest(t).Id("T22").Groups(test.Full, test.InterOp, test.ARM).Run(func(t test.TestHelper) {
+	test.NewTest(t).Id("T22").Groups(test.Full, test.InterOp, test.ARM, test.Persistent).Run(func(t test.TestHelper) {
 		ns := "foo"
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns)

pkg/tests/tasks/security/authorization/tcp_test.go

@@ -27,7 +27,7 @@ import (
 
 // TestAuthorizationTCPTraffic validates authorization polices for TCP traffic.
 func TestAuthorizationTCPTraffic(t *testing.T) {
-	test.NewTest(t).Id("T21").Groups(test.Full, test.InterOp, test.ARM).Run(func(t test.TestHelper) {
+	test.NewTest(t).Id("T21").Groups(test.Full, test.InterOp, test.ARM, test.Persistent).Run(func(t test.TestHelper) {
 		ns := "foo"
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns)

pkg/tests/tasks/security/authorization/trust_domain_test.go

@@ -27,7 +27,7 @@ import (
 )
 
 func TestTrustDomainMigration(t *testing.T) {
-	NewTest(t).Id("T24").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T24").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 		foo := "foo"
 		bar := "bar"
 		httpbinUrl := "http://httpbin.foo:8000/ip"

pkg/tests/tasks/traffic/circuit_breaking_test.go

@@ -34,7 +34,7 @@ import (
 )
 
 func TestCircuitBreaking(t *testing.T) {
-	NewTest(t).Id("T6").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T6").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("This test checks whether the circuit breaker functions correctly. Check documentation: https://istio.io/latest/docs/tasks/traffic-management/circuit-breaking/")
 
 		t.Cleanup(func() {

pkg/tests/tasks/traffic/egress/access_external_services_test.go

@@ -31,7 +31,7 @@ import (
 )
 
 func TestAccessExternalServices(t *testing.T) {
-	NewTest(t).Id("T11").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T11").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 		smcpName := env.GetDefaultSMCPName()
 		t.Cleanup(func() {
 			app.Uninstall(t, app.Sleep(ns.Bookinfo))

pkg/tests/tasks/traffic/egress/egress_gateways_test.go

@@ -25,7 +25,7 @@ import (
 )
 
 func TestEgressGateways(t *testing.T) {
-	NewTest(t).Id("T13").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T13").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)
 		})

pkg/tests/tasks/traffic/egress/egress_gateways_tls_file_mount_test.go

@@ -92,7 +92,7 @@ func TestTLSOrigination(t *testing.T) {
 				// TODO: this is a potential bug; investigate why the following is necessary
 				// ingressgateway needs to be restarted or it will continue reporting the following error:
 				// error	cache	resource:file-root:/etc/istio/nginx-ca-certs/example.com.crt failed to generate secret for proxy from file: open /etc/istio/nginx-ca-certs/example.com.crt: no such file or directory
-				oc.DeletePod(t, pod.MatchingSelector("app=istio-ingressgateway", meshNamespace))
+				oc.DeletePod(t, pod.MatchingSelector(fmt.Sprintf("app=istio-ingressgateway,maistra-control-plane=%s", meshNamespace), meshNamespace))
 			})
 
 			t.LogStep("Deploy nginx mTLS server and create secrets in the mesh namespace")

pkg/tests/tasks/traffic/egress/egress_gateways_tls_sds_test.go

@@ -25,7 +25,7 @@ import (
 )
 
 func TestTLSOriginationSDS(t *testing.T) {
-	NewTest(t).Id("T15").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T15").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)
 			oc.RecreateNamespace(t, ns.MeshExternal)

pkg/tests/tasks/traffic/egress/egress_tls_origination_test.go

@@ -25,7 +25,7 @@ import (
 )
 
 func TestEgressTLSOrigination(t *testing.T) {
-	test.NewTest(t).Id("T12").Groups(test.Full, test.InterOp, test.ARM).Run(func(t test.TestHelper) {
+	test.NewTest(t).Id("T12").Groups(test.Full, test.InterOp, test.ARM, test.Persistent).Run(func(t test.TestHelper) {
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.MeshExternal)
 			app.Uninstall(t, app.Sleep(ns.Bookinfo))

pkg/tests/tasks/traffic/egress/egress_wildcard_hosts_test.go

@@ -27,7 +27,7 @@ import (
 )
 
 func TestEgressWildcard(t *testing.T) {
-	NewTest(t).Id("T16").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T16").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 		t.Log("This test checks if the wildcard in the ServiceEntry and Gateway works as expected for Egress traffic.")
 
 		ossm.DeployControlPlane(t)

pkg/tests/tasks/traffic/fault_injection_test.go

@@ -40,7 +40,7 @@ var (
 )
 
 func TestFaultInjection(t *testing.T) {
-	NewTest(t).Id("T2").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T2").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)

pkg/tests/tasks/traffic/ingress/gatewayapi_test.go

@@ -145,7 +145,7 @@ func TestGatewayApi(t *testing.T) {
 			t.LogStep("Verfiy the GatewayApi access the httpbin service using curl")
 			retry.UntilSuccess(t, func(t TestHelper) {
 				oc.Exec(t,
-					pod.MatchingSelector("app=istio-ingressgateway", meshNamespace),
+					pod.MatchingSelector(fmt.Sprintf("app=istio-ingressgateway,maistra-control-plane=%s", meshNamespace), meshNamespace),
 					"istio-proxy",
 					fmt.Sprintf("curl http://%s.foo.svc.cluster.local:8080/get -H Host:httpbin.example.com -s -o /dev/null -w %%{http_code}", gatewayapi.GetDefaultServiceName(env.GetSMCPVersion(), "gateway", "istio")),
 					assert.OutputContains("200",

pkg/tests/tasks/traffic/ingress/ingress_gateways_test.go

@@ -34,7 +34,7 @@ import (
 )
 
 func TestIngressGateways(t *testing.T) {
-	NewTest(t).Id("T8").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T8").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)

pkg/tests/tasks/traffic/ingress/ingress_without_tls_termination_test.go

@@ -33,7 +33,7 @@ import (
 )
 
 func TestIngressWithoutTlsTermination(t *testing.T) {
-	test.NewTest(t).Id("T10").Groups(test.Full, test.InterOp, test.ARM).Run(func(t test.TestHelper) {
+	test.NewTest(t).Id("T10").Groups(test.Full, test.InterOp, test.ARM, test.Persistent).Run(func(t test.TestHelper) {
 		t.Log("This test validates configuring an Gateway with TLS PassThrough")
 		t.Log("Doc reference: https://istio.io/v1.14/docs/tasks/traffic-management/ingress/ingress-sni-passthrough/")
 

pkg/tests/tasks/traffic/ingress/secure_gateways_test.go

@@ -48,7 +48,7 @@ var (
 )
 
 func TestSecureGateways(t *testing.T) {
-	NewTest(t).Id("T9").Groups(Full, InterOp, ARM).Run(func(t TestHelper) {
+	NewTest(t).Id("T9").Groups(Full, InterOp, ARM, Persistent).Run(func(t TestHelper) {
 
 		t.Log("This test verifies secure gateways.")
 		t.Log("Doc reference: https://istio.io/latest/docs/tasks/traffic-management/ingress/secure-ingress/")

pkg/tests/tasks/traffic/request_routing_test.go

@@ -30,7 +30,7 @@ import (
 )
 
 func TestRequestRouting(t *testing.T) {
-	NewTest(t).Id("T1").Groups(Smoke, Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T1").Groups(Smoke, Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)

pkg/tests/tasks/traffic/request_timeouts_test.go

@@ -35,7 +35,7 @@ import (
 var reviewTimeout string
 
 func TestRequestTimeouts(t *testing.T) {
-	NewTest(t).Id("T5").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T5").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)

pkg/tests/tasks/traffic/traffic_mirroring_test.go

@@ -29,7 +29,7 @@ import (
 )
 
 func TestMirroring(t *testing.T) {
-	NewTest(t).Id("T7").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T7").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)

pkg/tests/tasks/traffic/traffic_shifting_test.go

@@ -35,7 +35,7 @@ import (
 )
 
 func TestTrafficShifting(t *testing.T) {
-	NewTest(t).Id("T3").Groups(Full, InterOp, ARM, Disconnected).Run(func(t TestHelper) {
+	NewTest(t).Id("T3").Groups(Full, InterOp, ARM, Disconnected, Persistent).Run(func(t TestHelper) {
 
 		t.Cleanup(func() {
 			oc.RecreateNamespace(t, ns.Bookinfo)

pkg/tests/tasks/traffic/traffic_tcp_shifting_test.go

@@ -32,7 +32,7 @@ import (
 
 // TestTcpTrafficShifting validates TCP traffic shifting feature.
 func TestTcpTrafficShifting(t *testing.T) {
-	test.NewTest(t).Id("T4").Groups(test.Full, test.InterOp, test.ARM).Run(func(t test.TestHelper) {
+	test.NewTest(t).Id("T4").Groups(test.Full, test.InterOp, test.ARM, test.Persistent).Run(func(t test.TestHelper) {
 
 		t.Cleanup(func() {
 			app.Uninstall(t, app.Sleep(ns.Foo), app.EchoV1(ns.Foo), app.EchoV2(ns.Foo))