Pārlūkot izejas kodu

celeryd: Stop worker on SIGTERM

Ask Solem 15 gadi atpakaļ
vecāks
revīzija
3ae14215d0
1 mainītis faili ar 3 papildinājumiem un 0 dzēšanām
  1. 3 0
      celery/bin/celeryd.py

+ 3 - 0
celery/bin/celeryd.py

@@ -213,9 +213,12 @@ class Worker(object):
 def install_worker_term_handler(worker):
 
     def _stop(signum, frame):
+        worker.stop()
         raise SystemExit()
+
     platform.install_signal_handler("SIGTERM", _stop)
 
+
 def install_worker_restart_handler(worker):
 
     def restart_worker_sig_handler(signum, frame):