Skip to content

API Reference

The CausalIQ Workflow framework provides a comprehensive API for building, validating, and executing data processing workflows. The API is organized into several key modules:

Core Components

Action Framework

Base classes and interfaces for creating reusable workflow actions that follow GitHub Actions patterns.

  • Action - Abstract base class for all workflow actions
  • ActionInput/ActionOutput - Type-safe input/output specifications
  • ActionExecutionError/ActionValidationError - Exception handling

Action Registry

Centralized discovery and execution system for workflow actions with plugin architecture support.

  • ActionRegistry - Dynamic action discovery and management
  • WorkflowContext - Complete workflow context for actions
  • ActionRegistryError - Registry-specific exceptions

Workflow Engine

Powerful workflow parsing, validation, and execution engine with matrix expansion and templating.

  • WorkflowExecutor - Main workflow processing engine
  • WorkflowExecutionError - Workflow execution exceptions
  • Template system - Variable substitution and validation

Schema Validation

Robust workflow validation against JSON schemas with detailed error reporting.

  • validate_workflow - Schema-based workflow validation
  • load_schema/load_workflow_file - File loading utilities
  • WorkflowValidationError - Validation-specific exceptions

CLI Interface

Command-line interface for workflow execution and management.

  • Command-line tools - Direct workflow execution
  • Integration support - CI/CD pipeline integration

Quick Start

from causaliq_workflow import WorkflowExecutor

# Create executor and run workflow
executor = WorkflowExecutor()
workflow = executor.parse_workflow("my_workflow.yml")
results = executor.execute_workflow(workflow, mode="run")

Next Steps

For detailed examples and usage patterns, see the Usage Examples page.