File: queues.rst

package info (click to toggle)
dask.distributed 2024.12.1%2Bds-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid, trixie
  • size: 12,588 kB
  • sloc: python: 96,954; javascript: 1,549; sh: 390; makefile: 220
file content (12 lines) | stat: -rw-r--r-- 402 bytes parent folder | download 
1
2
3
4
5
6
7
8
9
10
11
12
 
:orphan:

Data Streams with Queues
========================

This feature is no longer supported.
Instead people may want to look at the following options:

1.  Use normal for loops with Client.submit/gather and as_completed
2.  Use :doc:`asynchronous async/await <asynchronous>` code and a few coroutines
3.  Try out the `Streamz <https://streamz.readthedocs.io>`_ project,
    which has Dask support