From 8fe41163d84686baa0622916db0c36756501e609 Mon Sep 17 00:00:00 2001
From: Alex Collins <alex_collins@intuit.com>
Date: Thu, 16 Sep 2021 17:27:25 -0700
Subject: [PATCH] test: added wait to S3 e2e source and sink tests

---
 test/s3-e2e/s3_sink_test.go   | 1 +
 test/s3-e2e/s3_source_test.go | 1 +
 2 files changed, 2 insertions(+)

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")()