import type { WorkloadHeartbeatRequestBody, WorkloadRunAttemptCompleteRequestBody, WorkloadRunAttemptStartRequestBody, WorkloadDebugLogRequestBody } from "./schemas.js"; import type { WorkloadClientCommonOptions } from "./types.js"; type WorkloadHttpClientOptions = WorkloadClientCommonOptions; export declare class WorkloadHttpClient { private opts; private apiUrl; private runnerId; constructor(opts: WorkloadHttpClientOptions); updateApiUrl(apiUrl: string): void; updateRunnerId(runnerId: string): void; defaultHeaders(): Record; private isConnectionError; private withConnectionErrorDetection; heartbeatRun(runId: string, snapshotId: string, body?: WorkloadHeartbeatRequestBody): Promise<{ success: true; data: { ok: true; }; } | { success: false; error: string; isConnectionError?: boolean; }>; suspendRun(runId: string, snapshotId: string): Promise>; continueRunExecution(runId: string, snapshotId: string): Promise<{ success: true; data: { snapshot: { id: string; friendlyId: string; executionStatus: "DELAYED" | "EXECUTING" | "EXECUTING_WITH_WAITPOINTS" | "FINISHED" | "PENDING_CANCEL" | "PENDING_EXECUTING" | "QUEUED" | "QUEUED_EXECUTING" | "RUN_CREATED" | "SUSPENDED"; description: string; createdAt: Date; }; run: { id: string; friendlyId: string; status: "CANCELED" | "COMPLETED_SUCCESSFULLY" | "COMPLETED_WITH_ERRORS" | "CRASHED" | "DELAYED" | "DEQUEUED" | "EXECUTING" | "EXPIRED" | "INTERRUPTED" | "PAUSED" | "PENDING" | "PENDING_VERSION" | "RETRYING_AFTER_FAILURE" | "SYSTEM_FAILURE" | "TIMED_OUT" | "WAITING_FOR_DEPLOY" | "WAITING_TO_RESUME"; attemptNumber?: number | null | undefined; taskEventStore?: string | undefined; }; }; } | { success: false; error: string; isConnectionError?: boolean; }>; startRunAttempt(runId: string, snapshotId: string, body: WorkloadRunAttemptStartRequestBody): Promise | undefined; maxDuration?: number | undefined; priority?: number | undefined; baseCostInCents?: number | undefined; parentTaskRunId?: string | undefined; rootTaskRunId?: string | undefined; durationMs?: number | undefined; costInCents?: number | undefined; region?: string | undefined; } & { traceContext?: Record | undefined; realtimeStreamsVersion?: string | undefined; }; }; } & { envVars: Record; }>>; completeRunAttempt(runId: string, snapshotId: string, body: WorkloadRunAttemptCompleteRequestBody): Promise>; getSnapshotsSince(runId: string, snapshotId: string): Promise<{ success: true; data: { snapshots: { version: "1"; snapshot: { id: string; friendlyId: string; executionStatus: "DELAYED" | "EXECUTING" | "EXECUTING_WITH_WAITPOINTS" | "FINISHED" | "PENDING_CANCEL" | "PENDING_EXECUTING" | "QUEUED" | "QUEUED_EXECUTING" | "RUN_CREATED" | "SUSPENDED"; description: string; createdAt: Date; }; run: { id: string; friendlyId: string; status: "CANCELED" | "COMPLETED_SUCCESSFULLY" | "COMPLETED_WITH_ERRORS" | "CRASHED" | "DELAYED" | "DEQUEUED" | "EXECUTING" | "EXPIRED" | "INTERRUPTED" | "PAUSED" | "PENDING" | "PENDING_VERSION" | "RETRYING_AFTER_FAILURE" | "SYSTEM_FAILURE" | "TIMED_OUT" | "WAITING_FOR_DEPLOY" | "WAITING_TO_RESUME"; attemptNumber?: number | null | undefined; taskEventStore?: string | undefined; }; batch?: { id: string; friendlyId: string; } | undefined; checkpoint?: { type: "COMPUTE" | "DOCKER" | "KUBERNETES"; location: string; imageRef?: string | null | undefined; reason?: string | null | undefined; id: string; friendlyId: string; } | undefined; completedWaitpoints: { id: string; index?: number | undefined; friendlyId: string; type: "BATCH" | "DATETIME" | "MANUAL" | "RUN"; completedAt: Date; idempotencyKey?: string | undefined; completedByTaskRun?: { id: string; friendlyId: string; batch?: { id: string; friendlyId: string; } | undefined; } | undefined; completedAfter?: Date | undefined; completedByBatch?: { id: string; friendlyId: string; } | undefined; output?: string | undefined; outputType?: string | undefined; outputIsError: boolean; }[]; }[]; }; } | { success: false; error: string; isConnectionError?: boolean; }>; sendDebugLog(runId: string, body: WorkloadDebugLogRequestBody): Promise; } export {};