Tech Insights· docs.celeryproject.org
To list the current Celery tasks names in Redis queue, use:
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})
For reserved and active, use app.control.inspect(): #inspecting-workers
Shared by
- Celery
- Python
