diff --git a/sdc/__init__.py b/sdc/__init__.py index 29d1aca..3a26271 100644 --- a/sdc/__init__.py +++ b/sdc/__init__.py @@ -1,6 +1,8 @@ +import dask import xarray as xr from sdc.cluster import start_slurm_cluster +dask.config.set({"array.rechunk.method": "p2p"}) xr.set_options(keep_attrs=True) dask_client, cluster = start_slurm_cluster()