ray.util.dask.callbacks.RayDaskCallback._ray_postsubmit_all

RayDaskCallback._ray_postsubmit_all(object_refs: List[ray._raylet.ObjectRef], dsk)

在Ray提交所有任务后运行。

参数:

• object_refs – 任务图的输出（叶子）Ray 任务的对象引用。

• dsk – Dask 图。