NumberOfSyncs pause not triggered on errors

PeerDB-io · Dec 24, 2024 · 467fd28 · 467fd28
1 parent 85dbc04
commit 467fd28
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -503,12 +503,12 @@ func CDCFlowWorkflow(
 			_ = workflow.Sleep(ctx, 30*time.Second)
 		} else {
 			logger.Info("sync finished")
+			if state.SyncFlowOptions.NumberOfSyncs > 0 {
+				state.ActiveSignal = model.PauseSignal
+			}
 		}
 		syncFlowFuture = nil
 		finished = true
-		if state.SyncFlowOptions.NumberOfSyncs > 0 {
-			state.ActiveSignal = model.PauseSignal
-		}
 	})
 
 	flowSignalChan.AddToSelector(mainLoopSelector, func(val model.CDCFlowSignal, _ bool) {