_ray_posttask#

RayDaskCallback._ray_posttask(key: Any, result: Any, pre_state: Any)[source]#

Run after executing a Dask task within a Ray task.

This method executes within a Ray worker. This callback receives the return value of the _ray_pretask callback, if provided.

Parameters:

  • key (Any) – The Dask graph key for the Dask task.

  • result (Any) – The task result value.

  • pre_state (Any) – The return value of the corresponding _ray_pretask callback, if said callback is defined.