import { type PaginationResult } from "convex/server"; import { type Infer, type Value } from "convex/values"; import { type MutationCtx } from "./_generated/server.js"; import { type WorkflowId, type EventId, type SchedulerOptions } from "../types.js"; declare const createArgs: import("convex/values").VObject<{ maxParallelism?: number | undefined; onComplete?: { context?: any; fnHandle: string; } | undefined; startAsync?: boolean | undefined; workflowHandle: string; workflowArgs: any; workflowName: string; }, { workflowName: import("convex/values").VString; workflowHandle: import("convex/values").VString; workflowArgs: import("convex/values").VAny; maxParallelism: import("convex/values").VFloat64; onComplete: import("convex/values").VObject<{ context?: any; fnHandle: string; } | undefined, { fnHandle: import("convex/values").VString; context: import("convex/values").VAny; }, "optional", "context" | `context.${string}` | "fnHandle">; startAsync: import("convex/values").VBoolean; }, "required", "maxParallelism" | "workflowHandle" | "onComplete" | "onComplete.context" | `onComplete.context.${string}` | "onComplete.fnHandle" | "startAsync" | "workflowArgs" | "workflowName" | `workflowArgs.${string}`>; export declare const create: import("convex/server").RegisteredMutation<"public", { maxParallelism?: number | undefined; onComplete?: { context?: any; fnHandle: string; } | undefined; startAsync?: boolean | undefined; workflowHandle: string; workflowArgs: any; workflowName: string; }, Promise>>; export declare function createHandler(ctx: MutationCtx, args: Infer, schedulerOptions?: SchedulerOptions): Promise>; export declare const getStatus: import("convex/server").RegisteredQuery<"public", { workflowId: import("convex/values").GenericId<"workflows">; }, Promise<{ workflow: { args: string | number | bigint | boolean | ArrayBuffer | Value[] | { [key: string]: Value | undefined; } | null; runResult: { kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; } | undefined; _id: import("convex/values").GenericId<"workflows">; _creationTime: number; name?: string | undefined; startedAt?: null | undefined; logLevel?: null | undefined; onComplete?: { context?: any; fnHandle: string; } | undefined; state?: null | undefined; workflowHandle: string; generationNumber: number; }; inProgress: { step: { args: string | number | bigint | boolean | ArrayBuffer | Value[] | { [key: string]: Value | undefined; } | null; runResult: { kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; } | undefined; kind?: "function" | undefined; completedAt?: number | undefined; workId?: import("@convex-dev/workpool").WorkId | undefined; name: string; startedAt: number; functionType: "query" | "mutation" | "action"; handle: string; inProgress: boolean; argsSize: number; } | { args: string | number | bigint | boolean | ArrayBuffer | Value[] | { [key: string]: Value | undefined; } | null; runResult: { kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; } | undefined; workflowId?: import("convex/values").GenericId<"workflows"> | undefined; completedAt?: number | undefined; kind: "workflow"; name: string; startedAt: number; handle: string; inProgress: boolean; argsSize: number; } | { args: string | number | bigint | boolean | ArrayBuffer | Value[] | { [key: string]: Value | undefined; } | null; runResult: { kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; } | undefined; completedAt?: number | undefined; eventId?: import("convex/values").GenericId<"events"> | undefined; kind: "event"; name: string; startedAt: number; inProgress: boolean; argsSize: number; } | { args: string | number | bigint | boolean | ArrayBuffer | Value[] | { [key: string]: Value | undefined; } | null; runResult: { kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; } | undefined; completedAt?: number | undefined; workId?: import("@convex-dev/workpool").WorkId | undefined; kind: "sleep"; name: string; startedAt: number; inProgress: boolean; argsSize: number; }; workflowId: import("convex/values").GenericId<"workflows">; stepNumber: number; _creationTime: number; _id: string; }[]; logLevel: "DEBUG" | "TRACE" | "INFO" | "REPORT" | "WARN" | "ERROR"; }>>; export declare const list: import("convex/server").RegisteredQuery<"public", { order: "asc" | "desc"; paginationOpts: { id?: number; endCursor?: string | null; maximumRowsRead?: number; maximumBytesRead?: number; numItems: number; cursor: string | null; }; }, Promise>>; export declare const listByName: import("convex/server").RegisteredQuery<"public", { name: string; order: "asc" | "desc"; paginationOpts: { id?: number; endCursor?: string | null; maximumRowsRead?: number; maximumBytesRead?: number; numItems: number; cursor: string | null; }; }, Promise>>; export declare const listSteps: import("convex/server").RegisteredQuery<"public", { workflowId: import("convex/values").GenericId<"workflows">; order: "asc" | "desc"; paginationOpts: { id?: number; endCursor?: string | null; maximumRowsRead?: number; maximumBytesRead?: number; numItems: number; cursor: string | null; }; }, Promise | undefined; kind: "function" | "workflow" | "event" | "sleep"; workflowId: WorkflowId; name: string; args: any; stepId: string; stepNumber: number; startedAt: number; }>>>; declare const restartArgs: import("convex/values").VObject<{ startAsync?: boolean | undefined; from?: string | number | undefined; workflowId: import("convex/values").GenericId<"workflows">; }, { workflowId: import("convex/values").VId, "required">; from: import("convex/values").VUnion, import("convex/values").VString], "optional", never>; startAsync: import("convex/values").VBoolean; }, "required", "workflowId" | "startAsync" | "from">; export declare const restart: import("convex/server").RegisteredMutation<"public", { startAsync?: boolean | undefined; from?: string | number | undefined; workflowId: import("convex/values").GenericId<"workflows">; }, Promise>; export declare function restartHandler(ctx: MutationCtx, args: Infer): Promise; export declare const cancel: import("convex/server").RegisteredMutation<"public", { workflowId: import("convex/values").GenericId<"workflows">; }, Promise>; declare const completeArgs: import("convex/values").VObject<{ workflowId: import("convex/values").GenericId<"workflows">; runResult: { kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; }; generationNumber: number; }, { workflowId: import("convex/values").VId, "required">; generationNumber: import("convex/values").VFloat64; runResult: import("convex/values").VUnion<{ kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; }, [import("convex/values").VObject<{ kind: "success"; returnValue: any; }, { kind: import("convex/values").VLiteral<"success", "required">; returnValue: import("convex/values").VAny; }, "required", "kind" | "returnValue" | `returnValue.${string}`>, import("convex/values").VObject<{ kind: "failed"; error: string; }, { kind: import("convex/values").VLiteral<"failed", "required">; error: import("convex/values").VString; }, "required", "kind" | "error">, import("convex/values").VObject<{ kind: "canceled"; }, { kind: import("convex/values").VLiteral<"canceled", "required">; }, "required", "kind">], "required", "kind" | "returnValue" | `returnValue.${string}` | "error">; }, "required", "workflowId" | "runResult" | "runResult.kind" | "runResult.returnValue" | `runResult.returnValue.${string}` | "runResult.error" | "generationNumber">; export declare const complete: import("convex/server").RegisteredMutation<"public", { workflowId: import("convex/values").GenericId<"workflows">; runResult: { kind: "success"; returnValue: any; } | { kind: "failed"; error: string; } | { kind: "canceled"; }; generationNumber: number; }, Promise>; export declare function completeHandler(ctx: MutationCtx, args: Infer): Promise; export declare const cleanup: import("convex/server").RegisteredMutation<"public", { force?: boolean | undefined; workflowId: string; }, Promise>; export declare const sleep: import("convex/server").RegisteredQuery<"internal", {}, Promise>; export {}; //# sourceMappingURL=workflow.d.ts.map