/**
 * WorkflowScheduler - Manages DAG execution order and parallel scheduling
 */
import type { Workflow, WorkflowState } from '@cogitator-ai/types';
interface DependencyGraph {
    dependencies: Map<string, Set<string>>;
    dependents: Map<string, Set<string>>;
}
export declare class WorkflowScheduler {
    /**
     * Build dependency graph from workflow edges
     */
    buildDependencyGraph<S extends WorkflowState>(workflow: Workflow<S>): DependencyGraph;
    /**
     * Get nodes ready to execute (all dependencies completed)
     */
    getReadyNodes(graph: DependencyGraph, completed: Set<string>, pending: Set<string>): string[];
    /**
     * Get topological order of nodes (grouped by execution level)
     * Returns array of arrays, where each inner array can be executed in parallel
     */
    getExecutionLevels<S extends WorkflowState>(workflow: Workflow<S>): string[][];
    /**
     * Find the next node(s) to execute based on current state and edge conditions
     */
    getNextNodes<S extends WorkflowState>(workflow: Workflow<S>, currentNode: string, state: S): string[];
    /**
     * Run multiple async tasks with concurrency limit
     */
    runWithConcurrency<T>(tasks: (() => Promise<T>)[], maxConcurrency: number): Promise<T[]>;
    /**
     * Simpler parallel execution with Promise.all and concurrency via chunking
     */
    runParallel<T>(tasks: (() => Promise<T>)[], maxConcurrency: number): Promise<T[]>;
    /**
     * Run parallel tasks with per-completion callback
     * Uses pool-based execution to respect concurrency while allowing immediate callbacks
     */
    runParallelWithCallback<T>(tasks: (() => Promise<T>)[], maxConcurrency: number, onComplete: (result: T, index: number) => Promise<void>): Promise<T[]>;
}
export {};
//# sourceMappingURL=scheduler.d.ts.map