e2e: Relax error checking in logs (#705)

netobserv · Sep 2, 2024 · 123bb9d · 123bb9d
1 parent 72029f5
commit 123bb9d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/test/e2e/kafka/kafka_test.go b/pkg/test/e2e/kafka/kafka_test.go
@@ -30,6 +30,7 @@ import (
 	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"sigs.k8s.io/e2e-framework/klient/k8s/resources"
 	"sigs.k8s.io/e2e-framework/klient/wait"
 	"sigs.k8s.io/e2e-framework/klient/wait/conditions"
 	"sigs.k8s.io/e2e-framework/pkg/envconf"
@@ -105,7 +106,7 @@ func TestKafka_Basic(t *testing.T) {
 			}
 
 			var pods corev1.PodList
-			err = client.Resources(cfg.Namespace()).List(context.TODO(), &pods)
+			err = client.Resources(cfg.Namespace()).List(context.TODO(), &pods, resources.WithLabelSelector("app=flowlogs-pipeline"))
 			if err != nil {
 				t.Fatal(err)
 			}