export declare class TaskRunDispatcher {
    #private;
    private readonly deps;
    constructor(deps: {
        workerId: string;
        maxConcurrency?: number;
        ensureSession: (taskId: string, runId: string, agentId?: string) => Promise<string>;
        runAgent: (runId: string, conversationId: string, message: string) => Promise<void>;
    });
    dispatch(): void;
    stop(): void;
    drain(): Promise<void>;
    private reconcileExpiredRuns;
    private drainSlot;
}
export declare function buildTaskRunMessage(objective: string, trigger: Record<string, unknown>, body?: string): string;