Allow setting the path for temporary files when using the default

LocalCluster
ibr-cm · Oct 29, 2024 · 29f11db · 29f11db
1 parent 37caf4b
commit 29f11db
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/run_recipe.py b/run_recipe.py
@@ -563,7 +563,10 @@ def setup_dask(options):
     else:
         dashboard_address = f'localhost:{options.dashboard_port}'
         logi(f'using local cluster with dashboard at {dashboard_address}')
-        client = Client(dashboard_address=dashboard_address, n_workers=options.worker)
+        client = Client(dashboard_address=dashboard_address
+                        , n_workers=options.worker
+                        , local_directory = options.tmpdir
+                        )
         client.register_worker_plugin(plugin)
         return client