Module workflow 

Workflow Automation System

This module provides a sophisticated workflow engine for defining and executing complex multi-step synthesis pipelines with conditional logic, error recovery, and composition capabilities.

Features

• Declarative Workflow Definition: Define workflows using YAML/JSON/TOML
• Conditional Execution: Branch based on quality metrics, file size, duration
• Error Recovery: Automatic retry with exponential backoff, fallback strategies
• Workflow Composition: Combine workflows, create sub-workflows
• State Management: Persistent workflow state, resume capability
• Validation: Pre-execution workflow validation and optimization
• Parallel Execution: Run independent steps in parallel
• Variable Substitution: Dynamic parameter substitution

Example Workflow

name: "Multi-Voice Production Pipeline"
version: "1.0"
variables:
  quality: "high"
  voices: ["en-US-neural-1", "en-US-neural-2"]

steps:
  - name: "synthesis"
    type: "synthesize"
    parameters:
      text: "${input_text}"
      voice: "${voice}"
      quality: "${quality}"
    for_each: "${voices}"
    retry:
      max_attempts: 3
      backoff: "exponential"

  - name: "quality_check"
    type: "validate"
    condition: "${synthesis.success}"
    parameters:
      min_mos: 4.0
      max_duration_diff: 0.1

  - name: "fallback"
    type: "synthesize"
    condition: "${quality_check.failed}"
    parameters:
      voice: "fallback-voice"
      quality: "medium"

Re-exports

pub use definition::Condition;

pub use definition::ConditionOperator;

pub use definition::RetryStrategy;

pub use definition::Step;

pub use definition::StepDependency;

pub use definition::StepType;

pub use definition::Variable;

pub use definition::Workflow;

pub use definition::WorkflowMetadata;

pub use engine::WorkflowEngine;

pub use executor::ExecutionContext;

pub use executor::ExecutionResult;

pub use executor::StepExecutor;

pub use executor::StepResult;

pub use retry::BackoffStrategy;

pub use retry::RetryConfig;

pub use retry::RetryManager;

pub use state::ExecutionState;

pub use state::StateManager;

pub use state::WorkflowState;

pub use validation::ValidationError;

pub use validation::ValidationResult;

pub use validation::WorkflowValidator;

pub use variables::VariableResolver;

pub use variables::VariableScope;

Modules

definition

Workflow Definition Types

engine

Workflow Execution Engine

executor

Step Executor

retry

Retry Logic Module

state

Workflow State Management

validation

Workflow Validation

variables

Variable Resolution and Substitution

Structs

WorkflowRegistry

Workflow registry for managing multiple workflows

WorkflowStats

Workflow execution statistics