(
self, *, ctx: Context, node_input: Any
)
| 985 | rerun_on_resume: bool = True |
| 986 | |
| 987 | async def _run_impl( |
| 988 | self, *, ctx: Context, node_input: Any |
| 989 | ) -> AsyncGenerator[Any, None]: |
| 990 | if ctx.resume_inputs and 'fc-1' in ctx.resume_inputs: |
| 991 | yield f'approved: {ctx.resume_inputs["fc-1"]["ok"]}' |
| 992 | return |
| 993 | yield _make_interrupt_event(fc_name='approve', fc_id='fc-1') |
| 994 | |
| 995 | class _Parent(BaseNode): |
| 996 | rerun_on_resume: bool = True |
nothing calls this directly
no test coverage detected