如何在芹菜工作人员执行任务之前访问args和kwargs？

Question

我有一个注册为芹菜任务就像一个Python函数：

import celery 
@celery.task(base=MyTask) 
def my_fn(*args,**kwargs):# dooing stuff 

我要检查args和kwargs是应该执行任务之前仍然有效。 为此，我试图重写Task类execute和run功能，但是作为有代码和本细则规定他们没有得到执行。（至少这是我的理解！）

execute run

a sample use of run，similer到我想要的

这是我如何定义我的MyTask类：

from celery import Task 
class MyTask(Task): 
    def run(self,*args,**kwargs): #does't get called. 
    def execute(self,request,*args,**kwargs): #does't get called. 

我应该把什么样的类或函数放在一起？ 这不可能吗？

提前致谢！

Answer 1

我刚才发现，如果你重写__call__函数它可以正常工作。

代码变为：

from celery import Task 
class MyTask(Task): 
    def __call__(self,*args,**kwargs): 
     #do stuff 
     return super(...)... 

如果有一个更好的解决方案，我想看看，虽然。