ray.util.dask.callbacks.RayDaskCallback._ray_finish#

RayDaskCallback._ray_finish(result)[source]#

Run after Ray finishes executing all Ray tasks and returns the final result.

Parameters:

result – The final result (output) of the Dask computation, before any repackaging is done by Dask collection-specific post-compute callbacks.