Method _run_impl

tests/unittests/runners/test_runner_node.py:148–152

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

  class _Node(BaseNode):

    async def _run_impl(
        self, *, ctx: Context, node_input: Any
    ) -> AsyncGenerator[Any, None]:
      yield Event(state={'step': 'processing'})
      yield 'final_result'

  events, _, _ = await _run_node(_Node(name='steps'))