项目作者: dask

项目描述 :
Deprecated, please use https://github.com/jcrist/skein or https://github.com/dask/dask-yarn instead
高级语言: Python
项目地址: git://github.com/dask/old-dask-yarn.git
创建时间: 2016-12-29T02:46:42Z
项目社区:https://github.com/dask/old-dask-yarn

开源协议:

下载


Please find this functionality in https://github.com/dask/knit/blob/master/knit/dask_yarn.py

Build Status
Coverage Status

Example

  1. >>> from dask_yarn import YARNCluster
  2. >>> cluster = YARNCluster()
  3. >>> from dask.distributed import Client
  4. >>> client = Client(cluster)
  5. >>> cluster.start(2, cpus=1, memory=500)
  6. >>> future = client.submit(lambda x: x + 1, 10)
  7. >>> future.result()
  8. 11