Struct MetaWorkflow 

pub struct MetaWorkflow {
    pub name: String,
    pub description: String,
    pub sub_workflows: Vec<Workflow>,
    pub dependencies: Vec<CrossDependency>,
    pub statuses: HashMap<SubWorkflowRef, SubWorkflowStatus>,
    pub shared_variables: HashMap<String, Value>,
    pub metadata: HashMap<String, String>,
}

A meta-workflow that composes multiple sub-workflows.

Fields

name: String

Name of the meta-workflow.

description: String

Description.

sub_workflows: Vec<Workflow>

Sub-workflows in insertion order.

dependencies: Vec<CrossDependency>

Cross-workflow dependencies.

statuses: HashMap<SubWorkflowRef, SubWorkflowStatus>

Per-sub-workflow execution status.

shared_variables: HashMap<String, Value>

Shared variables accessible by all sub-workflows.

metadata: HashMap<String, String>

Metadata.

Implementations

impl MetaWorkflow

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

Create a new empty meta-workflow.

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

Set description.

pub fn add_sub_workflow(&mut self, workflow: Workflow) -> SubWorkflowRef

Add a sub-workflow, returning its reference handle.

pub fn add_dependency( &mut self, dep: CrossDependency, ) -> Result<(), ComposeError>

Add a cross-workflow dependency.

Errors

Returns ComposeError if either reference is invalid.

pub fn set_variable(&mut self, key: impl Into<String>, value: Value)

Set a shared variable.

pub fn get_sub_workflow(&self, ref_handle: SubWorkflowRef) -> Option<&Workflow>

Get a sub-workflow by reference.

pub fn get_sub_workflow_mut( &mut self, ref_handle: SubWorkflowRef, ) -> Option<&mut Workflow>

Get a mutable sub-workflow.

pub fn sub_workflow_count(&self) -> usize

Total number of sub-workflows.

pub fn total_task_count(&self) -> usize

Total number of tasks across all sub-workflows.

pub fn execution_order(&self) -> Result<Vec<SubWorkflowRef>, ComposeError>

Compute execution order (topological sort of sub-workflows).

Errors

Returns ComposeError::CycleDetected if dependencies form a cycle.

pub fn has_cycle(&self) -> bool

Check if the dependency graph has a cycle.

pub fn predecessors(&self, ref_handle: SubWorkflowRef) -> Vec<SubWorkflowRef>

Return predecessors of a sub-workflow.

pub fn successors(&self, ref_handle: SubWorkflowRef) -> Vec<SubWorkflowRef>

Return successors of a sub-workflow.

pub fn root_sub_workflows(&self) -> Vec<SubWorkflowRef>

Get root sub-workflows (no predecessors).

pub fn leaf_sub_workflows(&self) -> Vec<SubWorkflowRef>

Get leaf sub-workflows (no successors).

pub fn set_status( &mut self, ref_handle: SubWorkflowRef, status: SubWorkflowStatus, )

Mark a sub-workflow status.

pub fn get_status( &self, ref_handle: SubWorkflowRef, ) -> Option<&SubWorkflowStatus>

Get the status of a sub-workflow.

pub fn is_complete(&self) -> bool

Check whether all sub-workflows are complete (or skipped).

pub fn flatten(&self) -> Workflow

Merge a finished meta-workflow’s sub-workflows into a single flat Workflow.

This creates a new workflow containing all tasks from all sub-workflows, preserving internal edges and adding edges between leaf tasks of predecessors and root tasks of successors as per dependencies.

pub fn summary(&self) -> MetaWorkflowSummary

Compute summary metrics for the meta-workflow.

Trait Implementations

impl Clone for MetaWorkflow

fn clone(&self) -> MetaWorkflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetaWorkflow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MetaWorkflow

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MetaWorkflow

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

where __S: Serializer,

Serialize this value into the given Serde serializer.