Struct DagExecutor 

pub struct DagExecutor { /* private fields */ }

DAG executor for managing task dependencies

Implementations

impl DagExecutor

pub fn new() -> DagExecutor

Create a new DAG executor

pub fn add_task(&mut self, task: Task) -> Result<(), PolarisError>

Add a task to the DAG

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

Validate the DAG for cycles

pub fn get_ready_tasks(&self) -> Vec<TaskId>

Get tasks ready to execute (no pending dependencies)

pub fn topological_sort(&self) -> Result<Vec<TaskId>, PolarisError>

Get topological ordering of tasks

pub fn update_task_status(&mut self, task_id: TaskId, status: TaskStatus)

Update task status

pub fn get_task(&self, task_id: TaskId) -> Option<&Task>

Get task by ID

Trait Implementations

impl Debug for DagExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for DagExecutor

fn default() -> DagExecutor

Returns the “default value” for a type.