python - worker : Warm shutdown (MainProcess) after task started

标签 python celery celery-task celeryd

设置:Celery 3.1,broker=RabbitMQ,后端=Redis。

场景: 任务状态为 state=STARTED(正在运行) 我的工作线程正在重新启动。我收到 worker: Warm shutdown (MainProcess) 消息(stdout)。工作线程成功重新启动,但任务卡在 STARTED 状态(通过 Flower 监控)并且没有任何反应。

期望的状态:我希望卡住的任务能够再次运行(或在关闭之前失败) - 并且不会被忽略并永远保持“已启动”状态。

最佳答案

使用CELERY_ACKS_LATE = True解决了问题

关于python - worker : Warm shutdown (MainProcess) after task started,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44043579/

相关文章:

python - 按组划分数据框的列?

python - emacs 24 : How do I get back emacs-23 sexp behavior for python mode?

python - flask celery 任务不起作用

django - 使用 django channel 和 celery 收听 mqtt 主题

python - celery worker 在调用 retry() 后不重试任务

python - Django Celery 持久撤销

python - celery block 不执行任务

python - 查看 multiprocessing.queue?

python celery max-tasks-per-child-setting 默认值

python - 将格式化为列表的字符串转换为实际列表