ray.util.dask.callbacks.RayDaskCallback._ray_pretask

RayDaskCallback._ray_pretask(key, object_refs: List[ray._raylet.ObjectRef])

在Ray任务中执行Dask任务之前运行。

此方法在 Ray 提交任务到 Ray 工作线程后执行。如果提供了 _ray_posttask 回调，Ray 会将此任务的返回值传递给它。

参数:

• key – Dask 任务的 Dask 图键。

• object_refs – Ray 任务参数的对象引用。

返回:

Ray 传递给相应 _ray_posttask 回调的值，如果回调已定义。