| 1035 | yield _make_interrupt_event(fc_name='ask', fc_id='fc-1') |
| 1036 | |
| 1037 | class _Middle(BaseNode): |
| 1038 | rerun_on_resume: bool = True |
| 1039 | |
| 1040 | async def _run_impl( |
| 1041 | self, *, ctx: Context, node_input: Any |
| 1042 | ) -> AsyncGenerator[Any, None]: |
| 1043 | call_counts['middle'] += 1 |
| 1044 | inner_out = await ctx.run_node(_Inner(name='inner'), 'go') |
| 1045 | yield f'middle({inner_out})' |
| 1046 | |
| 1047 | class _Outer(BaseNode): |
| 1048 | rerun_on_resume: bool = True |