Struct TaskGraph 

pub struct TaskGraph { /* private fields */ }

Task graph for managing dependencies.

Implementations

impl TaskGraph

pub fn new() -> Self

Create a new task graph.

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

Add a task to the graph.

pub fn remove_task(&self, task_id: TaskId) -> Result<()>

Remove a task from the graph.

pub fn get_task(&self, task_id: TaskId) -> Result<Arc<RwLock<Task>>>

Get a task by ID.

pub fn get_all_tasks(&self) -> Vec<Arc<RwLock<Task>>>

Get all tasks.

pub fn get_tasks_by_status(&self, status: TaskStatus) -> Vec<Arc<RwLock<Task>>>

Get tasks by status.

pub fn update_task_status( &self, task_id: TaskId, status: TaskStatus, ) -> Result<()>

Update task status.

pub fn set_task_result(&self, task_id: TaskId, result: TaskResult) -> Result<()>

Set task result.

pub fn set_task_error(&self, task_id: TaskId, error: String) -> Result<()>

Set task error.

pub fn get_cached_result(&self, name: &str) -> Option<Arc<TaskResult>>

Get cached result by task name.

pub fn clear_result_cache(&self)

Clear result cache.

pub fn build_execution_plan(&self) -> Result<ExecutionPlan>

Build execution plan using topological sort.

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

Optimize the graph by fusing compatible tasks.

pub fn prune_completed(&self) -> Result<usize>

Prune completed tasks from the graph.

pub fn get_statistics(&self) -> TaskGraphStatistics

Get graph statistics.

Trait Implementations

impl Default for TaskGraph

fn default() -> Self

Returns the “default value” for a type.