ray.util.dask.callbacks.RayDaskCallback._ray_finish#

RayDaskCallback._ray_finish(result)[源代码]#

在Ray完成执行所有Ray任务并返回最终结果后运行。

参数:

result – Dask 计算的最终结果(输出),在 Dask 集合特定的后计算回调进行任何重新打包之前。