Method _run_impl

tests/unittests/runners/test_runner_node.py:1040–1045

(
        self, *, ctx: Context, node_input: Any
    )

    rerun_on_resume: bool = True

    async def _run_impl(
        self, *, ctx: Context, node_input: Any
    ) -> AsyncGenerator[Any, None]:
      call_counts['middle'] += 1
      inner_out = await ctx.run_node(_Inner(name='inner'), 'go')
      yield f'middle({inner_out})'

  class _Outer(BaseNode):
    rerun_on_resume: bool = True