Module chain_execute 

Spawn ChainedStreamTask from a ChainJob (framework-only, no committer).

Functions

execute

Run the built operator chain until Ctrl+C, task failure, or checkpoint manager exit.

spawn_chained_tasks

Build one pending chain task per subtask from the env’s ChainJob.