mars.contrib.dask.mars_scheduler#
- mars.contrib.dask.mars_scheduler(dsk: dict, keys: List[List[str]])[源代码]#
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 (List[List[str]]) – 2d-list of Dask graph keys whose values we wish to compute and return.
- 返回
Computed values corresponding to the provided keys.
- 返回类型
Object