Queues - Upstash Documentation

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)

Warning

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)

Warning

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.