Struct Workflow 

pub struct Workflow {

    pub schema: String,
    pub name: Option<String>,
    pub provider: String,
    pub model: Option<String>,
    pub mcp: Option<FxHashMap<String, McpConfigInline>>,
    pub context: Option<ContextConfig>,
    pub include: Option<Vec<IncludeSpec>>,
    pub agents: Option<FxHashMap<String, AgentDef>>,
    pub skills: Option<FxHashMap<String, SkillDef>>,
    pub artifacts: Option<ArtifactsConfig>,
    pub log: Option<LogConfig>,
    pub inputs: Option<FxHashMap<String, Value>>,
    pub tasks: Vec<Arc<Task>>,
}

Workflow with Arc-wrapped tasks for efficient cloning

Fields

schema: String

name: Option<String>

provider: String

model: Option<String>

mcp: Option<FxHashMap<String, McpConfigInline>>

MCP server configurations

Allows workflows to define MCP servers inline rather than referencing external configuration. The map key is the server name used in invoke.mcp fields.

context: Option<ContextConfig>

Context configuration for file loading at workflow start

Files are loaded into the RunContext at workflow start and accessible via {{context.files.alias}} bindings.

include: Option<Vec<IncludeSpec>>

Include external workflows for DAG fusion

Included workflows have their tasks merged into the main DAG at parse time. They share the same RunContext.

agents: Option<FxHashMap<String, AgentDef>>

Reusable agent definitions

Named agent configurations that can be referenced by tasks. Agents can be inline definitions or file references.

skills: Option<FxHashMap<String, SkillDef>>

Skill file mappings for prompt augmentation

Named skill files that can be injected into agent system prompts.

artifacts: Option<ArtifactsConfig>

Artifact configuration for file persistence

Workflow-level defaults for artifact output.

log: Option<LogConfig>

Log configuration

Workflow-level logging configuration.

inputs: Option<FxHashMap<String, Value>>

Input parameters with defaults

Maps parameter names to their definitions. Each definition is a JSON object with type, default, description, and optional enum values. Accessible via {{inputs.param_name}} in templates.

tasks: Vec<Arc<Task>>

Implementations

impl Workflow

pub fn compute_hash(&self) -> String

Compute a hash of the workflow for cache invalidation

Uses xxhash3 for fast hashing. The hash is computed from:

• Schema version
• Provider + model
• Task count and IDs

Returns a 16-character hex string (64-bit hash).

pub fn flow_count(&self) -> usize

Compute DAG edge count from per-task dependencies.

pub fn edges(&self) -> Vec<(&str, &str)>

Iterate over DAG edges as (source, target) pairs.

Built from each task’s depends_on field.

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.