Celery SQS任务失败后将不会执行

Question

我们正在将Celery与SQS代理一起使用，问题是在任务失败后，第一个失败的工作人员将不会消耗另一个]

设置是具有SQS队列的单个工作程序，未配置结果后端。

在调试Kombu SQS传输时，我注意到can_consume方法返回假https://github.com/celery/kombu/blob/master/kombu/transport/virtual/base.py#L191

这意味着传递的失败消息不会被删除

有人知道会导致什么吗？

Answer 1

创建了一个将在celery上发布的错误修正PR == 4.4.0

https://github.com/celery/celery/pull/5843