Expand description
The DAG engine: graph, scheduler, worker pool, and the executor that drives them.
DagExecutor is the entry point. It validates a Dag, optionally
recovers persisted state, then runs tasks concurrently — respecting
dependencies, priorities, retries, the circuit breaker, and the dead-letter
queue — and returns an ExecutionReport.
Structs§
- Dag
- A directed acyclic graph of tasks.
- DagExecutor
- Executes DAGs of tasks with persistence, fault-tolerance and observability.
- DagExecutor
Builder - Fluent builder for
DagExecutor. - Execution
Report - Summary of a completed (or cancelled) run.
- Scheduler
- Tracks the state of every task and serves the next ready task by priority.
- Task
Result - The final result of running one task (after any retries).
- Worker
Pool - Executes tasks concurrently under a global concurrency limit.