import type { EventPayload } from 'inngest/types';
import type { InngestRunExecutionBackend } from '../runs/InngestRunExecutionBackend';
import type { StoreContext } from '../chatkit/store';
import type { TaskService } from './TaskService';
import type { MaterializedTaskRun } from './TaskMaterializer';
export declare const XPOD_TASK_MATERIALIZE_DUE_EVENT = "xpod/task.materialize_due";
export declare const XPOD_TASK_EVENT = "xpod/task.event";
export declare const XPOD_TASK_MATERIALIZE_DUE_FUNCTION_ID = "xpod-task-materialize-due-runs";
export declare const XPOD_TASK_EVENT_FUNCTION_ID = "xpod-task-event";
export interface XpodTaskMaterializeDueEventData {
    source: string;
    requestId?: string;
    now?: number;
    limit?: number;
    authBindingId?: string;
    webId?: string;
}
export type XpodTaskMaterializeDueEvent = EventPayload<XpodTaskMaterializeDueEventData> & {
    name: string;
};
export interface XpodTaskEventData {
    source: string;
    requestId?: string;
    authBindingId?: string;
    webId?: string;
    eventName: string;
    payload?: Record<string, unknown>;
}
export type XpodTaskEvent = EventPayload<XpodTaskEventData> & {
    name: string;
};
export interface InngestTaskSchedulerOptions<TContext = StoreContext> {
    backend: InngestRunExecutionBackend;
    taskService: TaskService<TContext>;
    getContext?: () => TContext | undefined;
    getContexts?: () => Iterable<TContext> | Promise<Iterable<TContext>>;
    resolveContext?: (data: Partial<XpodTaskMaterializeDueEventData & XpodTaskEventData>) => TContext | Promise<TContext | undefined> | undefined;
    recordContext?: (context: TContext | undefined) => void;
    durableDelivery?: boolean;
    executeInline?: boolean;
}
export declare class InngestTaskScheduler<TContext = StoreContext> {
    readonly materializeDueRunsFunction: import("inngest").InngestFunction<import("inngest").InngestFunction.Options<[{
        readonly cron: "*/1 * * * *";
    }, {
        readonly event: string;
    }], import("inngest").HandlerWithTriggers<{
        sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
        waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
        };
        sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
        } | null : EventPayload<any> | null>;
        run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
        sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
        invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
            function: TFunction;
        } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
            meta?: import("inngest/types").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 cron: "*/1 * * * *";
    }, {
        readonly event: string;
    }], Omit<Omit<import("inngest/types").BaseContext<import("inngest").Inngest.Any>, never> & Record<never, never> & {
        logger: import("inngest").Logger;
    }, "group" | "step" | "requestId" | "event" | "attempt" | "events" | "runId" | "defer" | "jobId" | "maxAttempts"> & import("inngest/types").FailureEventArgs<EventPayload<any>> & {
        step: {
            sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
            waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
            };
            sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
            } | null : EventPayload<any> | null>;
            run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
            sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
            invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
                function: TFunction;
            } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
                meta?: import("inngest/types").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<MaterializedTaskRun[]>, import("inngest").HandlerWithTriggers<{
        sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
        waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
        };
        sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
        } | null : EventPayload<any> | null>;
        run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
        sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
        invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
            function: TFunction;
        } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
            meta?: import("inngest/types").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 cron: "*/1 * * * *";
    }, {
        readonly event: string;
    }], Omit<Omit<import("inngest/types").BaseContext<import("inngest").Inngest.Any>, never> & Record<never, never> & {
        logger: import("inngest").Logger;
    }, "group" | "step" | "requestId" | "event" | "attempt" | "events" | "runId" | "defer" | "jobId" | "maxAttempts"> & import("inngest/types").FailureEventArgs<EventPayload<any>> & {
        step: {
            sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
            waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
            };
            sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
            } | null : EventPayload<any> | null>;
            run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
            sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
            invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
                function: TFunction;
            } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
                meta?: import("inngest/types").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;
        };
    }>, import("inngest").Inngest<import("inngest/types").ClientOptions>, [{
        readonly cron: "*/1 * * * *";
    }, {
        readonly event: string;
    }]>;
    readonly eventTaskFunction: import("inngest").InngestFunction<import("inngest").InngestFunction.Options<[{
        readonly event: string;
    }], import("inngest").HandlerWithTriggers<{
        sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
        waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
        };
        sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
        } | null : EventPayload<any> | null>;
        run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
        sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
        invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
            function: TFunction;
        } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
            meta?: import("inngest/types").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;
    }], Omit<Omit<import("inngest/types").BaseContext<import("inngest").Inngest.Any>, never> & Record<never, never> & {
        logger: import("inngest").Logger;
    }, "group" | "step" | "requestId" | "event" | "attempt" | "events" | "runId" | "defer" | "jobId" | "maxAttempts"> & import("inngest/types").FailureEventArgs<EventPayload<any>> & {
        step: {
            sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
            waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
            };
            sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
            } | null : EventPayload<any> | null>;
            run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
            sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
            invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
                function: TFunction;
            } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
                meta?: import("inngest/types").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<MaterializedTaskRun[]>, import("inngest").HandlerWithTriggers<{
        sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
        waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
        };
        sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
        } | null : EventPayload<any> | null>;
        run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
        sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
        invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
            function: TFunction;
        } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
            meta?: import("inngest/types").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;
    }], Omit<Omit<import("inngest/types").BaseContext<import("inngest").Inngest.Any>, never> & Record<never, never> & {
        logger: import("inngest").Logger;
    }, "group" | "step" | "requestId" | "event" | "attempt" | "events" | "runId" | "defer" | "jobId" | "maxAttempts"> & import("inngest/types").FailureEventArgs<EventPayload<any>> & {
        step: {
            sendEvent: (idOrOptions: import("inngest/types").StepOptionsOrId, payload: import("inngest").SendEventPayload) => Promise<import("inngest/types").SendEventOutput<import("inngest").ClientOptionsFromInngest<import("inngest").Inngest<import("inngest/types").ClientOptions>>>>;
            waitForSignal: <TData>(idOrOptions: import("inngest/types").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/types").StepOptionsOrId, topicRef: import("inngest").Realtime.TopicRef<TData>, data: TData) => Promise<TData>;
            };
            sendSignal: (idOrOptions: import("inngest/types").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/types").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/types").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/types").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/types").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/types").ReceivedEventMeta;
            } | null : EventPayload<any> | null>;
            run: <TFn extends (...args: any[]) => unknown>(idOrOptions: import("inngest/types").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/types").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/types").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/types").StepOptionsOrId, time: number | string | import("inngest").DurationLike) => Promise<void>;
            sleepUntil: (idOrOptions: import("inngest/types").StepOptionsOrId, time: Date | string | import("inngest").InstantLike | import("inngest").ZonedDateTimeLike) => Promise<void>;
            invoke: <TFunction extends import("inngest/types").InvokeTargetFunctionDefinition>(idOrOptions: import("inngest/types").StepOptionsOrId, opts: {
                function: TFunction;
            } & Omit<import("inngest/types").TriggerEventFromFunction<TFunction>, "id"> & {
                meta?: import("inngest/types").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;
        };
    }>, import("inngest").Inngest<import("inngest/types").ClientOptions>, [{
        readonly event: string;
    }]>;
    private readonly taskService;
    private readonly getContext;
    private readonly getContexts?;
    private readonly resolveContext?;
    private readonly recordContext?;
    private readonly durableDelivery;
    private readonly executeInline;
    private readonly pendingDueTasks;
    private readonly pendingTaskEvents;
    private readonly client;
    private readonly source;
    private readonly materializeDueEventName;
    private readonly taskEventName;
    constructor(options: InngestTaskSchedulerOptions<TContext>);
    getFunctions(): unknown[];
    materializeDueTasks(context: TContext, options?: {
        now?: number;
        limit?: number;
    }): Promise<MaterializedTaskRun[]>;
    materializeEventTasks(input: {
        eventName: string;
        payload?: Record<string, unknown>;
        context: TContext;
    }): Promise<MaterializedTaskRun[]>;
    private handleDueTasks;
    private handleTaskEvent;
    private createInlineDueContext;
    private createInlineEventContext;
    private resolveDueContexts;
    private sourceRequestId;
    private resolveSingleContext;
    private contextEventData;
}