From 6aed0b3021039bebea990ad01ba34880448bfc76 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Fri, 23 Feb 2024 20:41:53 +0000 Subject: [PATCH] always a stupid typo --- flow/workflows/sync_flow.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flow/workflows/sync_flow.go b/flow/workflows/sync_flow.go index 7a1fc11571..567d772746 100644 --- 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