A Dask-Mars scheduler
This scheduler is intended to be compatible with existing dask user interface, no callbacks are implemented.
dsk (Dict) – Dask graph, represented as a task DAG dictionary.
keys (Union[List[List[str]], List[str]]) – 1d or 2d list of Dask graph keys whose values we wish to compute and return.
Computed values corresponding to the provided keys with same dimension.
Object
previous
Dask on Mars
next
mars.contrib.dask.convert_dask_collection