на несколько вопросов:
1) почему требуется запускать воркеры отдельной службой, а не просто генерировать их из кода тогда, когда появляется таск?
2) как правильно закрывать таски, и нужно ли после этого грохать воркер? на данный момент revoke() так и не завел, по окончанию таски signal.SIGTERM. Опять же, после этого при создании таски появляется воркер с ноым id. это нормально?
3) Почему при запуске службы celery таски выполняются в еще не запущенном приложении? это кажется бредом.
4) как при гроханьи приложения грохать воркеры? только связав и то и то супервизором?
1) потому что сообщение в очередь может слать больше одного просесса как и забирать из очереди могут больше одного воркера, запущенные не обязательно на одной ноде.
Обсуждают сегодня