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