So that we don't have to manually edit the source to change xarray/dask resources, we should add a section to the config.yml that maps to the keyword arguments of the cluster and open_mfdataset stages of the code.
This will allow for faster development, as well as user-specified resources as needed.
For example:
cluster:
n_workers: 1
processes: true
open_mfdataset:
parallel: true
chunks:
time: 24
latitude: -1
longitude: -1
Then:
# ...assume config is loaded as per usual
cluster = LocalCluster(**config.get("cluster"))
dataset = xr.open_mfdataset(file_list, **config.get("open_mfdataset"))
See:
So that we don't have to manually edit the source to change xarray/dask resources, we should add a section to the config.yml that maps to the keyword arguments of the cluster and
open_mfdatasetstages of the code.This will allow for faster development, as well as user-specified resources as needed.
For example:
Then:
See: