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))
from qstash import QStash client = QStash("<QSTASH-TOKEN>") queue_name = "upstash-queue" client.queue.delete(queue_name)
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)
Was this page helpful?