Merge branch 'main' into bq/use-source-for-avro-schema

PeerDB-io · May 7, 2024 · 8715b10 · 8715b10
2 parents ffe19ed + 5104b00
commit 8715b10
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/workflows/qrep_flow.go b/flow/workflows/qrep_flow.go
@@ -570,7 +570,7 @@ func QRepFlowWorkflow(
 		return err
 	}
 
-	if state.LastPartition != nil {
+	if !config.InitialCopyOnly && state.LastPartition != nil {
 		if err := q.waitForNewRows(ctx, signalChan, state.LastPartition); err != nil {
 			return err
 		}