fix up syncErr handling

PeerDB-io · Feb 28, 2024 · 81b0259 · 81b0259
1 parent 1e408f1
commit 81b0259
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/flow/workflows/sync_flow.go b/flow/workflows/sync_flow.go
@@ -110,7 +110,6 @@ func SyncFlowWorkflow(
 					err.Error(),
 				).Get(ctx, nil)
 				syncErr = true
-				mustWait = false
 			} else if childSyncFlowRes != nil {
 				_ = model.SyncResultSignal.SignalExternalWorkflow(
 					ctx,
@@ -180,15 +179,15 @@ func SyncFlowWorkflow(
 			}
 		})
 
-		for ctx.Err() == nil && (!syncDone || selector.HasPending()) {
+		for ctx.Err() == nil && (syncErr || !syncDone || selector.HasPending()) {
 			selector.Select(ctx)
 		}
 		if ctx.Err() != nil {
 			break
 		}
 
 		restart := currentSyncFlowNum >= maxSyncsPerSyncFlow || syncErr
-		if !stop && mustWait {
+		if !stop && !syncErr && mustWait {
 			waitSelector.Select(ctx)
 			if restart {
 				// must flush selector for signals received while waiting