From 88d53885feb697361934ce7c3e464b595c6a9bb4 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Tue, 30 Apr 2024 17:33:06 +0530 Subject: [PATCH] add wait for equal tables --- flow/e2e/bigquery/peer_flow_bq_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go index 900638f620..8525c32e31 100644 --- a/flow/e2e/bigquery/peer_flow_bq_test.go +++ b/flow/e2e/bigquery/peer_flow_bq_test.go @@ -1212,6 +1212,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Soft_Delete_UD_Same_Batch() { DELETE FROM %s WHERE id=1`, srcTableName)) e2e.EnvNoError(s.t, env, err) e2e.EnvNoError(s.t, env, insertTx.Commit(context.Background())) + e2e.EnvWaitForEqualTables(env, s, "normalize ud soft delete", dstName, "id,c1,c2,t") env.Cancel() e2e.RequireEnvCanceled(s.t, env)