From 0708a7200296197003d6cdb1d9658b5391022b79 Mon Sep 17 00:00:00 2001
From: Gabriele Tramonte <gabriele.tramonte@cmcc.it>
Date: Thu, 25 Jul 2024 15:29:48 +0200
Subject: [PATCH] setting worker number to 4

---
 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 2728e01..5282fd9 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"] = 1
+            dask_cluster_opts["n_workers"] = 4
             dask_cluster_opts["memory_limit"] = "auto"
         self._worker_id = self._db.create_worker(
             status="enabled",