dask.distributed allows using Futures abstraction to constructs DAGs. Is it supported with dask_on_ray scheduler? In general, what are the guidelines to build custom task graph to be executed on Ray? Use dask.delayed?
dask.distributed allows using Futures abstraction to constructs DAGs. Is it supported with dask_on_ray scheduler? In general, what are the guidelines to build custom task graph to be executed on Ray? Use dask.delayed?