python - 如何覆盖主 celery 中的__call__？

Question

我一直在使用一个抽象任务并覆盖 __call__ 方法来在每个任务执行之前处理一些事情，如下所示:

class CoreTaskHandler(Task):
    abstract = True
    def __call__(self, *args, **kwargs):

但是 __call__ 方法在 worker 上执行，我需要一些重写，每次任务“延迟”时都会在 main 上执行，而不是在 worker 上执行。

有谁知道我将如何继续这样做？

Answer 1

我已经通过覆盖任务中的 apply_sync 方法修复了这个问题:

class CoreTaskHandler(Task):
    abstract = True
    def apply_async(self, *args, **kwargs):

        ........

        return super(CoreTaskHandler, self).apply_async(*args, **kwargs)