ray.util.dask.callbacks.RayDaskCallback._ray_postsubmit

RayDaskCallback._ray_postsubmit(task, key, deps, object_ref: ray._raylet.ObjectRef)

提交 Ray 任务后运行。

参数:

• task – 一个 Dask 任务，其中元组的第一项是任务函数，其余元组项是任务参数，这些参数要么是实际的参数值，要么是 deps 字典中的 Dask 键，其对应的值是参数值。

• key – 给定任务的 Dask 图键。

• deps – 此任务的依赖项。

• object_ref – Ray 任务返回值的对象引用。