(ctx: Context, node_input: str)
| 26 | |
| 27 | @node(rerun_on_resume=True) |
| 28 | async def orchestrate(ctx: Context, node_input: str) -> str: |
| 29 | return await ctx.run_node( |
| 30 | summarizer, node_input=node_input, use_as_output=True |
| 31 | ) |
| 32 | |
| 33 | |
| 34 | def finalize(node_input: str) -> str: |