Utilities to work with Dask

Functions

class xr_fresh.backends.Cluster(**kwargs)

Wrapper for Dask clients providing cluster management functionality.

Methods

close()	Close the Dask client and cluster resources.
restart()	Restart the Dask client.
start()	Start a Dask cluster for general computation.
start_large_IO_object()	Start a Dask cluster optimized for large I/O-bound computations.
start_large_object()	Start a Dask cluster optimized for large object computations.
start_small_object()	Start a Dask cluster optimized for small object computations.

close()

Close the Dask client and cluster resources.

restart()

Restart the Dask client.

start()

Start a Dask cluster for general computation.

start_large_IO_object()

Start a Dask cluster optimized for large I/O-bound computations.

start_large_object()

Start a Dask cluster optimized for large object computations.

start_small_object()

Start a Dask cluster optimized for small object computations.