ray.util.dask.callbacks.RayDaskCallback._ray_finish

RayDaskCallback._ray_finish(result)

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.