Function parent

tests/unittests/workflow/test_workflow_dynamic_nodes.py:121–123

(*, ctx, node_input)

  @node(rerun_on_resume=True)
  async def parent(*, ctx, node_input):
    result = await ctx.run_node(child, node_input='hello')
    yield f'parent got: {result}'

  wf = Workflow(name='wf', edges=[(START, parent)])
  ss = InMemorySessionService()