Bulk Resume Workflows from DLQ

When a workflow run fails, it’s automatically moved to the DLQ (Dead Letter Queue) where it can be analyzed and resumed. The resume feature allows you to continue a failed workflow run from exactly where it failed, without re-executing successfully completed steps.

This is particularly useful for long-running workflows where you don’t want to lose progress from successful steps when a single step fails.

When a workflow is resumed, it continues execution from the last failed step. A new workflow run ID is generated, but the workflow maintains the state and results from previously completed steps.

You can make changes to the workflow code as long as these changes come after the failed steps. However, making changes before the failed step will break the code and is not allowed.

For more details, check out Handle workflow route code changes page.

POST /v2/workflows/dlq/resume

Bulk Resume Workflows from DLQ

cURL

curl --request POST \
  --url https://qstash.upstash.io/v2/workflows/dlq/resume \
  --header 'Authorization: Bearer <token>'

200

{
  "workflowRuns": [
    {
      "workflowRunId": "<string>",
      "workflowCreatedAt": 123
    }
  ],
  "cursor": "<string>"
}

Authorizations

bearerAuthbearerAuthQuery

Authorization · string · header · required

QStash authentication token

Headers

Upstash-Retries · integer

Override the number of retries for the remaining workflow steps.

Upstash-Delay · string

Override the delay before executing the next workflow step. Format is <value><unit> (e.g., "10s", "5m").

Upstash-Retry-Delay · string

Override the retry delay expression for the remaining workflow steps.

Upstash-Flow-Control-Key · string

Override the flow control key for the remaining workflow steps.

Upstash-Flow-Control-Value · string

Override the flow control configuration in the format parallelism=<value>, rate=<value>, period=<value>.

Upstash-Label · string

Override the label for the remaining workflow steps.

Upstash-Failure-Callback · string

Override the failure callback URL for the remaining workflow steps.

Query Parameters

dlqIds · string[]

List of specific DLQ IDs to resume. If provided, other filters are ignored.

cursor · string

Pagination cursor for resuming workflows in batches.

count · integer

Maximum number of workflows to resume. If not provided, all matching workflows will be resumed.

fromDate · integer<int64>

Filter workflows by starting date, in milliseconds (Unix timestamp). This is inclusive.

toDate · integer<int64>

Filter workflows by ending date, in milliseconds (Unix timestamp). This is inclusive.

workflowUrl · string

Filter workflows by workflow URL.

workflowRunId · string

Filter workflows by workflow run ID.

workflowCreatedAt · integer<int64>

Filter workflows by creation timestamp in milliseconds (Unix timestamp).

label · string

Filter workflows by label assigned by the user.

failureFunctionState · string

Filter workflows by failure function state.

State	Description
CALLBACK_INPROGRESS	The failure function is in progress.
CALLBACK_SUCCESS	The failure function run successfully.
CALLBACK_FAIL	The failure function failed to run.
CALLBACK_CANCELED	The failure function was manually canceled

callerIp · string

Filter workflows by IP address of the publisher.

flowControlKey · string

Filter workflows by Flow Control Key.

Response

200

application/json

Workflows resumed successfully

workflowRuns · object[]

Array of resumed workflow runs.

Show child attributes

cursor · string

Pagination cursor to use in subsequent requests. If empty, all matching workflows have been processed.