Skip to main content

Interface: SpillingJobTransportOptions

Defined in: packages/workflow-engine/src/kernel/spill.ts:355

Extends​

Properties​

blobStore​

blobStore: BlobStore

Defined in: packages/workflow-engine/src/kernel/spill.ts:115

Where spilled values are written. Required — see the module comment.

Inherited from​

PayloadSpillOptions.blobStore

groupBy?​

optional groupBy?: string

Defined in: packages/workflow-engine/src/kernel/spill.ts:365

Dotted path into the job payload naming the fairness group. Defaults to the wrapped transport's own fairnessGroupBy when it exposes one (the Prisma job queue does), so a queue with fairness configured needs no extra configuration here. When set (or discovered) and a payload is about to spill, the value at that path is hoisted onto EnqueueJobInput.groupKey before the body is packed, so the queue row still carries the group and starvation protection survives spilling.

thresholdBytes?​

optional thresholdBytes?: number

Defined in: packages/workflow-engine/src/kernel/spill.ts:121

Soft threshold in bytes of serialised JSON. Defaults to DEFAULT_SPILL_THRESHOLD_BYTES. Number.POSITIVE_INFINITY stops new values from spilling without breaking reads of old ones.

Inherited from​

PayloadSpillOptions.thresholdBytes