python - 如何在 celery 中实现 on_revoked 事件

Question

我有一个经常重试的任务，如果它在重试状态下被撤销，我想要一种方法来清理它。似乎有几个选项可以做到这一点，我想知道最可接受/最干净的会是什么。到目前为止，这是我的想法：

1. 拾取已撤销任务并调用 on_revoked 的自定义相机
2. 知道在被撤销的任务上处理 on_revoked 的自定义事件消费者
3. 使用 AbortableTasks 并使用 abort 而不是 revoke（我真的很想避免这种情况）

我还有其他选择吗？

Answer 1

用作AbortableTask模板并根据您的规范创建一个RevokableTask类。