import type { Database as DatabaseType } from 'better-sqlite3';
export declare function createBatch(db: DatabaseType, triggerMessageId: number, chainRootBatchId: number | null, chainDepth: number): number;
export declare function createJob(db: DatabaseType, batchId: number, agentName: string, extra?: {
    requested_by_email?: string | null;
    requested_by_user_id?: string | null;
    effective_mode?: string | null;
    effective_profile?: string | null;
}): number;
export declare function updateJobStatus(db: DatabaseType, jobId: number, status: string, extra?: {
    output_message_id?: number;
    error?: string;
    requested_by_email?: string;
    requested_by_user_id?: string;
    effective_mode?: string;
    effective_profile?: string | null;
    waiting_request_id?: number | null;
}): void;
export declare function markJobWaitingInput(db: DatabaseType, jobId: number, requestId: number): void;
export declare function markJobResumed(db: DatabaseType, jobId: number): void;
export declare function cancelJob(db: DatabaseType, jobId: number, error?: string): void;
export declare function getJob(db: DatabaseType, jobId: number): any;
export declare function getJobsForBatch(db: DatabaseType, batchId: number): Array<{
    id: number;
    agent_name: string;
    status: string;
    output_message_id: number | null;
    error: string | null;
}>;
export declare function listActiveJobsForTopic(db: DatabaseType, topicId: number): Array<{
    id: number;
    agent_name: string;
    status: string;
    output_message_id: number | null;
    error: string | null;
}>;
export declare function countActiveJobsByTopic(db: DatabaseType): Map<number, {
    queued: number;
    running: number;
}>;
export declare function failInterruptedJobs(db: DatabaseType, error?: string): number;
export declare function countChainJobs(db: DatabaseType, chainRootBatchId: number): number;
//# sourceMappingURL=jobs.d.ts.map