Code

[WIP] Async stream handlers#4474

Code

Closed

ian-r-rose wants to merge 6 commits intodask:masterdask/distributed:masterfrom ian-r-rose:async-stream-handlersian-r-rose/distributed:async-stream-handlersCopy head branch name to clipboard

+77-41

Commits

Commits on Jan 30, 2021

• Type stream handlers as async-only

  

  Ian Rose

  committed
  36e026e

• Asyncify some stream handlers

  

  Ian Rose

  committed
  d682c13

• Fix circular imports -- a lot of work just to get a type annotation.

  

  Ian Rose

  committed
  d80cf8d

• Roll back some API changes, instead introduce asyncify util function.

  

  Ian Rose

  committed
  6b90ee8

• Also ensure that every_cycle is async

  

  Ian Rose

  committed
  bebc06e

• Python 3.6 support

  

  Ian Rose

  committed
  4f1944b