暂时禁用 celery 中的分布式处理

Question

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

我可以发誓有一个环境变量可以处理这个，但我似乎无法在文档中找到它？

例如：

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

当调用 add_together 方法时，我不想将它发送给 celery worker。

Answer 1

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