test: remove pending check

argoproj-labs · Oct 8, 2021 · 5301aa7 · 5301aa7
1 parent c872a18
commit 5301aa7
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/test/kafka-stress/kafka_stress_test.go b/test/kafka-stress/kafka_stress_test.go
@@ -106,8 +106,6 @@ func testKafkaSinkStress(t *testing.T, async bool) {
 	defer StartTPSReporter(t, "main", prefix, n)()
 
 	go PumpKafkaTopic(topic, n, prefix, Params.MessageSize)
-	WaitForPending(Params.Timeout)
-	WaitForNothingPending(Params.Timeout)
 	WaitForTotalSourceMessages(n, Params.Timeout)
 	WaitForTotalSunkMessages(n, Params.Timeout)
 }