Dask On Ray Cleanup

Hi

At our company we are experimenting with Dask On Ray. We deployed a ray cluster on K8S following the official guide.

In some cases the script that is executing Dask is interupted, but ray tasks are not terminated and they keep running.

The main question is whether there is an option to perform some manual cleanup. I know that ray supports .cancel, .kill however those take object_ref as an argument, and I have no idea how to get those if we are using Dask.

Cheers Marek