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

Posted 2021-04-04

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

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

例如：

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

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

答案

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