ray.util.dask.callbacks.RayDaskCallback._ray_posttask#

RayDaskCallback._ray_posttask(key, result, pre_state)[源代码]#

在Ray任务中执行Dask任务后运行。

此方法在 Ray 工作进程中执行。此回调接收 _ray_pretask 回调的返回值(如果提供了的话)。

参数:
  • key – Dask 任务的 Dask 图键。

  • result – 任务结果值。

  • pre_state – 如果定义了相应的 _ray_pretask 回调,则返回该回调的返回值。