Function parent_node

tests/unittests/workflow/test_workflow_dynamic_nodes.py:1187–1190

(*, ctx, node_input)

  @node(rerun_on_resume=True)
  async def parent_node(*, ctx, node_input):
    tasks = [ctx.run_node(echo_node, node_input=f'call_{i}') for i in range(3)]
    results = await asyncio.gather(*tasks)
    yield results

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