问题描述
我正在使用 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 (将#修改为@)