Data Streams with Queues

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 asynchronous async/await code and a few coroutines

  3. Try out the Streamz project, which has Dask support