Method _run_impl

tests/unittests/runners/test_runner_node.py:1050–1055

(
        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['outer'] += 1
      mid_out = await ctx.run_node(_Middle(name='middle'), 'start')
      yield f'outer({mid_out})'

  events1, events2, _, _, _ = await _run_two_turns(
      _Outer(name='top'),