Flow Control

List all flow control keys

from qstash import QStash

client = QStash("<QSTASH-TOKEN>")

controls = client.flow_control.list()
print(controls)

Get a single flow control key

from qstash import QStash

client = QStash("<QSTASH-TOKEN>")

info = client.flow_control.get("USER_GIVEN_KEY")
print(info.key)
print(info.wait_list_size)
print(info.parallelism_max)
print(info.parallelism_count)
print(info.rate_max)
print(info.rate_count)
print(info.rate_period)
print(info.rate_period_start)

Reset a flow control key

Resetting clears the parallelism and rate counters, allowing queued messages to be dispatched immediately.

from qstash import QStash

client = QStash("<QSTASH-TOKEN>")

client.flow_control.reset("USER_GIVEN_KEY")