Category "dask-delayed"

dask bag embarrassingly parallel but with a generator

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

Applying a function to each timestep in an xarray.Dataset, and return lazy Dask array outputs

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