Struct DagExecutor 

pub struct DagExecutor { /* private fields */ }

Executes DAGs of tasks with persistence, fault-tolerance and observability.

Implementations

impl DagExecutor

pub fn builder() -> DagExecutorBuilder

Start building an executor.

pub fn new() -> Self

Build an executor with all defaults.

pub fn metrics(&self) -> &Arc<MetricsCollector>

Access the metrics collector (live during a run).

pub fn dead_letter(&self) -> &DeadLetterQueue

Access the dead-letter queue.

pub async fn run(&self, dag: Dag) -> Result<ExecutionReport>

Run dag to completion with a fresh context.

pub async fn run_with_context( &self, dag: Dag, ctx: Arc<Context>, ) -> Result<ExecutionReport>

Run dag using a caller-supplied Context.

This is the hook for graceful shutdown: hold a clone of ctx and call Context::cancel (e.g. on SIGINT) to stop scheduling new work.

Trait Implementations

impl Default for DagExecutor

fn default() -> Self

Returns the “default value” for a type.