import type { WorkerApiConnectRequestBody, WorkerApiDequeueRequestBody, WorkerApiHeartbeatRequestBody, WorkerApiRunAttemptCompleteRequestBody, WorkerApiRunAttemptStartRequestBody, WorkerApiRunHeartbeatRequestBody, WorkerApiRunRestoreOutcomeRequestBody, WorkerApiDebugLogBody, WorkerApiSuspendRunRequestBody } from "./schemas.js"; import { WorkerApiContinueRunExecutionRequestBody } from "./schemas.js"; import type { SupervisorClientCommonOptions } from "./types.js"; import { type ContinueRetryBudget, type ContinueRetrySummary } from "./continueRetry.js"; import { type ApiResult } from "../../zodfetch.js"; type SupervisorHttpClientOptions = SupervisorClientCommonOptions; export declare class SupervisorHttpClient { private readonly apiUrl; private readonly workerToken; private readonly instanceName; private readonly defaultHeaders; private readonly sendRunDebugLogs; private readonly resolveResponseSchema; private readonly onHttpRequestComplete?; private readonly logger; constructor(opts: SupervisorHttpClientOptions); private request; connect(body: WorkerApiConnectRequestBody): Promise>; dequeue(body: WorkerApiDequeueRequestBody): Promise; annotations?: { triggerSource: "api" | "cli" | "dashboard" | "mcp" | "schedule" | "sdk" | (string & {}); triggerAction: "replay" | "test" | "trigger" | (string & {}); rootTriggerSource: "api" | "cli" | "dashboard" | "mcp" | "schedule" | "sdk" | (string & {}); rootScheduleId?: string | undefined; taskKind?: "AGENT" | "SCHEDULED" | "STANDARD" | (string & {}) | undefined; externalDeploymentId?: string | undefined; webhookDeliveryId?: string | undefined; webhookEndpointId?: string | undefined; workerCell?: string | undefined; workerLane?: string | undefined; } | undefined; }; environment: { id: string; type: "DEVELOPMENT" | "PREVIEW" | "PRODUCTION" | "STAGING"; }; organization: { id: string; hasPrivateLink?: boolean | undefined; }; project: { id: string; }; placementTags?: { key: string; values?: string[] | undefined; }[] | undefined; }[]>>; heartbeatWorker(body: WorkerApiHeartbeatRequestBody): Promise>; heartbeatRun(runId: string, snapshotId: string, body: WorkerApiRunHeartbeatRequestBody, runnerId?: string): Promise>; startRunAttempt(runId: string, snapshotId: string, body: WorkerApiRunAttemptStartRequestBody, runnerId?: string, environmentId?: string): 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: WorkerApiRunAttemptCompleteRequestBody, runnerId?: string, environmentId?: string): Promise>; getLatestSnapshot(runId: string, runnerId?: string, environmentId?: string): Promise>; getSnapshotsSince(runId: string, snapshotId: string, runnerId?: string, environmentId?: string): Promise>; sendDebugLog(runId: string, body: WorkerApiDebugLogBody, runnerId?: string): Promise; continueRunExecution(runId: string, snapshotId: string, runnerId?: string, environmentId?: string, options?: { retryBudget?: ContinueRetryBudget; }): Promise & { retry?: ContinueRetrySummary; }>; reportRestoreOutcome(runId: string, snapshotId: string, body: WorkerApiRunRestoreOutcomeRequestBody, runnerId?: string, environmentId?: string): Promise>; submitSuspendCompletion({ runId, snapshotId, runnerId, body, }: { runId: string; snapshotId: string; runnerId?: string; body: WorkerApiSuspendRunRequestBody; }): Promise>; private runnerIdHeader; private environmentIdHeader; } export {};