Data Streams with Queues
Data Streams with QueuesΒΆ
This feature is no longer supported. Instead people may want to look at the following options:
Use normal for loops with Client.submit/gather and as_completed
Use asynchronous async/await code and a few coroutines
Try out the Streamz project, which has Dask support