import { Inngest } from 'inngest';
import type { EventPayload } from 'inngest/types';
import type { StoreContext } from '../chatkit/store';
import type { AgentRuntimeEvent } from './AgentRuntimeTypes';
import { ManagedRunWorker, type ManagedRunStore } from './ManagedRunWorker';
import type { RunContextRetriever, RunExecutionBackend, RunExecutionInput } from './RunExecutionBackend';
import type { AiConnectionsInvocationKeyIssuer } from '../ai-gateway/auth/AiConnectionsInvocationKeyIssuer';
export declare const XPOD_RUN_REQUESTED_EVENT = "xpod/run.requested";
export declare const XPOD_RUN_CONTINUE_REQUESTED_EVENT = "xpod/run.continue_requested";
export declare const XPOD_AGENT_RUN_FUNCTION_ID = "xpod-agent-run";
export interface XpodRunRequestedEventData {
    source: string;
    runId: string;
    threadId: string;
    executionKey?: string;
    authBindingId?: string;
    webId?: string;
    continuation?: RunExecutionInput['continuation'];
}
export type XpodRunRequestedEvent = EventPayload<XpodRunRequestedEventData> & {
    name: string;
};
export interface InngestRunExecutionBackendOptions {
    client?: Inngest;
    source?: string;
    baseUrl?: string;
    eventKey?: string;
    signingKey?: string;
    isDev?: boolean;
    runtimeDriver?: RunExecutionBackend;
    store?: ManagedRunStore<StoreContext>;
    managedRunWorker?: ManagedRunWorker<StoreContext>;
    contextRetriever?: RunContextRetriever<StoreContext>;
    contextResolver?: (data: XpodRunRequestedEventData) => StoreContext | Promise<StoreContext | undefined> | undefined;
    contextRecorder?: (context: StoreContext | undefined) => void;
    aiConnectionInvocationKeyIssuer?: Pick<AiConnectionsInvocationKeyIssuer, 'issue'>;
    durableDelivery?: boolean;
    /**
     * When true, execute the registered Inngest handler in-process after sending
     * the event. This keeps Chat streaming low-latency while preserving the
     * Inngest event/function boundary for the managed-agents backend.
     */
    executeInline?: boolean;
}
/**
 * Inngest-backed managed-agent execution backend.
 *
 * Xpod owns the Run facts; Inngest owns durable function delivery. In this
 * first API-facing implementation the function can execute inline so ChatKit
 * still receives a normal SSE stream without waiting for external polling.
 *
 * The in-memory pending map is only the streaming bridge for an active HTTP
 * request. When no pending stream exists, the registered Inngest function can
 * restore the Run from store through ManagedRunWorker.
 */
