Fix await condition

temporalio · Feb 5, 2025 · 9467050 · 9467050
1 parent eee06ce
commit 9467050
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/shoppingcart/workflow.go b/shoppingcart/workflow.go
@@ -58,7 +58,14 @@ func CartWorkflow(ctx workflow.Context, cart *CartState) error {
 
 	signalChan := workflow.GetSignalChannel(ctx, "checkout")
 
-	err := workflow.Await(ctx, func() bool { return workflow.GetInfo(ctx).GetContinueAsNewSuggested() || signalChan.Receive(ctx, nil) })
+	err := workflow.Await(ctx, func() bool {
+		if workflow.GetInfo(ctx).GetContinueAsNewSuggested() {
+			return true
+		}
+		signalChan.Receive(ctx, nil)
+
+		return true
+	})
 	if err != nil {
 		return err
 	}