data_store_handler_dask#

class predict_backend.persistence.data_store_handler_dask.DaskHandler(client)#

Bases: DataStoreHandler

Convenience Class for persisting datasets/objects to a Dask Cluster

Parameters:

client (Client) – a dask.distributed Client object

download(dname, client)#

Download an object from a dask cluster

Parameters:

  • dname (str) – the dataset name

  • client (Client) – the dask.distributed Client object

Returns:

the persisted object

upload(data, dname)#

Upload an object to a dask cluster

Parameters:

  • data – the data/object to be uploaded

  • dname – the dataset name

Returns: