diff --git a/api/app/core/workflow/nodes/base_node.py b/api/app/core/workflow/nodes/base_node.py index e9fa4f25..8eb31fb4 100644 --- a/api/app/core/workflow/nodes/base_node.py +++ b/api/app/core/workflow/nodes/base_node.py @@ -356,7 +356,8 @@ class BaseNode(ABC): **final_output, "runtime_vars": { self.node_id: runtime_var - } + }, + "looping": state["looping"] } # Add streaming buffer for non-End nodes