在辅助角色重新启动时恢复在 Celery 中运行已终止的任务



阅读文档后;我的理解是,您无法在应用程序上下文之外重新运行芹菜任务。最初;我以为是;重新启动工作线程后,终止的任务将恢复运行;然而它没有。我目前正在使用

celery.control.terminate(task_id)

这会终止我的芹菜任务 ID;然后,我尝试运行一个同名的辅助角色,希望我撤销的任务能够恢复并完成;它没有。在做了一些研究之后;我看到可以用相同的参数重新运行任务;我想如果我再次重新运行相同的任务,也许它会恢复,但它没有。如何撤销任务 - 然后能够重新运行它。

我正在使用 .apply_async(( 来启动我的任务。

使用 revoke 而不是 terminate ,例如:

celery_app.control.revoke(task_id)

您也可以参考此解决方案。

取消已经使用芹菜执行的任务?

相关内容

  • 没有找到相关文章

最新更新