Serialize downloads on a worker

bopen · Apr 9, 2024 · b7dfb20 · b7dfb20
1 parent 23ad8ee
commit b7dfb20
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/xarray_ecmwf/engine_ecmwf.py b/xarray_ecmwf/engine_ecmwf.py
@@ -91,7 +91,7 @@ def retrieve(
         if not os.path.isdir(self.cache_folder):
             os.makedirs(self.cache_folder, exist_ok=True)
 
-        with xr.backends.locks.get_write_lock(f"{HOSTNAME}/{filename}"):  # type: ignore
+        with xr.backends.locks.get_write_lock(f"{HOSTNAME}"):  # type: ignore
             if not os.path.exists(path):
                 robust_save_to_file(self.request_client.download, (result,), path)
         ds = self.open_dataset(path)