如何在使用 celery-beat 完成上一个任务后的 5 分钟内完成 运行 任务？

Question

我有两个任务 - a 和 b。

任务 a 运行 完成上一个任务 a.

后 5 分钟

任务 b 运行 完成上一个任务 b 后 3 分钟。

我该如何实施？我正在使用 python 3.6.8、Django 2.2.6 和 celery 4.3.0?

Answer 1

简短的回答是，您不能使用 celery beat 执行此操作，因为 celery beat 会在任务开始时触发，而不是在任务结束时触发。如果您确实需要在上一个任务结束三分钟后执行此操作，建议您在 a 和 b 的末尾添加对 .apply_async 的调用并开始每个任务一次。