Interface WorkflowEngine

Workflow engine

Executes workflows and manages their lifecycle.

Example

const engine: WorkflowEngine = new StandardWorkflowEngine({
  agentOrchestrator,
  toolRegistry,
  ragPipelines
});

const execution = await engine.execute(workflow, { customerData: {...} });

if (execution.status === 'completed') {
  console.log('Workflow completed:', execution.variables);
}
interface WorkflowEngine {
    execute(
        workflow: Workflow,
        input: Record<string, unknown>,
    ): Promise<Result<WorkflowExecution, Error>>;
    resume(
        executionId: string,
        input?: Record<string, unknown>,
    ): Promise<Result<WorkflowExecution, Error>>;
    pause(executionId: string): Promise<Result<void, Error>>;
    cancel(executionId: string): Promise<Result<void, Error>>;
    getExecution(executionId: string): Promise<undefined | WorkflowExecution>;
    listActive(): Promise<WorkflowExecution[]>;
    listExecutions(workflowId: string): Promise<WorkflowExecution[]>;
}

Methods

execute resume pause cancel getExecution listActive listExecutions

Methods

execute

resume

pause

cancel

  • cancel(executionId: string): Promise<Result<void, Error>>

    Cancel a running workflow

    Parameters

    • executionId: string

      Execution to cancel

    Returns Promise<Result<void, Error>>

    Success or error

getExecution

listActive

listExecutions

Settings

Member Visibility

On This Page

Methods