Как получить результат задачи в плагине dask scheduler

Question

Я хочу переслать результат задачи с помощью плагина планировщика в dask.У меня есть класс, который зарегистрирован, и когда я вхожу в функцию перехода, он показывает:

переход: ключ =, начало = обработка, финиш = память, * аргументы = (), ** kwargs ={'worker': 'tcp: //127.0.0.1: 51514', 'status': 'OK', 'nbytes': 95196, 'thread': 123145458712576, 'type': b '\ x80 \ x04 \ x95 \x16 \ x00 \ x00 \ x00 \ x00 \ x00 \ x00 \ x00 \ x8c \ x08builtins \ x94 \ x8c \ x05tuple \ x94 \ x93 \ x94. ',' Starttops ': ((' compute ', 1554303315.1791308, 1554303315.1879702),)}

Как получить фактический результат задания?

Answer 1

Нет, планировщик не хранит результаты задач, самое большее, он знает тип и размер выходных данных, которые хранятся на рабочих.Это было бы препятствием для перемещения данных в планировщик, пожалуйста, не поддавайтесь искушению сделать это.Если вы хотите получить больше информации о результатах, имело бы смысл рассчитать их для работников, содержащих данные.