Call Get on SignalExternalWorkflow, maybe issue is immediate Continue…

…AsNew
PeerDB-io · Feb 23, 2024 · 0e862d3 · 0e862d3
1 parent e655f5e
commit 0e862d3
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/flow/workflows/normalize_flow.go b/flow/workflows/normalize_flow.go
@@ -113,12 +113,16 @@ func NormalizeFlowWorkflow(
 	}
 
 	if !peerdbenv.PeerDBEnableParallelSyncNormalize() {
-		model.NormalizeDoneSignal.SignalExternalWorkflow(
+		err := model.NormalizeDoneSignal.SignalExternalWorkflow(
 			ctx,
 			parent.ID,
 			"",
 			struct{}{},
-		)
+		).Get(ctx, nil)
+		if err != nil {
+			logger.Error("Failed to signal completion", slog.Any("error", err))
+			return err
+		}
 	}
 
 	state.Wait = true