From d766c01d2db277b3656b6f7eed2f7ae6f8688a2d Mon Sep 17 00:00:00 2001
From: Peter Rowlands <peter@pmrowla.com>
Date: Tue, 24 May 2022 18:31:53 +0900
Subject: [PATCH] exp: enable late_ack to disable celery prefetch

---
 dvc/repo/experiments/queue/local.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dvc/repo/experiments/queue/local.py b/dvc/repo/experiments/queue/local.py
index 99d82016f..e0b46aad6 100644
--- a/dvc/repo/experiments/queue/local.py
+++ b/dvc/repo/experiments/queue/local.py
@@ -81,6 +81,7 @@ class LocalCeleryQueue(BaseStashQueue):
                 "dvc_task.proc.tasks",
             ],
         )
+        app.conf.update({"task_acks_late": True})
         return app
 
     @cached_property