import type { Workflow, WorkflowState, WorkflowResult } from '@cogitator-ai/types';
import { type SubworkflowContext, type SubworkflowConfig, type SubworkflowResult, type SubworkflowErrorStrategy } from './subworkflow-node.js';
export interface ParallelSubworkflowDef<PS extends WorkflowState, CS extends WorkflowState> {
    id: string;
    config: SubworkflowConfig<PS, CS>;
}
export interface ParallelSubworkflowsConfig<S extends WorkflowState> {
    name: string;
    subworkflows: ParallelSubworkflowDef<S, WorkflowState>[] | ((state: S) => ParallelSubworkflowDef<S, WorkflowState>[]);
    concurrency?: number;
    continueOnError?: boolean;
    onError?: SubworkflowErrorStrategy;
    aggregator: (results: Map<string, SubworkflowResult<S, WorkflowState>>, parentState: S) => S;
    maxDepth?: number;
    shareCheckpoints?: boolean;
    onSubworkflowStart?: (id: string, config: SubworkflowConfig<S, WorkflowState>) => void;
    onSubworkflowComplete?: (id: string, result: SubworkflowResult<S, WorkflowState>) => void;
    onProgress?: (progress: ParallelProgress) => void;
}
export interface ParallelProgress {
    total: number;
    completed: number;
    successful: number;
    failed: number;
    pending: number;
    running: number;
}
export interface ParallelSubworkflowsResult<S extends WorkflowState> {
    success: boolean;
    parentState: S;
    results: Map<string, SubworkflowResult<S, WorkflowState>>;
    errors: Map<string, Error>;
    duration: number;
    stats: {
        total: number;
        successful: number;
        failed: number;
        skipped: number;
    };
}
export declare function executeParallelSubworkflows<S extends WorkflowState>(parentState: S, config: ParallelSubworkflowsConfig<S>, context: SubworkflowContext): Promise<ParallelSubworkflowsResult<S>>;
export declare function parallelSubworkflows<S extends WorkflowState>(name: string, config: Omit<ParallelSubworkflowsConfig<S>, 'name'>): ParallelSubworkflowsConfig<S>;
export declare function fanOutFanIn<S extends WorkflowState, CS extends WorkflowState>(name: string, config: {
    workflow: Workflow<CS>;
    getInputs: (state: S) => {
        id: string;
        input: Partial<CS>;
    }[];
    aggregator: (results: Map<string, WorkflowResult<CS>>, state: S) => S;
    concurrency?: number;
    continueOnError?: boolean;
}): ParallelSubworkflowsConfig<S>;
export declare function scatterGather<S extends WorkflowState, CS extends WorkflowState>(name: string, config: {
    workflows: Map<string, Workflow<CS>>;
    inputMapper: (state: S, workflowId: string) => Partial<CS>;
    outputMapper: (results: Map<string, WorkflowResult<CS>>, state: S) => S;
    concurrency?: number;
    timeout?: number;
    continueOnError?: boolean;
}): ParallelSubworkflowsConfig<S>;
export declare function raceSubworkflows<PS extends WorkflowState, CS extends WorkflowState>(parentState: PS, subworkflows: SubworkflowConfig<PS, CS>[], context: SubworkflowContext): Promise<SubworkflowResult<PS, CS> | null>;
export declare function fallbackSubworkflows<PS extends WorkflowState, CS extends WorkflowState>(parentState: PS, subworkflows: SubworkflowConfig<PS, CS>[], context: SubworkflowContext): Promise<SubworkflowResult<PS, CS>>;
//# sourceMappingURL=parallel-subworkflows.d.ts.map