(idx: int, item_ctx: StepContext)
| 1069 | return f"{step_id}:{base_id}:{idx}" |
| 1070 | |
| 1071 | def run_item(idx: int, item_ctx: StepContext) -> Any: |
| 1072 | item_step = dict(template) |
| 1073 | item_step["id"] = item_id(idx) |
| 1074 | self._execute_steps( |
| 1075 | [item_step], item_ctx, state, registry, step_offset=-1, |
| 1076 | ) |
| 1077 | # Read back through the context that was actually executed against, |
| 1078 | # not the outer closure — clearer and robust if StepContext copying |
| 1079 | # ever stops sharing the steps dict by reference. |
| 1080 | return item_ctx.steps.get(item_step["id"], {}).get("output", {}) |
| 1081 | |
| 1082 | # Sequential path — identical to the historical behavior. |
| 1083 | if workers <= 1: |
nothing calls this directly
no test coverage detected