Events

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

Get all events with pagination using cursor

Since there can be a large number of events, they are paginated. You can go through the results using the cursor.

from upstash_qstash import Client

client = Client("<QSTASH_TOKEN>")
all_events = []
cursor = None
while True:
  res = client.events({"cursor": cursor})
  all_events.extend(res["events"])
  cursor = res.get("cursor")
  if cursor is None:
    break