From 6ae159bf35f6ed5fc63b8c750dc4013cc7641bec Mon Sep 17 00:00:00 2001
From: Gabriele Tramonte <gabriele.tramonte@cmcc.it>
Date: Mon, 22 Jul 2024 12:21:41 +0200
Subject: [PATCH] setting dask workers to 1

---
 executor/app/main.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/executor/app/main.py b/executor/app/main.py
index ecefd8e..bd0ed61 100644
--- a/executor/app/main.py
+++ b/executor/app/main.py
@@ -249,7 +249,7 @@ def create_dask_cluster(self, dask_cluster_opts: dict = None):
             dask_cluster_opts["processes"] = True
             port = int(os.getenv("DASK_DASHBOARD_PORT", 8787))
             dask_cluster_opts["dashboard_address"] = f":{port}"
-            dask_cluster_opts["n_workers"] = 4
+            dask_cluster_opts["n_workers"] = 1
             dask_cluster_opts["memory_limit"] = "auto"
         self._worker_id = self._db.create_worker(
             status="enabled",