Florian Jetter

There is one related test failure `distributed/tests/test_client_executor.py::test_retries`

> A plot of your data table: I know this plot looks dramatic but it is not surprising. What we do here, sorting, scales with `W Log(W)` where W is...

If we dropped this fast path we could also demote the workers dictionary to a plain `dict`. It is currently a `sortedcontainers.SortedDict`. I guess this would yield other hard to...

@gjoseph92 what's the status on this?

The heartbeat is running via a pooled RPC, this is running via the batched stream This basically ensures that there is some network traffic on the comm. Sometimes firewalls close...

> Though couldn't this be done by the socket/comm itself? TCP keepalive is already configured and active. Firewalls are smarter ;) > Maybe some firewalls close connections even if there...

+1 for the UX I'm wondering how to best implement this. Maybe task groups should/could/must track min/max priorities of contained tasks? Maybe min/max priorities per `Computation` to not have mixed...

In https://github.com/dask/distributed/pull/5217 (the ticket is a bit cryptic, below example pseudo code) we built a functionality to support "remote printing" that may be useful for some people in here. It...

> It's common to use a synchronization primitive like a semaphore or [CapacityLimiter](https://trio.readthedocs.io/en/stable/reference-core.html#trio.CapacityLimiter) to manage concurrent code's access to a limited resource. Maybe we could have a similar structure around...

This is in, by now