Goal I would like to parallelize a loop with dask that uses a library function inside the loop. This function, mhw.detect(), calculates some statistics on a sli
Example code: import dask.bag as db from dask import delayed from dask.distributed import Client, LocalCluster N = 10**6 def load(): return delayed(range(N
I have an xarray.Dataset with two 1D variables sun_azimuth and sun_elevation with multiple timesteps along the time dimension: import xarray as xr import numpy