Function parent_b

tests/unittests/workflow/test_workflow_dynamic_nodes.py:661–663

(*, ctx, node_input)

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

  from google.adk.workflow import JoinNode