dask.distributed allows setting priorities for tasks (in case we have more work than workers, the scheduler knows which ones to execute first), it’s done via passing priority param to client.submit/compute/persist methods explained here. Is it possible to do this with dask_on_ray scheduler?
Task priority is currently not supported by Ray.
are task priorities still not supported?
How would one implement them with existing ray features? maybe with placement_group ?