Как корректно перезапустить celery workers?

При выпуске новой сборки для обновления кода в worker'ах, как мне корректно перезапустить celery workers?

Редактировать: То, что я собираюсь сделать, это что-то вроде этого.

  • Рабочий процесс запущен, возможно, он загружает 100-мегабайтный файл на S3
  • Приходит новая сборка
  • В код рабочего процесса внесены изменения
  • Сценарий сборки запускает сигнал рабочему(s)
  • Запускает новый рабочий процесс с новый код
  • Worker(s), который получил сигнал после завершения существующего выхода из задания.
40
задан Quintin Par 19 March 2012 в 14:48
поделиться