Struct DagScheduler 

pub struct DagScheduler<Q: JobQueue, A: ArtifactStore> { /* private fields */ }

Event-driven DAG scheduler.

Listens for JobEvents from the queue and enqueues downstream jobs when their dependencies are satisfied. Replaces the inline orchestrator.

Implementations

impl<Q: JobQueue, A: ArtifactStore> DagScheduler<Q, A>

pub fn new(queue: Arc<Q>, artifacts: Arc<A>, state: SharedState) -> Self

pub async fn start_workflow( &self, workflow_id: &str, ) -> Result<(), SchedulerError>

Initiate a workflow run: reset all jobs to Queued, then enqueue root jobs.

pub async fn cancel_workflow( &self, workflow_id: &str, ) -> Result<(), SchedulerError>

Cancel a running workflow: cancel all pending/active jobs.

pub async fn run(self: Arc<Self>)

Run the scheduler event loop. Listens for queue events and drives the DAG. This should be spawned as a background task.