暂时禁用芹菜中的分布式处理

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了暂时禁用芹菜中的分布式处理相关的知识,希望对你有一定的参考价值。

我想暂时将芹菜task的分布式行为转换为串行行为。也就是说,我希望该过程运行任务代码,就像task装饰器不存在一样。我需要这个用于调试目的。

我可以发誓有一个env var处理这个但我似乎无法在文档中找到它?

例如:

@celery.task()
def add_together(a, b):
    return a + b

当调用add_together方法时,我不希望它被发送给芹菜工人。

答案

我认为你的意思是渴望模式,可以通过task_always_eager设置打开。打开它后,所有任务将在本地执行,而不是发送到队列。

以上是关于暂时禁用芹菜中的分布式处理的主要内容,如果未能解决你的问题,请参考以下文章