export declare class TaskRunDispatcher {
    #private;
    private readonly deps;
    constructor(deps: {
        workerId: string;
        ensureSession: (taskId: string, runId: string, agentId?: string) => Promise<string>;
        runAgent: (runId: string, sessionKey: string, message: string) => Promise<void>;
    });
    dispatch(): void;
    drain(): Promise<void>;
}