2

我正在使用信号在发布之前拦截 celery beat 任务。这工作正常。但是，除此之外，我还想执行一些逻辑，并根据结果可能取消任务。

除了引发异常之外，我找不到从事件处理程序中取消任务的方法，这似乎非常不雅。

背景是我正在使用缓存锁实现分布式任务处理，并且在发布之前对锁执行CAS操作。

有没有办法使用当前的 celery/celerybeat 功能来实现这一点？

谢谢

4

0 回答 0