don't call getMaxSyncsPerCDCFlow in loop

this was spamming temporal history
PeerDB-io · Jun 22, 2024 · d811bd0 · d811bd0
1 parent 38dd81f
commit d811bd0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -521,6 +521,7 @@ func CDCFlowWorkflow(
 	addCdcPropertiesSignalListener(ctx, logger, mainLoopSelector, state)
 
 	state.CurrentFlowStatus = protos.FlowStatus_STATUS_RUNNING
+	maxSyncPerCDCFlow := int(getMaxSyncsPerCDCFlow(ctx, logger))
 	for {
 		mainLoopSelector.Select(ctx)
 		for ctx.Err() == nil && mainLoopSelector.HasPending() {
@@ -531,7 +532,7 @@ func CDCFlowWorkflow(
 			return state, err
 		}
 
-		if state.ActiveSignal == model.PauseSignal || syncCount >= int(getMaxSyncsPerCDCFlow(ctx, logger)) {
+		if state.ActiveSignal == model.PauseSignal || syncCount >= maxSyncPerCDCFlow {
 			restart = true
 			if syncFlowFuture != nil {
 				err := model.SyncStopSignal.SignalChildWorkflow(ctx, syncFlowFuture, struct{}{}).Get(ctx, nil)