setting dask workers to 1

CMCC-Foundation · Jul 22, 2024 · 6ae159b · 6ae159b
1 parent 374ebb3
commit 6ae159b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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",