Pipeline.Executor (pipeline v0.0.1)

Main pipeline execution engine.

Orchestrates the execution of workflow steps, manages state, and coordinates between Brain (Gemini) and Muscle (Claude) operations.

Summary

workflow()

Execute a complete workflow.

Execute a single step for testing.

@type execution_result() :: {:ok, map()} | {:error, String.t()}

@type workflow() :: map()

@spec execute(
  workflow(),
  keyword()
) :: execution_result()

Execute a complete workflow.

Takes a workflow configuration and executes all steps in sequence, managing state and checkpoints along the way.

@spec execute_step(map(), map()) :: {:ok, map()} | {:error, String.t()}

Execute a single step for testing.