python - How to retrieve list of tasks in a queue in Celery?

Question

My goal is to retrieve active & reserved tasks on my Celery workers.

I'm using a Django-Celery-Redis framework.

As suggested here: Retrieve list of tasks in a queue in Celery

I have done this to retrieve the tasks:

from your_app.celery import app as my_app

i = my_app.control.inspect()
active_tasks = i.active()
reserved_tasks = i.reserved()

It works well under my local environment.

Online though (I'm using Heroku), it works 5% of the time & 95% of the time I get some errors.

I get two types of errors, that randomly appears:

raise ConnectionError(str(exc)) from exc
kombu.exceptions.OperationalError: Error 0 connecting to THE_REDIS_SERVER. Error.

Or I get a None response from my calls.

I tried to configure some timeouts because by default control.inspect has timeout = 1.0.

from your_app.celery import app as my_app

i = my_app.control.inspect(timeout = 4.0)
active_tasks = i.active()
reserved_tasks = i.reserved()

But still I get some connection errors.

Any ideas?

标签： pythondjangoherokurediscelery