always a stupid typo

PeerDB-io · Feb 23, 2024 · 6aed0b3 · 6aed0b3
1 parent 0e862d3
commit 6aed0b3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flow/workflows/sync_flow.go b/flow/workflows/sync_flow.go
@@ -194,7 +194,7 @@ func SyncFlowWorkflow(
 			}
 		})
 
-		for ctx.Err() == nil && !syncDone && !selector.HasPending() {
+		for ctx.Err() == nil && !syncDone && selector.HasPending() {
 			selector.Select(ctx)
 		}
 		if ctx.Err() != nil {
@@ -206,7 +206,7 @@ func SyncFlowWorkflow(
 			waitChan.Receive(ctx)
 			if restart {
 				// must flush selector for signals received while waiting
-				for ctx.Err() == nil && !selector.HasPending() {
+				for ctx.Err() == nil && selector.HasPending() {
 					selector.Select(ctx)
 				}
 				break