export declare class InngestRunExecutionBackend implements RunExecutionBackend {
    private readonly client;
    private readonly source;
    private readonly requestedEventName;
    private readonly continueRequestedEventName;
    private readonly runtimeDriver;
    private readonly managedRunWorker?;
    private readonly contextResolver?;
    private readonly contextRecorder?;
    private readonly aiConnectionInvocationKeyIssuer?;
    private readonly executeInline;
    private readonly durableDelivery;
    private readonly pendingRuns;
    readonly agentRunFunction: import("inngest").InngestFunction<import("inngest").InngestFunction.Options<[{
        readonly event: string;
    }, {
        readonly event: string;
    }], import("inngest").HandlerWithTriggers<{
        sendEvent: (idOrOptions: import("inngest").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<Inngest<import("inngest").ClientOptions>>>>;
        waitForSignal: <TData>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
            signal: string;
            timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
            onConflict: "replace" | "fail";
        }) => Promise<{
            signal: string;
            data: import("inngest/types").Jsonify<TData>;
        } | null>;
        realtime: {
            publish: <TData>(idOrOptions: import("inngest").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
        };
        sendSignal: (idOrOptions: import("inngest").StepOptionsOrId, opts: {
            signal: string;
            data?: unknown;
        }) => Promise<import("inngest/api/api").InngestApi.SendSignalResponse>;
        waitForEvent: <TOpts extends {
            event: string | import("inngest").EventType<string, any>;
            timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
        } & import("inngest").ExclusiveKeys<{
            match?: string;
            if?: string;
        }, "match", "if">>(idOrOptions: import("inngest").StepOptionsOrId, opts: TOpts) => Promise<TOpts extends {
            event: import("inngest").EventType<infer TName extends string, import("inngest").StandardSchemaV1<infer TData extends Record<string, unknown>>>;
        } ? {
            name: TName;
            data: TData;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : TOpts extends {
            event: import("inngest").EventType<infer TName_1 extends string, undefined>;
        } ? {
            name: TName_1;
            data: Record<string, any>;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : TOpts extends {
            event: infer TName_2 extends string;
            schema: import("inngest").StandardSchemaV1<infer TData_1 extends Record<string, unknown>>;
        } ? {
            name: TName_2;
            data: TData_1;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : TOpts extends {
            event: infer TName_3 extends string;
        } ? {
            name: TName_3;
            data: Record<string, any>;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : EventPayload<any> | null>;
        run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
        ai: {
            infer: <TAdapter extends import("inngest").AiAdapter>(idOrOptions: import("inngest").StepOptionsOrId, options: {
                model: TAdapter;
                body: import("inngest").AiAdapter.Input<TAdapter>;
            }) => Promise<import("inngest").AiAdapter.Output<TAdapter>>;
            wrap: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
            models: {
                anthropic: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Anthropic.AiModelOptions], import("inngest").Anthropic.AiModel>;
                gemini: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Gemini.AiModelOptions], import("inngest").Gemini.AiModel>;
                openai: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").OpenAi.AiModelOptions], import("inngest").OpenAi.AiModel>;
                deepseek: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").DeepSeek.AiModelOptions], import("inngest").DeepSeek.AiModel>;
                grok: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Grok.AiModelOptions], import("inngest").Grok.AiModel>;
            };
        };
        sleep: (idOrOptions: import("inngest").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
        sleepUntil: (idOrOptions: import("inngest").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
        invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
            function: TFunction;
        } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
            meta?: import("inngest").EventMeta;
            timeout?: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
        }) => import("inngest/types").InvocationResult<import("inngest/types").Jsonify<import("inngest").GetFunctionOutputRaw<TFunction>>>;
        fetch: import("inngest").StepFetch;
    }, [{
        readonly event: string;
    }, {
        readonly event: string;
    }], Omit<Omit<import("inngest").BaseContext<Inngest.Any>, never> & Record<never, never> & {
        logger: import("inngest").Logger;
    }, "group" | "step" | "requestId" | "event" | "attempt" | "events" | "runId" | "defer" | "jobId" | "maxAttempts"> & import("inngest").FailureEventArgs<EventPayload<any>> & {
        step: {
            sendEvent: (idOrOptions: import("inngest").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<Inngest<import("inngest").ClientOptions>>>>;
            waitForSignal: <TData>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
                signal: string;
                timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
                onConflict: "replace" | "fail";
            }) => Promise<{
                signal: string;
                data: import("inngest/types").Jsonify<TData>;
            } | null>;
            realtime: {
                publish: <TData>(idOrOptions: import("inngest").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
            };
            sendSignal: (idOrOptions: import("inngest").StepOptionsOrId, opts: {
                signal: string;
                data?: unknown;
            }) => Promise<import("inngest/api/api").InngestApi.SendSignalResponse>;
            waitForEvent: <TOpts extends {
                event: string | import("inngest").EventType<string, any>;
                timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
            } & import("inngest").ExclusiveKeys<{
                match?: string;
                if?: string;
            }, "match", "if">>(idOrOptions: import("inngest").StepOptionsOrId, opts: TOpts) => Promise<TOpts extends {
                event: import("inngest").EventType<infer TName extends string, import("inngest").StandardSchemaV1<infer TData extends Record<string, unknown>>>;
            } ? {
                name: TName;
                data: TData;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : TOpts extends {
                event: import("inngest").EventType<infer TName_1 extends string, undefined>;
            } ? {
                name: TName_1;
                data: Record<string, any>;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : TOpts extends {
                event: infer TName_2 extends string;
                schema: import("inngest").StandardSchemaV1<infer TData_1 extends Record<string, unknown>>;
            } ? {
                name: TName_2;
                data: TData_1;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : TOpts extends {
                event: infer TName_3 extends string;
            } ? {
                name: TName_3;
                data: Record<string, any>;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : EventPayload<any> | null>;
            run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
            ai: {
                infer: <TAdapter extends import("inngest").AiAdapter>(idOrOptions: import("inngest").StepOptionsOrId, options: {
                    model: TAdapter;
                    body: import("inngest").AiAdapter.Input<TAdapter>;
                }) => Promise<import("inngest").AiAdapter.Output<TAdapter>>;
                wrap: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
                models: {
                    anthropic: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Anthropic.AiModelOptions], import("inngest").Anthropic.AiModel>;
                    gemini: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Gemini.AiModelOptions], import("inngest").Gemini.AiModel>;
                    openai: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").OpenAi.AiModelOptions], import("inngest").OpenAi.AiModel>;
                    deepseek: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").DeepSeek.AiModelOptions], import("inngest").DeepSeek.AiModel>;
                    grok: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Grok.AiModelOptions], import("inngest").Grok.AiModel>;
                };
            };
            sleep: (idOrOptions: import("inngest").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
            sleepUntil: (idOrOptions: import("inngest").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
            invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
                function: TFunction;
            } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
                meta?: import("inngest").EventMeta;
                timeout?: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
            }) => import("inngest/types").InvocationResult<import("inngest/types").Jsonify<import("inngest").GetFunctionOutputRaw<TFunction>>>;
            fetch: import("inngest").StepFetch;
        };
    }>>, (ctx: any) => Promise<{
        runId: string;
        status: string;
    }>, import("inngest").HandlerWithTriggers<{
        sendEvent: (idOrOptions: import("inngest").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<Inngest<import("inngest").ClientOptions>>>>;
        waitForSignal: <TData>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
            signal: string;
            timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
            onConflict: "replace" | "fail";
        }) => Promise<{
            signal: string;
            data: import("inngest/types").Jsonify<TData>;
        } | null>;
        realtime: {
            publish: <TData>(idOrOptions: import("inngest").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
        };
        sendSignal: (idOrOptions: import("inngest").StepOptionsOrId, opts: {
            signal: string;
            data?: unknown;
        }) => Promise<import("inngest/api/api").InngestApi.SendSignalResponse>;
        waitForEvent: <TOpts extends {
            event: string | import("inngest").EventType<string, any>;
            timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
        } & import("inngest").ExclusiveKeys<{
            match?: string;
            if?: string;
        }, "match", "if">>(idOrOptions: import("inngest").StepOptionsOrId, opts: TOpts) => Promise<TOpts extends {
            event: import("inngest").EventType<infer TName extends string, import("inngest").StandardSchemaV1<infer TData extends Record<string, unknown>>>;
        } ? {
            name: TName;
            data: TData;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : TOpts extends {
            event: import("inngest").EventType<infer TName_1 extends string, undefined>;
        } ? {
            name: TName_1;
            data: Record<string, any>;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : TOpts extends {
            event: infer TName_2 extends string;
            schema: import("inngest").StandardSchemaV1<infer TData_1 extends Record<string, unknown>>;
        } ? {
            name: TName_2;
            data: TData_1;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : TOpts extends {
            event: infer TName_3 extends string;
        } ? {
            name: TName_3;
            data: Record<string, any>;
            id: string;
            ts: number;
            v?: string;
            meta?: import("inngest").ReceivedEventMeta;
        } | null : EventPayload<any> | null>;
        run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
        ai: {
            infer: <TAdapter extends import("inngest").AiAdapter>(idOrOptions: import("inngest").StepOptionsOrId, options: {
                model: TAdapter;
                body: import("inngest").AiAdapter.Input<TAdapter>;
            }) => Promise<import("inngest").AiAdapter.Output<TAdapter>>;
            wrap: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
            models: {
                anthropic: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Anthropic.AiModelOptions], import("inngest").Anthropic.AiModel>;
                gemini: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Gemini.AiModelOptions], import("inngest").Gemini.AiModel>;
                openai: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").OpenAi.AiModelOptions], import("inngest").OpenAi.AiModel>;
                deepseek: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").DeepSeek.AiModelOptions], import("inngest").DeepSeek.AiModel>;
                grok: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Grok.AiModelOptions], import("inngest").Grok.AiModel>;
            };
        };
        sleep: (idOrOptions: import("inngest").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
        sleepUntil: (idOrOptions: import("inngest").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
        invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
            function: TFunction;
        } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
            meta?: import("inngest").EventMeta;
            timeout?: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
        }) => import("inngest/types").InvocationResult<import("inngest/types").Jsonify<import("inngest").GetFunctionOutputRaw<TFunction>>>;
        fetch: import("inngest").StepFetch;
    }, [{
        readonly event: string;
    }, {
        readonly event: string;
    }], Omit<Omit<import("inngest").BaseContext<Inngest.Any>, never> & Record<never, never> & {
        logger: import("inngest").Logger;
    }, "group" | "step" | "requestId" | "event" | "attempt" | "events" | "runId" | "defer" | "jobId" | "maxAttempts"> & import("inngest").FailureEventArgs<EventPayload<any>> & {
        step: {
            sendEvent: (idOrOptions: import("inngest").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<Inngest<import("inngest").ClientOptions>>>>;
            waitForSignal: <TData>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
                signal: string;
                timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
                onConflict: "replace" | "fail";
            }) => Promise<{
                signal: string;
                data: import("inngest/types").Jsonify<TData>;
            } | null>;
            realtime: {
                publish: <TData>(idOrOptions: import("inngest").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
            };
            sendSignal: (idOrOptions: import("inngest").StepOptionsOrId, opts: {
                signal: string;
                data?: unknown;
            }) => Promise<import("inngest/api/api").InngestApi.SendSignalResponse>;
            waitForEvent: <TOpts extends {
                event: string | import("inngest").EventType<string, any>;
                timeout: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
            } & import("inngest").ExclusiveKeys<{
                match?: string;
                if?: string;
            }, "match", "if">>(idOrOptions: import("inngest").StepOptionsOrId, opts: TOpts) => Promise<TOpts extends {
                event: import("inngest").EventType<infer TName extends string, import("inngest").StandardSchemaV1<infer TData extends Record<string, unknown>>>;
            } ? {
                name: TName;
                data: TData;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : TOpts extends {
                event: import("inngest").EventType<infer TName_1 extends string, undefined>;
            } ? {
                name: TName_1;
                data: Record<string, any>;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : TOpts extends {
                event: infer TName_2 extends string;
                schema: import("inngest").StandardSchemaV1<infer TData_1 extends Record<string, unknown>>;
            } ? {
                name: TName_2;
                data: TData_1;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : TOpts extends {
                event: infer TName_3 extends string;
            } ? {
                name: TName_3;
                data: Record<string, any>;
                id: string;
                ts: number;
                v?: string;
                meta?: import("inngest").ReceivedEventMeta;
            } | null : EventPayload<any> | null>;
            run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
            ai: {
                infer: <TAdapter extends import("inngest").AiAdapter>(idOrOptions: import("inngest").StepOptionsOrId, options: {
                    model: TAdapter;
                    body: import("inngest").AiAdapter.Input<TAdapter>;
                }) => Promise<import("inngest").AiAdapter.Output<TAdapter>>;
                wrap: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest").StepOptionsOrId, fn: TFn, ...input: Parameters<TFn>) => Promise<import("inngest/types").Jsonify<TFn extends (...args: Parameters<TFn>) => Promise<infer U> ? Awaited<U extends void ? null : U> : ReturnType<TFn> extends void ? null : ReturnType<TFn>>>;
                models: {
                    anthropic: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Anthropic.AiModelOptions], import("inngest").Anthropic.AiModel>;
                    gemini: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Gemini.AiModelOptions], import("inngest").Gemini.AiModel>;
                    openai: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").OpenAi.AiModelOptions], import("inngest").OpenAi.AiModel>;
                    deepseek: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").DeepSeek.AiModelOptions], import("inngest").DeepSeek.AiModel>;
                    grok: import("inngest").AiAdapter.ModelCreator<[options: import("inngest").Grok.AiModelOptions], import("inngest").Grok.AiModel>;
                };
            };
            sleep: (idOrOptions: import("inngest").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
            sleepUntil: (idOrOptions: import("inngest").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
            invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest").StepOptionsOrId, opts: {
                function: TFunction;
            } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
                meta?: import("inngest").EventMeta;
                timeout?: number | string | Date | import("inngest").DurationLike | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike;
            }) => import("inngest/types").InvocationResult<import("inngest/types").Jsonify<import("inngest").GetFunctionOutputRaw<TFunction>>>;
            fetch: import("inngest").StepFetch;
        };
    }>, Inngest<import("inngest").ClientOptions>, [{
        readonly event: string;
    }, {
        readonly event: string;
    }]>;
    constructor(options?: InngestRunExecutionBackendOptions);
    getClient(): Inngest;
    getSource(): string;
    start(input: RunExecutionInput): AsyncIterable<AgentRuntimeEvent>;
    private handleAgentRun;
    restoreExecutionInput(runId: string, context: StoreContext): Promise<RunExecutionInput>;
    close(): Promise<void>;
    private createInlineContext;
    private formatError;
    private executionKeyForInput;
    private contextEventData;
}