dask

dask#

Functions

get_client()

get_dask_lock(name)

Get a dask lock with given name.

get_default_chunks()

Get the default chunks:

get_or_create_dask_client([processes, env_vars])

Return default Dask client or create a local cluster and linked client if not existing Returns:

is_chunked(array)

Returns true if the array is still chunked.

is_computed(array)

Returns true if the array is still chunked.

is_dask_installed()

raise_if_dask_computes([max_computes, ...])

Module Attributes

DEFAULT_CHUNKS

Default chunks used in Sertit library (if dask is installed)

SERTIT_DEFAULT_CHUNKS

Environment variable to override default chunks.