diff --git a/test/s3-e2e/s3_sink_test.go b/test/s3-e2e/s3_sink_test.go
index a46c2f6c..ea21b86a 100644
--- a/test/s3-e2e/s3_sink_test.go
+++ b/test/s3-e2e/s3_sink_test.go
@@ -46,6 +46,7 @@ func Handler(ctx context.Context, m []byte) ([]byte, error) {
 		},
 	})
 
+	WaitForPipeline()
 	WaitForPod()
 
 	defer StartPortForward("s3-main-0")()
diff --git a/test/s3-e2e/s3_source_test.go b/test/s3-e2e/s3_source_test.go
index 51452de4..bd66ae55 100644
--- a/test/s3-e2e/s3_source_test.go
+++ b/test/s3-e2e/s3_source_test.go
@@ -34,6 +34,7 @@ func TestS3Source(t *testing.T) {
 		},
 	})
 
+	WaitForPipeline()
 	WaitForPod()
 
 	defer StartPortForward("s3-main-0")()