bring back batch size signal check

PeerDB-io · Dec 12, 2023 · b12149a · b12149a
1 parent a1e8d05
commit b12149a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -394,6 +394,7 @@ func CDCFlowWorkflowWithConfig(
 		}
 
 		w.logger.Info("Total records synced: ", totalRecordsSynced)
+		batchSizeSelector.Select(ctx)
 	}
 
 	workflow.SignalExternalWorkflow(ctx, normExecution.ID, normExecution.RunID, "StopLoop", true)