如何在 dask 调度程序插件中获取任务结果

Question

我想通过 dask 中的调度程序插件转发任务的结果。我有一个已注册的类，当我登录转换功能时，它显示：

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),)}

如何才能得到任务的实际结果？

Answer 1

不，调度器不存储任务的结果，它最多知道存储在工作器上的输出的类型和大小。将数据移动到调度程序是一种反模式，请不要试图这样做。如果您想了解有关输出的更多信息，那么计算包含数据的工作人员的那些信息是有意义的。