| 890 | yield 'child_a_output' |
| 891 | |
| 892 | class _ChildB(BaseNode): |
| 893 | rerun_on_resume: bool = True |
| 894 | |
| 895 | async def _run_impl( |
| 896 | self, *, ctx: Context, node_input: Any |
| 897 | ) -> AsyncGenerator[Any, None]: |
| 898 | if ctx.resume_inputs and 'fc-1' in ctx.resume_inputs: |
| 899 | yield f'resumed: {ctx.resume_inputs["fc-1"]["answer"]}' |
| 900 | return |
| 901 | yield _make_interrupt_event(fc_name='ask', fc_id='fc-1') |
| 902 | |
| 903 | class _ParentNode(BaseNode): |
| 904 | rerun_on_resume: bool = True |