Method _run_impl

tests/unittests/workflow/test_workflow.py:1397–1402

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

    rerun_on_resume: bool = True

    async def _run_impl(
        self, *, ctx: Context, node_input: Any
    ) -> AsyncGenerator[Any, None]:
      await ctx.run_node(func_b, use_as_output=True)
      return
      yield

  wf = Workflow(name='wf', edges=[(START, _Delegator(name='delegator'))])
  events, _, _ = await _run_workflow(wf)