如何在 dask scheduler 插件中获取任务结果
How to get task result in dask scheduler plugin
我想在 dask 中使用调度程序插件转发任务的结果。我有一个已注册的 class，当我登录转换功能时，它显示：
transition: key=, start=processing, finish=memory, *args=(), **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.', 'startstops': (('compute', 1554303315.1791308, 1554303315.1879702),)}
如何获取任务的实际结果？
不，调度程序不存储任务的结果，它最多知道存储在工作程序上的输出的类型和大小。将数据移动到调度程序将是一种反模式，请不要尝试这样做。如果您想了解有关输出的更多信息，计算包含数据的工作人员的输出是有意义的。
我想在 dask 中使用调度程序插件转发任务的结果。我有一个已注册的 class，当我登录转换功能时，它显示：
transition: key=, start=processing, finish=memory, *args=(), **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.', 'startstops': (('compute', 1554303315.1791308, 1554303315.1879702),)}
如何获取任务的实际结果？
不，调度程序不存储任务的结果，它最多知道存储在工作程序上的输出的类型和大小。将数据移动到调度程序将是一种反模式，请不要尝试这样做。如果您想了解有关输出的更多信息，计算包含数据的工作人员的输出是有意义的。