python - 如果任务没有运行超过 10 分钟，如何重新安排任务？

Question

我有任务:recursive_task，它将安排相同的任务在 5 秒后执行，但如果由于某种原因该任务崩溃，则需要再次重新运行。我几乎捕捉到了所有场景，但你永远不知道 future 会发生什么。

我首先做了一个重复的任务:manage_tasks，它检查recursive_task的状态，并检查它是否长时间没有运行以及是否成功完成，但这感觉不对。那么你会如何解决这个问题呢？

Answer 1

尝试 acks_late 设置 CELERY_ACKS_LATE ，任务执行后会确认任务消息。这样您就可以更轻松地重新运行任务。