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

Question

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

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

例如:

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

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

Answer 1

我认为你的意思是可以使用 task_always_eager 打开的急切模式环境。开启后，所有任务都将在本地执行，而不是发送到队列。