2024-04-20 10:38:49 发布
网友
我一直在使用一个抽象任务并重写__call__方法来处理每个任务执行之前的一些事情:
__call__
class CoreTaskHandler(Task): abstract = True def __call__(self, *args, **kwargs):
但是在worker上执行__call__方法,我需要一些重写,它将在main上执行,而不是每次任务“延迟”时在worker上执行。在
有人知道我该怎么做吗?在
我已通过重写任务中的apply\u sync方法修复了此问题:
class CoreTaskHandler(Task): abstract = True def apply_async(self, *args, **kwargs): ........ return super(CoreTaskHandler, self).apply_async(*args, **kwargs)
我已通过重写任务中的apply\u sync方法修复了此问题:
相关问题 更多 >
编程相关推荐