Struct AnalyzedWorkflow 

pub struct AnalyzedWorkflow {

    pub schema_version: SchemaVersion,
    pub name: Option<String>,
    pub description: Option<String>,
    pub provider: Option<String>,
    pub model: Option<String>,
    pub task_table: TaskTable,
    pub tasks: Vec<AnalyzedTask>,
    pub mcp_servers: IndexMap<String, AnalyzedMcpServer>,
    pub context_files: Vec<AnalyzedContextFile>,
    pub imports: Vec<AnalyzedImportSpec>,
    pub inputs: IndexMap<String, Value>,
    pub artifacts: Option<ArtifactsConfig>,
    pub log: Option<LogConfig>,
    pub agents: Option<IndexMap<String, AgentDef>>,
    pub skills_map: HashMap<String, String>,
    pub span: Span,
}

An analyzed workflow - validated and ready for execution.

Unlike RawWorkflow, this has:

• References resolved to interned IDs (TaskId)
• Validated schema version
• Validated dependency graph (no cycles)
• Validated task IDs (no duplicates)

Fields

schema_version: SchemaVersion

Schema version (validated)

name: Option<String>

Optional workflow name

description: Option<String>

Optional description

provider: Option<String>

Default provider for the workflow

model: Option<String>

Default model for the workflow

task_table: TaskTable

Task lookup table (TaskId → name)

tasks: Vec<AnalyzedTask>

Tasks in execution order (topologically sorted)

mcp_servers: IndexMap<String, AnalyzedMcpServer>

MCP server configurations (name → config)

context_files: Vec<AnalyzedContextFile>

Context file configurations

imports: Vec<AnalyzedImportSpec>

Import specifications

inputs: IndexMap<String, Value>

Input parameters with defaults

artifacts: Option<ArtifactsConfig>

Artifact configuration for file persistence

log: Option<LogConfig>

Log configuration

agents: Option<IndexMap<String, AgentDef>>

Reusable agent definitions (name → config)

skills_map: HashMap<String, String>

Workflow-level skills mapping (alias -> file path)

Carried from the skills: block in the workflow YAML. Used by TaskExecutor to wire skill injection into agent loops.

span: Span

Span of the entire workflow

Implementations

impl AnalyzedWorkflow

pub fn get_task(&self, id: TaskId) -> Option<&AnalyzedTask>

Get a task by its ID.

pub fn get_task_by_name(&self, name: &str) -> Option<&AnalyzedTask>

Get a task by name.

pub fn task_count(&self) -> usize

Get the number of tasks.

pub fn iter_tasks(&self) -> impl Iterator<Item = &AnalyzedTask>

Iterate over all tasks.

pub fn has_task(&self, name: &str) -> bool

Check if a task exists by name.

pub fn compute_hash(&self) -> String

Compute a hash of the workflow for trace identification.

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

• Schema version
• Provider + model
• Task count and task names

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

Trait Implementations

impl Clone for AnalyzedWorkflow

fn clone(&self) -> AnalyzedWorkflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AnalyzedWorkflow

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

Formats the value using the given formatter.

impl Default for AnalyzedWorkflow

fn default() -> AnalyzedWorkflow

Returns the “default value” for a type.