如何解决如果失败,如何等待 celery 任务chains、link_error 和 get_leaf?
我正在使用 falcon 和 celery 编写后端,并且我使用具有相同逻辑的多个端点和各种对象,其中一个端点应该以相同的流程同步运行。
当可怕的事情发生并触发另一个任务优雅地完成时,流程是由几个带有 link_error 的链构建的。
如果链运行成功,下面的解决方案工作正常。
def on_post(self,req,res):
result = run_asynchronously()
leaf = result.get_leaf()
res.media = leaf.build_response()
如果任务运行时发生异常,则触发link_error,执行其逻辑并触发清理以正常完成。
error_handler(链中的link_error),get_leaf
返回异常而不是等待新触发的任务(link_error)结果。
关于如何让它工作的任何建议?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。