You can run the async code by importing AsyncQStash from qstash
and awaiting the methods.
Retrieve a message
from qstash import QStash
client = QStash("<QSTASH-TOKEN>")
msg = client.message.get("<msg-id>")
Cancel/delete a message
from qstash import QStash
client = QStash("<QSTASH-TOKEN>")
client.message.cancel("<msg-id>")
Cancel messages in bulk
Cancel many messages at once or cancel all messages
from qstash import QStash
client = QStash("<QSTASH-TOKEN>")
# cancel more than one message
client.message.cancel_many(["<msg-id-0>", "<msg-id-1>"])
# cancel all messages
client.message.cancel_all()