Dask on Yarn
Project description
[![Build Status](https://travis-ci.org/dask/dask-yarn.svg?branch=master)](https://travis-ci.org/dask/dask-yarn)
[![Coverage Status](https://coveralls.io/repos/github/dask/dask-yarn/badge.svg?branch=master)](https://coveralls.io/github/dask/dask-yarn?branch=master)
## Example
```python
>>> from dask_yarn import YARNCluster
>>> cluster = YARNCluster()
>>> from dask.distributed import Client
>>> client = Client(cluster)
>>> cluster.start(2, cpus=1, memory=500)
>>> future = client.submit(lambda x: x + 1, 10)
>>> future.result()
11
```
[![Coverage Status](https://coveralls.io/repos/github/dask/dask-yarn/badge.svg?branch=master)](https://coveralls.io/github/dask/dask-yarn?branch=master)
## Example
```python
>>> from dask_yarn import YARNCluster
>>> cluster = YARNCluster()
>>> from dask.distributed import Client
>>> client = Client(cluster)
>>> cluster.start(2, cpus=1, memory=500)
>>> future = client.submit(lambda x: x + 1, 10)
>>> future.result()
11
```
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
dask-yarn-0.1.1.tar.gz
(18.7 kB
view details)
File details
Details for the file dask-yarn-0.1.1.tar.gz
.
File metadata
- Download URL: dask-yarn-0.1.1.tar.gz
- Upload date:
- Size: 18.7 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 25d8ac38f7244f6b4c3c654c5f1c177f2a2b4fcef39ec8b052dfac9d290ce666 |
|
MD5 | 8a2ad42771ca60b6dde45b411052a90a |
|
BLAKE2b-256 | c7250c15f299f6de1fecc273f3ca8471d162018a0ae3c3af8233e064b7ed1f6d |