/**
 * WorkflowExecutor - Main execution engine for workflows
 */
import type { Workflow, WorkflowState, WorkflowResult, WorkflowExecuteOptions, StreamingWorkflowEvent, CheckpointStore } from '@cogitator-ai/types';
export interface ExecutorExecuteOptions extends WorkflowExecuteOptions {
    signal?: AbortSignal;
}
import type { Cogitator } from '@cogitator-ai/core';
export declare class NodeExecutionError extends Error {
    readonly nodeName: string;
    constructor(nodeName: string, cause: Error);
}
export declare class WorkflowExecutor {
    private cogitator;
    private checkpointStore;
    private scheduler;
    constructor(cogitator: Cogitator, checkpointStore?: CheckpointStore);
    /**
     * Execute a workflow
     */
    execute<S extends WorkflowState>(workflow: Workflow<S>, input?: Partial<S>, options?: ExecutorExecuteOptions): Promise<WorkflowResult<S>>;
    /**
     * Resume a workflow from a checkpoint
     */
    resume<S extends WorkflowState>(workflow: Workflow<S>, checkpointId: string, options?: WorkflowExecuteOptions): Promise<WorkflowResult<S>>;
    /**
     * Stream workflow execution events
     */
    stream<S extends WorkflowState>(workflow: Workflow<S>, input?: Partial<S>, options?: Omit<WorkflowExecuteOptions, 'onNodeStart' | 'onNodeComplete' | 'onNodeError' | 'onNodeProgress'>): AsyncIterable<StreamingWorkflowEvent>;
}
//# sourceMappingURL=executor.d.ts.map