Struct Executor 

pub struct Executor;

Single-threaded task graph executor.

Executes an ExecutionPlan wave by wave, propagating outputs from completed tasks to downstream consumers via DataRef name matching. Failed tasks are retried up to TaskDef::retries times; if retries are exhausted, all transitive downstream tasks are marked TaskStatus::Skipped.

Implementations

impl Executor

pub fn new() -> Self

Create a new executor.

pub fn run(plan: ExecutionPlan) -> Result<ExecutionResult, FabricError>

Execute the plan, consuming it.

Tasks are executed sequentially within each wave. Outputs from completed tasks are stored and made available as inputs to downstream tasks matched by DataRef::name.

Trait Implementations

impl Default for Executor

fn default() -> Self

Returns the “default value” for a type.