How can I programmatically, using Python code, list current workers and their corresponding celery.worker.consumer.Consumer
instances?
You can use celery.control.inspect to inspect the running workers:
>>> import celery
>>> celery.current_app.control.inspect().ping()
{u'celery@host': {u'ok': u'pong'}}
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With