export declare const MAX_AGENT_TEAM_CONTINUATIONS = 60;
export declare const MAX_AGENT_TEAM_NO_PROGRESS_CONTINUATIONS = 3;
export declare const RUN_DISPATCH_STUCK_AFTER_MS = 15000;
export declare const RUN_PROCESSING_STUCK_AFTER_MS: number;
export declare const RUN_RECONCILIATION_RETRY_AFTER_MS = 60000;
export type AgentTeamRunQueueStatus = "queued" | "running" | "done" | "failed";
export interface AgentTeamRunPayload {
    description: string;
    instructions?: string;
    model?: string;
    agentRef?: string;
    parentThreadId?: string;
    parentRunId?: string;
    name?: string;
    allowedActionNames?: string[];
    noProgressCount?: number;
    hitContinuationLimit?: boolean;
    transcriptRunIds?: string[];
    turnId: string;
}
export interface AgentTeamRunQueueRow {
    taskId: string;
    threadId: string;
    runId: string;
    status: AgentTeamRunQueueStatus;
    ownerEmail: string | null;
    orgId: string | null;
    payload: AgentTeamRunPayload;
    continuationCount: number;
    attempts: number;
    createdAt: number;
    updatedAt: number;
}
export declare const agentTeamRunQueueStore: import("../db/store-registry.js").Store;
export declare function ensureTable(): Promise<void>;
declare function getAffectedRowCount(result: unknown): number;
export interface EnqueueAgentTeamRunInput {
    taskId: string;
    threadId: string;
    runId: string;
    ownerEmail?: string | null;
    orgId?: string | null;
    payload: AgentTeamRunPayload;
}
export declare function enqueueAgentTeamRun(input: EnqueueAgentTeamRunInput): Promise<void>;
export declare function claimAgentTeamRun(taskId: string, options?: {
    stuckAfterMs?: number;
}): Promise<AgentTeamRunQueueRow | null>;
export declare function touchAgentTeamRun(taskId: string, claimedAttempts?: number): Promise<boolean>;
export declare function bumpAgentTeamContinuation(taskId: string, claimedAttempts?: number, options?: {
    requeue?: boolean;
}): Promise<number | null>;
export declare function requeueAgentTeamRunContinuation(taskId: string, claimedAttempts: number, payload?: AgentTeamRunPayload): Promise<boolean>;
export declare function withCurrentAgentTeamRunAttempt<T>(taskId: string, claimedAttempts: number, write: () => Promise<T>, options?: {
    statuses?: readonly AgentTeamRunQueueStatus[];
    expectedUpdatedAt?: number;
    revokeExecutionLease?: boolean;
}): Promise<{
    current: false;
} | {
    current: true;
    value: T;
}>;
export declare function persistAgentTeamRunEventIfCurrent(input: {
    taskId: string;
    claimedAttempts: number;
    runId: string;
    seq: number;
    eventData: string;
    terminal: boolean;
}): Promise<boolean>;
export declare function completeAgentTeamRun(taskId: string, status: "done" | "failed", claimedAttempts?: number, payload?: AgentTeamRunPayload): Promise<boolean>;
export declare function completeAgentTeamRunIfCurrent(taskId: string, status: "done" | "failed", expected: Pick<AgentTeamRunQueueRow, "status" | "attempts" | "updatedAt">): Promise<boolean>;
export declare function listActiveAgentTeamTaskIdsForOwner(owner: string, limit?: number): Promise<string[]>;
export declare function listStaleActiveAgentTeamRuns(updatedBefore: number, limit?: number, reconciliationAttemptedBefore?: number): Promise<Array<{
    taskId: string;
    ownerEmail: string;
    orgId: string | null;
}>>;
export declare function claimAgentTeamRunReconciliationAttempt(taskId: string, updatedBefore: number, reconciliationAttemptedBefore: number, attemptedAt?: number): Promise<number | null>;
export declare function getAgentTeamRunDispatchState(taskId: string): Promise<AgentTeamRunQueueRow | null>;
export declare const _agentTeamRunQueueForTests: {
    resetInit(): void;
    getAffectedRowCount: typeof getAffectedRowCount;
};
export {};