如果连接丢失，如何从 Celery 队列中删除任务？

Question

我正在使用 Celery beat 和工作人员每 30 分钟检索一次最新消息。晚上，当我的电脑睡着时，互联网连接丢失。然后在早上，同一个任务想要运行几次以弥补丢失的尝试。万一断了，这些任务怎么能不堆积呢？

在 Django 的管理部分有一个名为“Expires timedelta with seconds”的选项，但它似乎没有做我需要的事情。有什么建议吗？

Answer 1

您可以将max_retries设置为0或处理任务中的错误。这将防止任何重试。