Class PipelineRunner

new PipelineRunner(): PipelineRunner

compile(
    plan: {
        taskId: string;
        stages: {
            id: string;
            type: "analyze" | "validate" | "aggregate" | "execute" | "gate" | "route";
            pluginId: string;
            inputArtifacts: string[];
            outputArtifacts: string[];
            dependencies: string[];
            config: Record<string, unknown>;
            preferredCli?: string;
            maxRetries?: number;
            timeoutMs?: number;
        }[];
        policyGates: {
            id: string;
            afterStage: string;
            beforeStage: string;
            rules: string[];
            onFail: "warn"
            | "block"
            | "escalate";
        }[];
        estimatedCost: {
            totalTokensIn: number;
            totalTokensOut: number;
            estimatedCostUsd: number;
            modelCalls: number;
        };
        approvalRequired: boolean;
        maxIterations: number;
        timeoutMs: number;
    },
    options?: PlanCompileOptions,
): CompileResult

execute(
    pipeline: CompiledPipeline,
    task: {
        id: string;
        description: string;
        status:
            | "failed"
            | "planning"
            | "executing"
            | "approved"
            | "done"
            | "intake"
            | "clarifying"
            | "validating";
        analysis: { complexity: string; taskType: string; ambiguityScore: number };
        constraints: { time?: string; quality?: string; scope: string[] };
        requiredCapabilities: { tools: string[]; experts: string[] };
        capabilityGaps: {
            available: { tools: string[]; experts: string[] };
            gaps: unknown[];
            allSatisfied: boolean;
        };
        parentId?: string;
        artifacts: {
            id: string;
            type: | "code"
            | "plan"
            | "analysis"
            | "review"
            | "test"
            | "spec"
            | "report"
            | "vote";
        }[];
        metadata: Record<string, unknown>;
        createdAt: number;
        updatedAt: number;
        completedAt?: number;
        error?: string;
    },
    options?: PipelineExecuteOptions,
): Promise<ExecuteResult>

retryFailed(
    pipeline: CompiledPipeline,
    previousResult: PipelineResult,
    task: {
        id: string;
        description: string;
        status:
            | "failed"
            | "planning"
            | "executing"
            | "approved"
            | "done"
            | "intake"
            | "clarifying"
            | "validating";
        analysis: { complexity: string; taskType: string; ambiguityScore: number };
        constraints: { time?: string; quality?: string; scope: string[] };
        requiredCapabilities: { tools: string[]; experts: string[] };
        capabilityGaps: {
            available: { tools: string[]; experts: string[] };
            gaps: unknown[];
            allSatisfied: boolean;
        };
        parentId?: string;
        artifacts: {
            id: string;
            type: | "code"
            | "plan"
            | "analysis"
            | "review"
            | "test"
            | "spec"
            | "report"
            | "vote";
        }[];
        metadata: Record<string, unknown>;
        createdAt: number;
        updatedAt: number;
        completedAt?: number;
        error?: string;
    },
    options?: PipelineExecuteOptions,
): Promise<ExecuteResult>