test: added wait to S3 e2e source and sink tests

argoproj-labs · Sep 17, 2021 · 8fe4116 · 8fe4116
1 parent d2bf012
commit 8fe4116
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git 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
@@ -34,6 +34,7 @@ func TestS3Source(t *testing.T) {
 		},
 	})
 
+	WaitForPipeline()
 	WaitForPod()
 
 	defer StartPortForward("s3-main-0")()