import type { ChatKitStore, StoreContext } from '../chatkit/store';
import type { RunContextRetriever, RunExecutionBackend, RunExecutionInput } from './RunExecutionBackend';
import { type RunRecordData, type RunStore } from './store';
export type ManagedRunStore<TContext = StoreContext> = ChatKitStore<TContext> & RunStore<TContext>;
export interface ManagedRunWorkerOptions<TContext = StoreContext> {
    store: ManagedRunStore<TContext>;
    runtimeDriver: RunExecutionBackend;
    leaseOwner?: string;
    leaseDurationSeconds?: number;
    contextRetriever?: RunContextRetriever<TContext>;
}
export interface ManagedRunExecutionResult {
    runId: string;
    status: RunRecordData['status'] | 'skipped';
}
/**
 * Store-backed Managed Agent worker.
 *
 * The worker is the durable Inngest callback path: it restores Run/Thread/
 * Message state from the configured store, invokes the stateless Agent Runtime,
 * then projects runtime output back into RunStep and assistant Message facts.
 */
export declare class ManagedRunWorker<TContext = StoreContext> {
    private readonly store;
    private readonly runtimeDriver;
    private readonly leaseOwner;
    private readonly leaseDurationSeconds;
    private readonly contextRetriever?;
    constructor(options: ManagedRunWorkerOptions<TContext>);
    executeRun(runId: string, context: TContext): Promise<ManagedRunExecutionResult>;
    private retrieveRunContext;
    private claimRun;
    private claimRunWithSave;
    private canExecuteClaimedRun;
    private checkCancellation;
    loadExecutionInput(runId: string, context: TContext): Promise<RunExecutionInput>;
    private loadRunInput;
    private resolveUserMessage;
    private resolveRuntimeConfig;
    private authBindingIdFromRun;
    private asRuntimeConfig;
    private parseRunner;
    private isRunnerType;
    private handleRuntimeControlEvent;
    private markRunStarted;
    private finishRun;
    private stepTypeForStatus;
    private appendRunStep;
    private createAssistantMessage;
    private loadConversation;
    private threadRefFromRun;
    private extractThreadId;
    private resolveRunResource;
    private resolvePodBaseUrl;
}