import type { MorePartsResponse } from '../../../agents/agent-usecases.js';
import type { CompanionFinding, PartDefinition, PartResult } from '../../models/types.js';
import { type TeamLeaderExecutionPublicationFence } from './team-leader-execution-terminal.js';
type DeepReadonly<T> = T extends object ? {
    readonly [Key in keyof T]: DeepReadonly<T[Key]>;
} : T;
interface TeamLeaderFeedbackArgs {
    readonly partResults: readonly DeepReadonly<PartResult>[];
    readonly latestBatchResults: readonly DeepReadonly<PartResult>[];
    readonly completedPartResults: readonly DeepReadonly<PartResult>[];
    readonly plannedParts: readonly DeepReadonly<PartDefinition>[];
    readonly scheduledIds: readonly string[];
    readonly cancellablePartIds: readonly string[];
    readonly abortSignal: AbortSignal;
    readonly companionFindings?: readonly DeepReadonly<CompanionFinding>[];
}
interface TeamLeaderExecutionTerminalArgs {
    readonly partResults: readonly DeepReadonly<PartResult>[];
    readonly plannedParts: readonly DeepReadonly<PartDefinition>[];
    readonly scheduledIds: readonly string[];
}
export interface TeamLeaderExecutionOptions {
    initialParts: PartDefinition[];
    maxConcurrency: number;
    abortSignal?: AbortSignal;
    beforeInitialPartExecution?: () => Promise<MorePartsResponse | undefined>;
    /** IDs allow a failed delivery to remain pending without restarting planning forever. */
    getPendingLiveInterventionIds?: () => readonly number[];
    runPart: (part: PartDefinition, partIndex: number, publicationFence: TeamLeaderExecutionPublicationFence, abortSignal: AbortSignal) => Promise<PartResult>;
    requestMoreParts: (args: TeamLeaderFeedbackArgs) => Promise<MorePartsResponse>;
    reviewCompletion?: (args: Omit<TeamLeaderFeedbackArgs, 'companionFindings'>) => Promise<readonly CompanionFinding[]>;
    onPartQueued?: (part: DeepReadonly<PartDefinition>, partIndex: number) => void;
    onPartCompleted?: (result: DeepReadonly<PartResult>) => void;
    onPlanningDone?: (feedback: {
        reason: string;
        plannedParts: number;
        completedParts: number;
    }) => void;
    onPlanningNoNewParts?: (feedback: {
        reason: string;
        plannedParts: number;
        completedParts: number;
    }) => void;
    onPartsAdded?: (feedback: {
        parts: readonly DeepReadonly<PartDefinition>[];
        reason: string;
        totalPlanned: number;
    }) => void;
    onPlanningError?: (error: unknown) => void;
    onCompletionPlanningFailure?: (error: unknown) => void;
    onTerminalError?: (error: unknown) => void;
    onExecutionTerminal?: (args: TeamLeaderExecutionTerminalArgs) => Promise<MorePartsResponse | undefined>;
}
export interface TeamLeaderExecutionResult {
    plannedParts: PartDefinition[];
    partResults: PartResult[];
}
export declare function runTeamLeaderExecution(options: TeamLeaderExecutionOptions): Promise<TeamLeaderExecutionResult>;
export {};
//# sourceMappingURL=team-leader-execution.d.ts.map