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

Question

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

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

例如：

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

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

Answer 1

我想你的意思是可以通过task_always_eager设置打开的渴望模式。启用此功能后，所有任务都将在本地执行，而不是发送到队列。