(
self, *, ctx: Context, node_input: Any
)
| 1164 | rerun_on_resume: bool = True |
| 1165 | |
| 1166 | async def _run_impl( |
| 1167 | self, *, ctx: Context, node_input: Any |
| 1168 | ) -> AsyncGenerator[Any, None]: |
| 1169 | target_id = f'fc-{ctx.run_id}' |
| 1170 | if ctx.resume_inputs and target_id in ctx.resume_inputs: |
| 1171 | yield f"resumed:{ctx.resume_inputs[target_id]['v']}" |
| 1172 | return |
| 1173 | yield _make_interrupt_event(fc_name='ask', fc_id=target_id) |
| 1174 | |
| 1175 | class _ParentNode(BaseNode): |
| 1176 | rerun_on_resume: bool = True |
nothing calls this directly
no test coverage detected