dask / dask/distributed

Asyncio progress reporting

Open
#1,024 8 comments 0 reactions 0 assignees View on GitHub
Dominant language
Python
Stars
1.7k
Forks
778
Avg merge
2h 50m
Merged PRs (30d)
3

Description

I'd like to send progress reports through a websocket.
Currently I can't find a nice way to achieve that.

Could we implement an interface similar to the following?

```python
from distributed.diagnostics import Progress

future = client.compute(...)

async for processed_key, completeness in Progress(future):
logging.info(processed_key)
websocket.send(completeness)
```

Somewhat related to https://github.com/dask/distributed/issues/1020

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.