diff --git a/flow/workflows/qrep_flow.go b/flow/workflows/qrep_flow.go
index a988e1f96c..8be2619866 100644
--- 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
 		}