<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 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.