diff --git a/flow/workflows/normalize_flow.go b/flow/workflows/normalize_flow.go
index a13acc33f8..405e7b858e 100644
--- 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