Struct TaskDAG 

pub struct TaskDAG {
    pub dependencies: HashMap<String, Vec<String>>,
    pub dependents: HashMap<String, Vec<String>>,
    pub tasks: HashMap<String, AgentTask>,
}

Directed Acyclic Graph (DAG) for task execution

Fields

dependencies: HashMap<String, Vec<String>>

Map of task ID to its dependencies

dependents: HashMap<String, Vec<String>>

Map of task ID to tasks that depend on it

tasks: HashMap<String, AgentTask>

All tasks in the DAG

Implementations

impl TaskDAG

pub fn new() -> Self

Create a new empty DAG

pub fn add_task(&mut self, task: AgentTask)

Add a task to the DAG

pub fn add_dependency(&mut self, task_id: String, depends_on: String)

Add a dependency between tasks

pub fn get_root_tasks(&self) -> Vec<String>

Get tasks with no dependencies (can execute immediately)

pub fn get_dependents(&self, task_id: &str) -> Vec<String>

Get tasks that depend on a given task

pub fn get_dependencies(&self, task_id: &str) -> Vec<String>

Get dependencies for a task

Trait Implementations

impl Clone for TaskDAG

fn clone(&self) -> TaskDAG

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TaskDAG

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

Formats the value using the given formatter.

impl Default for TaskDAG

fn default() -> Self

Returns the “default value” for a type.