don't signal normFlowFuture if normFlowFuture already done when sync …

…flow finishes
PeerDB-io · Mar 5, 2024 · 240b5e3 · 240b5e3
1 parent 6f26120
commit 240b5e3
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -428,13 +428,15 @@ func CDCFlowWorkflow(
 		logger.Info("sync finished, finishing normalize")
 		syncFlowFuture = nil
 		restart = true
-		err = model.NormalizeSignal.SignalChildWorkflow(ctx, normFlowFuture, model.NormalizePayload{
-			Done:        true,
-			SyncBatchID: -1,
-		}).Get(ctx, nil)
-		if err != nil {
-			logger.Warn("failed to signal normalize done, finishing", slog.Any("error", err))
-			finished = true
+		if normFlowFuture != nil {
+			err = model.NormalizeSignal.SignalChildWorkflow(ctx, normFlowFuture, model.NormalizePayload{
+				Done:        true,
+				SyncBatchID: -1,
+			}).Get(ctx, nil)
+			if err != nil {
+				logger.Warn("failed to signal normalize done, finishing", slog.Any("error", err))
+				finished = true
+			}
 		}
 	})
 	mainLoopSelector.AddFuture(normFlowFuture, func(f workflow.Future) {