add wait for equal tables

PeerDB-io · Apr 30, 2024 · 88d5388 · 88d5388
1 parent 1ce9f72
commit 88d5388
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)