79π
Try this in terminal
ps aux|grep 'celery worker'
You will see like this
username 29042 0.0 0.6 23216 14356 pts/1 S+ 00:18 0:01 /bin/celery worker ...
Then kill process id by
sudo kill -9 process_id # here 29042
If you have multiple processes, then you have to kill all process id using above kill
commmand
sudo kill -9 id1 id2 id3 ...
From the celery doc
ps auxww | grep 'celery worker' | awk '{print $2}' | xargs kill -9
OR if you are running celeryd
ps auxww | grep celeryd | awk '{print $2}' | xargs kill -9
Note
If you are running celery
in supervisor
, even though kill the process, it automatically restarts(if autorestart=True
in supervisor script).
- [Django]-How to get primary keys of objects created using django bulk_create
- [Django]-Ignoring Django Migrations in pyproject.toml file for Black formatter
- [Django]-Feedback on using Google App Engine?
42π
If the celery worker is running on a machine you do not have access to, you can use Celery "remote control" to control workers through messages sent via the broker.
celery control shutdown
This will kill all workers immediately. Depending on your setup, you might have to use -A myProject
, like with Django.
Documentation here.
- [Django]-Django : How can I find a list of models that the ORM knows?
- [Django]-Embed YouTube video β Refused to display in a frame because it set 'X-Frame-Options' to 'SAMEORIGIN'
- [Django]-Using Basic HTTP access authentication in Django testing framework
4π
ps auxww | grep 'celery worker' | grep -v " grep " | awk '{print $2}' | xargs kill -9
this one is very similar to one presented before but improved because avoid the error that shows when attempt to kill the grep process..
- [Django]-How to customize user profile when using django-allauth
- [Django]-Sending post data from angularjs to django as JSON and not as raw content
- [Django]-Adding a user to a group in django
1π
In case someoneβs looking to shutdown their celery app programmatically, the same thing can be done in python with:
celery_app.control.shutdown()
- [Django]-Django dynamic model fields
- [Django]-How to duplicate virtualenv
- [Django]-How to pass multiple values for a single URL parameter?