Skip to content

Commit 0082e3e

Browse files
committed
fix: enable iterations for for_each
1 parent 8a7563e commit 0082e3e

1 file changed

Lines changed: 9 additions & 1 deletion

File tree

src/workflows_mcp/engine/execution.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -225,9 +225,17 @@ def set_for_each_result(
225225

226226
iteration_executions[iteration_key] = iter_exec
227227

228+
# Build iterations output as a list for downstream chaining (outputs.iterations)
229+
# List format works for both for_each inputs (engine converts to indexed dict)
230+
# and for direct iteration in Shell blocks (for s in summaries)
231+
iterations_output = [iter_exec.outputs for iter_exec in iteration_executions.values()]
232+
228233
# Store parent with iterations as child blocks
229234
parent_exec = Execution(
230-
inputs={}, outputs={}, blocks=iteration_executions, metadata=parent_meta
235+
inputs={},
236+
outputs={"iterations": iterations_output},
237+
blocks=iteration_executions,
238+
metadata=parent_meta,
231239
)
232240
self.blocks[block_id] = parent_exec
233241

0 commit comments

Comments
 (0)