(*, ctx, node_input)
| 654 | |
| 655 | @node(rerun_on_resume=True) |
| 656 | async def parent_a(*, ctx, node_input): |
| 657 | result = await ctx.run_node(child, node_input='complete') |
| 658 | yield f'a: {result}' |
| 659 | |
| 660 | @node(rerun_on_resume=True) |
| 661 | async def parent_b(*, ctx, node_input): |