Class _ChildA

tests/unittests/runners/test_runner_node.py:885–890

  """

  class _ChildA(BaseNode):

    async def _run_impl(
        self, *, ctx: Context, node_input: Any
    ) -> AsyncGenerator[Any, None]:
      yield 'child_a_output'

  class _ChildB(BaseNode):
    rerun_on_resume: bool = True