Skip to content

Commit 34dfdcf

Browse files
committed
if caching with dask, close and reopen ds to ensure ds points to file
1 parent f9cc9d7 commit 34dfdcf

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

nlmod/cache.py

+4
Original file line numberDiff line numberDiff line change
@@ -171,6 +171,10 @@ def decorator(*args, cachedir=None, cachename=None, **kwargs):
171171
delayed = result.to_netcdf(fname_cache, compute=False)
172172
with ProgressBar():
173173
delayed.compute()
174+
# close and reopen dataset to ensure data is read from
175+
# disk, and not from opendap
176+
result.close()
177+
result = xr.open_dataset(fname_cache, chunks="auto")
174178
else:
175179
result.to_netcdf(fname_cache)
176180

0 commit comments

Comments
 (0)