patch that test

PeerDB-io · Apr 30, 2024 · 1ce9f72 · 1ce9f72
1 parent dccb413
commit 1ce9f72
Showing 1 changed file with 0 additions and 11 deletions.
diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go
@@ -1212,17 +1212,6 @@ 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.EnvWaitFor(s.t, env, 3*time.Minute, "normalize transaction", func() bool {
-		pgRows, err := e2e.GetPgRows(s.conn, s.bqSuffix, srcName, "id,c1,c2,t")
-		e2e.EnvNoError(s.t, env, err)
-		rows, err := s.GetRowsWhere(dstName, "id,c1,c2,t", "NOT _PEERDB_IS_DELETED")
-		if err != nil {
-			return false
-		}
-		return e2eshared.CheckEqualRecordBatches(s.t, pgRows, rows)
-	})
-
 	env.Cancel()
 	e2e.RequireEnvCanceled(s.t, env)