Asyncio progress reporting
Open
- 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
Assessment
This issue has not been assessed yet.