Examples
Queues
Create a queue with parallelism
from qstash import QStashclient = 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 QStashclient = QStash("<QSTASH-TOKEN>")queue_name = "upstash-queue"client.queue.delete(queue_name)Resuming or creating a queue may take up to a minute. Therefore, it is not recommended to pause or delete a queue during critical operations.
Pause/Resume a queue
from qstash import QStashclient = 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 Trueclient.queue.resume(queue_name)Resuming or creating a queue may take up to a minute. Therefore, it is not recommended to pause or delete a queue during critical operations.