You can run the async code by importing Client from upstash_qstash.asyncio and awaiting the methods.
Client
upstash_qstash.asyncio
Since there can be a large number of events, they are paginated. You can go through the results using the cursor.
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
Was this page helpful?