export type DispatchMode = 'parallel' | 'serial-fallback';
export interface DagNode<TPayload = unknown> {
    id: string;
    workPackageId: string;
    dependsOn: string[];
    parallel: boolean;
    payload: TPayload;
}
export interface DagMetrics {
    parallelTaskCount: number;
    maxParallelism: number;
    criticalPathLength: number;
}
export interface TaskDispatchAuditEntry {
    taskId: string;
    workPackageId: string;
    batchId: number;
    dependsOn: string[];
    dispatchedAt: string;
    completedAt?: string;
    unlockedTasks: string[];
    mode: DispatchMode;
}
export interface DispatchBatch<TPayload = unknown> {
    batchId: number;
    mode: DispatchMode;
    tasks: DagNode<TPayload>[];
}
export declare function sanitizeDagNodes<TPayload>(nodes: DagNode<TPayload>[]): DagNode<TPayload>[];
export declare function buildDependencyGraph<TPayload>(nodes: DagNode<TPayload>[]): Record<string, string[]>;
export declare function computeDagMetrics<TPayload>(nodes: DagNode<TPayload>[]): DagMetrics;
export declare class TaskDagScheduler<TPayload = unknown> {
    private readonly options;
    private readonly nodes;
    private readonly adjacency;
    private readonly criticalPathDepth;
    private readonly pending;
    private readonly running;
    private readonly completed;
    private readonly auditLog;
    private batchCounter;
    constructor(inputNodes: DagNode<TPayload>[], options?: {
        singleAgent?: boolean;
    });
    get mode(): DispatchMode;
    hasPendingWork(): boolean;
    getAuditLog(): readonly TaskDispatchAuditEntry[];
    getDependencyGraph(): Record<string, string[]>;
    getMetrics(): DagMetrics;
    dispatchNextBatch(dispatchedAt: string): DispatchBatch<TPayload> | null;
    markCompleted(taskIds: string[], completedAt: string): string[];
    private getReadyTaskIds;
    private getReadyNodes;
    private pickFallbackNodes;
    private sortReady;
    private findLatestAuditEntry;
}
//# sourceMappingURL=task-dag.d.ts.map