Getting Started

Install

PyPI

pip install upstash-qstash

Get QStash token

Follow the instructions here to get your QStash token and signing keys.

Usage

Synchronous Client

from upstash_qstash import Client
client = Client("<QSTASH_TOKEN>")

def handler():
  client.publish_json(...)

if __name__ == "__main__":
  main()

Asynchronous Client

import asyncio
from upstash_qstash.asyncio import Client

async def handler():
  await client.publish_json(...)

if __name__ == "__main__":
  asyncio.run(main())

RetryConfig

You can configure the retry policy of the client by passing the configuration to the client constructor.

Note: This isn for sending the request to QStash, not for the retry policy of QStash.

The default number of attempts is 6 and the default backoff function is lambda retry_count: math.exp(retry_count) * 50.

You can also pass in False to disable retrying.

from upstash_qstash import Client
client = Client("<QSTASH_TOKEN>", {
  "attempts": 3,
  "backoff": lambda retry_count: (2 ** retry_count) * 20,
})