refactor(workflow): move _merge_conv_vars call inside iteration loop for consistent state updates

2026-04-13 19:00:36 +08:00
parent 7ca80b5d01
commit 2450fe3afe
1 changed files with 1 additions and 1 deletions
--- a/api/app/core/workflow/nodes/cycle_graph/iteration.py
+++ b/api/app/core/workflow/nodes/cycle_graph/iteration.py
@@ -249,9 +249,9 @@ class IterationRuntime:
                    else:
                        self.result.append(output)
                    child_state.append(result)
+                    self._merge_conv_vars(child_pool)
                    if stopped:
                        self.looping = False
-                self._merge_conv_vars(batch_sorted[-1][3])
        else:
            # Execute iterations sequentially
            while idx < len(array_obj) and self.looping: