client.dlq.resume - Upstash Documentation

The dlq.resume method resumes one or more workflow runs from the Dead Letter Queue (DLQ) at the point where they previously failed. This allows you to continue execution from the failed step instead of restarting the workflow from the beginning.

Arguments

The first argument specifies which DLQ entries to resume. The optional second argument provides flow control and retry settings.

By DLQ ID

Pass a single DLQ ID or an array of IDs directly:

await client.dlq.resume("dlq-12345");await client.dlq.resume(["dlq-12345", "dlq-67890"]);

By filters

Pass an object with a filter field:

filterbodyobject

workflowUrlbodystring

Filter by exact workflow URL.

workflowRunIdbodystring

Filter by workflow run ID.

labelbodystring | string[]

Resume workflows with this label. Pass an array to match runs that have any of the given labels (OR semantics).

fromDatebodyDate | number

Resume workflows created after this date.

toDatebodyDate | number

Resume workflows created before this date.

callerIpbodystring

Filter by the IP address that triggered the workflow.

flowControlKeybodystring

Filter by flow control key.

workflowCreatedAtbodynumber

Filter by workflow creation time (Unix timestamp in ms).

failureFunctionStatebodystring

Filter by failure callback state.

countbodynumber

Maximum number of messages to process per call. Defaults to 100.

cursorbodystring

A pagination cursor from a previous request.

Resume all

allbodyboolean

Set to true to resume all DLQ entries.

Options (second argument)

flowControlbodyobject

An optional flow control configuration to limit concurrency and execution rate of resumed workflow runs.

See Flow Control for details.

keybodystring

A logical grouping key that identifies which resumed runs share the same flow control limits.

ratebodynumber

The maximum number of allowed resumption requests per second.

parallelismbodynumber

The maximum number of resumed runs that can execute concurrently.

periodbodystring|number

The time window used to enforce the defined rate limit. Default is 1s.

retriesbodynumber

Number of retry attempts to apply when resuming the workflow run. Defaults to 3 if not provided.

Response

cursorstring

A pagination cursor. If not returned, all matching entries have been processed.

workflowRunsobject[]

workflowRunIdstring

The ID of the workflow run resumed from the DLQ message.

workflowCreatedAtnumber

The Unix timestamp (in milliseconds) when the resumed run was created.

Usage

Single

const { messages } = await client.dlq.list();const response = await client.dlq.resume(messages[0].dlqId, {  flowControl: {    key: "my-flow-control-key",    parallelism: 10,  },  retries: 3,});

Multiple

const response = await client.dlq.resume(["dlq-12345", "dlq-67890"]);

By filters

let cursor: string | undefined;do {  const result = await client.dlq.resume({    filter: {      label: "my-label",      workflowUrl: "https://example.com/workflow",    },    cursor,  });  cursor = result.cursor;} while (cursor);

All

let cursor: string | undefined;do {  const result = await client.dlq.resume({ all: true, cursor });  cursor = result.cursor;} while (cursor);