[Python] Dask Distributed - Plugin for Monitoring Memory Usage

I have a distributed Dask cluster that I send a bunch of work to via Dask Distributed Client.

At the end of sending a bunch of work, I'd love to get a report or something that tells me what was the peak memory usage of each worker.

Is this possible via existing diagnostics tools? https://docs.dask.org/en/latest/diagnostics-distributed.html

Thanks! Best,

Continue reading...