<p>To list the current Celery tasks names in Redis queue, use:</p>
<p><code>import json
import base64
from redis import StrictRedis
redis_client = StrictRedis.from_url(BROKER_URL)
default_queue = redis_client.lrange('celery', 0, -1)
print({json.loads(base64.b64decode(json.loads(message.decode('utf-8'))['body']).decode('utf-8'))['task'] for message in default_queue})</code>
For reserved and active, use <code>app.control.inspect()</code>: #inspecting-workers</p>
By clicking “Accept cookies”, you agree to the storing of cookies on your device to enhance site navigation, analyze site usage and assist in our marketing efforts. Check our privacy policies.
By clicking “Accept all”, you agree to the storing of cookies on your device to enhance site navigation, analyze site usage and assist in our marketing efforts. Check our privacy policies.