如何解决一旦工人被强行关闭，如何在芹菜中重新启动正在运行的任务和挂起的任务？
目前我正在 celery 中运行需要 10 到 15 分钟才能完成的任务，但问题是我如何重新启动当前在 worker 中运行的任务以及当前未运行但等待任务运行而我强行停止 worker 的任务或者万一我的服务器崩溃或停止。现在发生的情况是，如果我再次启动 celery，它不会启动最后一个正在运行的任务或剩余的任务。
解决方法
您可以做的一件事是在任务上启用 acks_late。此外，阅读他们的 FAQ section on acks late and retry.
@app.task(acks_late=True)
def task(*args,**kwargs):
...
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
