Module runtime 

Modules

chain_job

Linear operator chain built at DSL time (no per-step graph nodes).

chain_segment

In-process operator chain steps (fused subtask, no inter-op channels).

chained_stream_task

In-process operator chain (framework-only; no connector channel types).

checkpoint_manager

control_msg

job_runtime

Job-level task handles for graceful shutdown.

pending_task

Deferred task launch for chain execution (collect then spawn).

runtime_context

Re-exports for backward compatibility. Prefer crate::api::context.

task_lifecycle

Spawn helpers: forward task Err, join failures, and panics to the job error_tx.