Я использую сельдерей для обучения модели ML асинхронно. Если я даю запрос на выполнение задачи 2-3 раза (не уверен), получаю сообщение как рабочий: горячее завершение работы (основной процесс) и после этого не могу отправить запрос в течение нескольких часов. После иногда это автоматически начинается.
Мой код для сельдерея вот так.
celery = Celery(app.name, broker='redis://localhost:6379/0')
@celery.task
Я тоже пробовал это:
@celery.task(CELERY_ACKS_LATE = True)
Я пробовал это для установки параллелизма = 1
celery worker -A classify_model.celery --loglevel=info -Q random-tasks --concurrency=1
Я получаю ошибку как
worker:warm shutdown(Main Process)