Struct Workflow 

pub struct Workflow {
    pub id: WorkflowId,
    pub name: String,
    pub description: String,
    pub tasks: HashMap<TaskId, Task>,
    pub edges: Vec<Edge>,
    pub config: WorkflowConfig,
    pub state: WorkflowState,
    pub metadata: HashMap<String, String>,
}

Workflow definition.

Fields

id: WorkflowId

Unique workflow identifier.

name: String

Workflow name.

description: String

Workflow description.

tasks: HashMap<TaskId, Task>

Tasks in the workflow.

edges: Vec<Edge>

Edges defining task dependencies.

config: WorkflowConfig

Workflow configuration.

state: WorkflowState

Current state.

metadata: HashMap<String, String>

Workflow metadata.

Implementations

impl Workflow

pub fn new(name: impl Into<String>) -> Self

Create a new workflow.

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

Add a task to the workflow.

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

Add an edge between tasks.

pub fn add_conditional_edge( &mut self, from: TaskId, to: TaskId, condition: String, ) -> Result<()>

Add a conditional edge.

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

Get task by ID.

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

Get mutable task by ID.

pub fn tasks(&self) -> impl Iterator<Item = &Task>

Get all tasks.

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

Get dependencies for a task.

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

Get dependents for a task.

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

Get root tasks (tasks with no dependencies).

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

Get leaf tasks (tasks with no dependents).

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

Validate workflow structure.

pub fn has_cycle(&self) -> bool

Check if workflow has a cycle.

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

Get topological order of tasks.

pub fn with_description(self, description: impl Into<String>) -> Self

Set workflow description.

pub fn with_config(self, config: WorkflowConfig) -> Self

Set workflow configuration.

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add metadata.

Trait Implementations

impl Clone for Workflow

fn clone(&self) -> Workflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Workflow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Workflow

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Workflow

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.