Skip to content

@saflib/jobs-db


Variable: retryByIdJob()

const retryByIdJob: (dbKey, params) => Promise<ReturnsError<{ attempt: number; authority: JobAuthority; concurrency_key: null | string; created_at: Date; dedupe_key: null | string; enqueued_by_operation_id: string; finished_at: null | Date; heartbeat_at: null | Date; id: string; max_attempts: number; operation_id: string; original_request_id: string; parent_job_id: null | string; priority: number; request: JobRequest; result: null | JobResult; run_at: Date; started_at: null | Date; status: "pending" | "running" | "retrying" | "succeeded" | "dead" | "cancelled"; updated_at: Date; user_id: string; }, RetryByIdJobError>>>>

Re-queue a dead/cancelled job as pending with a full attempt reset. Other statuses return JobNotRetryableError (409-style).

Parameters

ParameterType
dbKeysymbol
paramsRetryByIdJobParams

Returns

Promise<ReturnsError<{ attempt: number; authority: JobAuthority; concurrency_key: null | string; created_at: Date; dedupe_key: null | string; enqueued_by_operation_id: string; finished_at: null | Date; heartbeat_at: null | Date; id: string; max_attempts: number; operation_id: string; original_request_id: string; parent_job_id: null | string; priority: number; request: JobRequest; result: null | JobResult; run_at: Date; started_at: null | Date; status: "pending" | "running" | "retrying" | "succeeded" | "dead" | "cancelled"; updated_at: Date; user_id: string; }, RetryByIdJobError>>