feat(workflow): fix concurrent update conflict of looping flag in parallel loop nodes

2026-01-06 10:35:43 +08:00
parent 71c5b54532
commit 0300abc454
1 changed files with 1 additions and 1 deletions
--- a/api/app/core/workflow/nodes/base_node.py
+++ b/api/app/core/workflow/nodes/base_node.py
@@ -29,7 +29,7 @@ class WorkflowState(TypedDict):

    # Set of loop node IDs, used for assigning values in loop nodes
    cycle_nodes: list
-    looping: bool
+    looping: Annotated[bool, lambda x, y: x and y]

    # Input variables (passed from configured variables)
    # Uses a deep merge function, supporting nested dict updates (e.g., conv.xxx)