| 144 | """Runner yields intermediate events (e.g. state), not just output.""" |
| 145 | |
| 146 | class _Node(BaseNode): |
| 147 | |
| 148 | async def _run_impl( |
| 149 | self, *, ctx: Context, node_input: Any |
| 150 | ) -> AsyncGenerator[Any, None]: |
| 151 | yield Event(state={'step': 'processing'}) |
| 152 | yield 'final_result' |
| 153 | |
| 154 | events, _, _ = await _run_node(_Node(name='steps')) |
| 155 |
no outgoing calls