ray.util.dask.callbacks.RayDaskCallback._ray_pretask#

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

Run before executing a Dask task within a Ray task.

This method executes after Ray submits the task within a Ray worker. The return value of this method is passed to the _ray_posttask callback, if provided.

Parameters:

  • key – The Dask graph key for the Dask task.

  • object_refs – The object references for the arguments of the Ray task.