| 1023 | call_counts = {'outer': 0, 'middle': 0, 'inner': 0} |
| 1024 | |
| 1025 | class _Inner(BaseNode): |
| 1026 | rerun_on_resume: bool = True |
| 1027 | |
| 1028 | async def _run_impl( |
| 1029 | self, *, ctx: Context, node_input: Any |
| 1030 | ) -> AsyncGenerator[Any, None]: |
| 1031 | call_counts['inner'] += 1 |
| 1032 | if ctx.resume_inputs and 'fc-1' in ctx.resume_inputs: |
| 1033 | yield f'inner_resumed:{ctx.resume_inputs["fc-1"]["v"]}' |
| 1034 | return |
| 1035 | yield _make_interrupt_event(fc_name='ask', fc_id='fc-1') |
| 1036 | |
| 1037 | class _Middle(BaseNode): |
| 1038 | rerun_on_resume: bool = True |