芹菜错误-工人：热关闭（主进程）

Question

我使用 celery 进行异步 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)