Examples
Queues
Create a queue with parallelism
from qstash import QStash
client = QStash("<QSTASH-TOKEN>")
queue_name = "upstash-queue"
client.queue.upsert(queue_name, parallelism=2)
print(client.queue.get(queue_name))
Delete a queue
from qstash import QStash
client = QStash("<QSTASH-TOKEN>")
queue_name = "upstash-queue"
client.queue.delete(queue_name)
Pause/Resume a queue
from qstash import QStash
client = QStash("<QSTASH-TOKEN>")
queue_name = "upstash-queue"
client.queue.upsert(queue_name, parallelism=1)
client.queue.pause(queue_name)
queue = client.queue.get(queue_name)
print(queue.paused) # prints True
client.queue.resume(queue_name)