How to diagnose celery workers who are hanging

Question

I start with Celery for the Django project. For local development purposes, I installed it with djcelery and djkombu (transporting the database) according to these instructions http://ask.github.com/celery/tutorials/otherqueues.html#django-database , but plan on using rabbitmq on the production server .

I found that it works, but one or more of them will hang randomly. Workers hang on different tasks, so this is not the case when one specific task enters into an infinite loop. When I try to close the celery, in the journal I usually see all the workers coming out with the exception of one. Both before and after the worker freezes, I tried to use celeryctl to get information about the workers, but celeryctl always fails with the message "Error: No nodes responded in time." I also tried checking workers at http://docs.celeryproject.org/en/latest/userguide/workers.html#inspecting-workers , but all methods return nothing.

Any ideas on how to diagnose what causes the employee to hang or be useful.

Answer 1

I had the same problem. I think this is due to the fact that you are using ghettoq , which does not support events.

On request:

remote control commands (broadcast) and events do not work with ghettoq.