CreateDrizzleJobQueueOptions

How long a dequeued job may stay processing before it is due again (default: Infinity, no lease). If it is neither completed nor failed by then, for example because the worker stopped mid-job, the next dequeue() counts the lost attempt as failed (error: "LEASE_EXPIRED") and makes the job due again, or fails it when no attempts are left. Set it above the longest time a job can take: a lease is not renewed, and a worker that outlives it can still complete or fail the job while another worker has it. dequeue() leaves the jobs its caller names as still running alone, which is how JobProcessor keeps a job it is still running from being run again or counted as lost.

Inherited from

JobLeaseOptions.leaseMs

mapTransactionDb?

optional mapTransactionDb?: (value) => DrizzleSqlDatabaseLike

Defined in: packages/messaging/src/adapters/cloudflare/sql-client.ts:50

Parameters

value

unknown

Returns

DrizzleSqlDatabaseLike

Inherited from

CreateDrizzleSqlClientOptions.mapTransactionDb

normalizeResult?

optional normalizeResult?: <T>(input) => CloudflareSqlQueryResult<T>

Defined in: packages/messaging/src/adapters/cloudflare/sql-client.ts:45

Type Parameters

T

T = Record<string, unknown>

Parameters

input

params

readonly unknown[]

result

unknown

sql

string

Returns

CloudflareSqlQueryResult<T>

Inherited from

CreateDrizzleSqlClientOptions.normalizeResult

onLeaseExpired?

optional onLeaseExpired?: (job) => void | Promise<void>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:72

Called by dequeue() for each job whose lease had expired, once the job is stored pending again or, with no attempts left, failed. dequeue() waits for it before it leases the job it returns, which may be the same one, so it does not shorten that lease. What it throws is logged and does not stop the dequeue.