Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

Engine for registering and executing multi-step agent workflows.

Implementations

impl WorkflowEngine

pub fn new() -> Self

Create a new workflow engine.

pub fn register_workflow(&self, workflow: Workflow) -> WorkflowId

Register a sequential workflow definition and return its ID.

pub fn register_dag_workflow( &self, workflow: DagWorkflow, ) -> Result<WorkflowId, Vec<ValidationError>>

Register a DAG workflow definition and return its ID.

Validates the workflow before registering. Returns an error with validation details if the workflow is invalid.

pub async fn execute_workflow( &self, workflow_id: &WorkflowId, input: String, memory: Arc<MemorySubstrate>, driver: Arc<dyn LlmDriver>, model_config: &ModelConfig, ) -> PunchResult<WorkflowRunId>

Execute a sequential workflow with the given input string.

pub fn get_run(&self, run_id: &WorkflowRunId) -> Option<WorkflowRun>

Get a workflow run by its ID.

pub fn list_workflows(&self) -> Vec<Workflow>

List all registered sequential workflows.

pub fn list_dag_workflows(&self) -> Vec<DagWorkflow>

List all registered DAG workflows.

pub fn list_runs(&self) -> Vec<WorkflowRun>

List all workflow runs.

pub fn list_runs_for_workflow( &self, workflow_id: &WorkflowId, ) -> Vec<WorkflowRun>

List workflow runs filtered by workflow ID.

pub fn get_workflow(&self, id: &WorkflowId) -> Option<Workflow>

Get a sequential workflow by its ID.

pub fn get_dag_workflow(&self, id: &WorkflowId) -> Option<DagWorkflow>

Get a DAG workflow by its ID.

Trait Implementations

impl Default for WorkflowEngine

fn default() -> Self

Returns the “default value” for a type.