From 29f11db8f742d093f2e81fa08f41c27d14d66cd4 Mon Sep 17 00:00:00 2001 From: Christian Hagau Date: Tue, 29 Oct 2024 16:03:37 +0100 Subject: [PATCH] Allow setting the path for temporary files when using the default LocalCluster --- run_recipe.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/run_recipe.py b/run_recipe.py index 4da05bb..7b1d4de 100644 --- 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