skip wait for normalize if already handled stop

PeerDB-io · Feb 23, 2024 · d46ef65 · d46ef65
1 parent 068a18a
commit d46ef65
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/workflows/sync_flow.go b/flow/workflows/sync_flow.go
@@ -207,7 +207,7 @@ func SyncFlowWorkflow(
 		}
 
 		restart := currentSyncFlowNum >= maxSyncsPerSyncFlow || syncErr
-		if mustWait {
+		if !stop && mustWait {
 			waitSelector.Select(ctx)
 			if restart {
 				// must flush selector for signals received while waiting