Is importing celery app
and calling control.inspect()
the best way for inspecting active tasks? Also, I’m using RabbitMQ as my broker.
from core.celery import app
def get_running_tasks(request):
i = app.control.inspect()
i.active() # retrieving active tasks