The dlq.delete method deletes one or more workflow runs from the Dead Letter Queue (DLQ).
Arguments
You can delete DLQ entries by ID, by an array of IDs, or by filters.
By DLQ ID
Pass a single DLQ ID or an array of IDs directly:
await client.dlq.delete("dlq-123");
await client.dlq.delete(["dlq-123", "dlq-456"]);
dlqIds:
await client.dlq.delete({ dlqIds: ["dlq-123", "dlq-456"] });
By filters
Filter by exact workflow URL.
Filter by workflow run ID.
Delete workflows with this label.
Delete workflows created after this date. Accepts Date objects or Unix timestamps (ms).
Delete workflows created before this date. Accepts Date objects or Unix timestamps (ms).
Filter by the IP address that triggered the workflow.
Filter by flow control key.
Filter by workflow creation time (Unix timestamp in ms).
Filter by failure callback state.
Maximum number of messages to process per call. Defaults to 100.
A pagination cursor from a previous request.
Delete all
Set to true to delete all DLQ entries.
Response
The number of DLQ entries that were deleted.
A pagination cursor. If not returned, all matching entries have been processed.
Usage
await client.dlq.delete("dlq-123");
