Профилирование распределенной коммуникации между работниками и клиентом в Dask

Я хотел бы спросить, есть ли способ измерить время общения между сотрудниками и клиентом. В настоящее время я использую плагин Scheduler для получения состояний задач и получения оттуда сведений о выполнении. Я не вижу никаких задач передачи, когда результаты возвращаются клиенту. Справедливо ли предположить, что он равен времени между последней завершенной задачей и возвратом вычислений?

Как мы можем также узнать объем данных, перемещенных от каждой задачи к клиенту?

Общий пример:

{task: id, "Bytes Returned": 128, "Time":50ms}

Спасибо!


person neiron21    schedule 14.11.2017    source источник
comment
Не могли бы вы показать пример использования плагина Scheduler?   -  person Sanchit    schedule 04.07.2019
comment
Вы можете найти его здесь   -  person neiron21    schedule 20.08.2019


Ответы (1)


В настоящее время не существует механизма, который измеряет связь с клиентом и от него.

person MRocklin    schedule 29.11.2017