Struct TaskGraph 

pub struct TaskGraph { /* private fields */ }

Builder for constructing a task DAG.

Tasks are added with add_task and dependency edges with add_dependency. Call build to validate the graph and compute an ExecutionPlan.

Implementations

impl TaskGraph

pub fn new() -> Self

Create an empty task graph.

pub fn add_task(&mut self, def: TaskDef) -> TaskId

Add a task and return its assigned TaskId.

pub fn add_dependency( &mut self, from: TaskId, to: TaskId, ) -> Result<(), FabricError>

Declare that to depends on from (i.e. from must complete before to can start).

Errors

Returns FabricError::IoError(-100) if either task ID does not exist in the graph.

pub fn validate(&self) -> Result<(), FabricError>

Validate the graph: check for cycles and unresolved data references.

Errors

Returns FabricError::IoError(-101) if a cycle is detected. Returns FabricError::IoError(-102) if a task has an input with no upstream producer.

pub fn build(self) -> Result<ExecutionPlan, FabricError>

Validate and compute an ExecutionPlan with topologically sorted waves. Consumes the graph.

Errors

Returns the same errors as validate.

Trait Implementations

impl Default for TaskGraph

fn default() -> Self

Returns the “default value” for a type.