DLQ

You can run the async code by importing Client from upstash_qstash.asyncio and awaiting the methods.

Get all messages with pagination using cursor

Since the DLQ can have a large number of messages, they are paginated. You can go through the results using the cursor.

from upstash_qstash import Client



dlq = client.dlq()

all_messages = []

cursor = None

while True:

  res = dlq.list_messages({"cursor": cursor})

  all_messages.extend(res["messages"])

  cursor = res.get("cursor")

  if cursor is None:

    break

Get a message from the DLQ

from upstash_qstash import Client



dlq = client.dlq()

msg = dlq.get("dlqId")

Delete a message from the DLQ

from upstash_qstash import Client



dlq = client.dlq()

dlq.delete("dlqId")