如何解决如何在celery工作流程中以优美的方式引发错误?
我有一个由链和组组成的celery工作流,其设计方式是,如果特定任务失败,则不会运行其他链接的任务。
workflow = first_task.apply_async(args=[foo],kwargs={},link=chained_task)
我在first_task中有try / except块来处理异常。
如果first_task以错误结尾并进入except之外,则celery认为这是成功执行,并且仍运行chained_task。仅当我在except块中有一个raise
语句时,chained_task才会执行,但在控制台中却留下丑陋的回溯。
有什么方法可以优雅地处理异常并仍然从函数返回错误,从而使celery不执行第二项任务?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。