Skip ray tests with newer dask version

Signed-off-by: Julio Faracco <[email protected]>

Author: jcfaracco

tests/pipeline/executors/test_ray.py

@@ -5,11 +5,12 @@
 import subprocess
 import unittest
 
+import dask
 import ray as ray_default
 from mock import Mock, patch
+from packaging.version import Version
 
 from dasf.pipeline.executors import RayPipelineExecutor
-from dasf.pipeline.executors.ray import setup_ray_protocol
 from dasf.utils.funcs import is_gpu_supported
 
 
@@ -30,6 +31,9 @@ def test_setup_ray_protocol_foo(self):
         self.assertTrue('Protocol foo is not supported.' in str(context.exception))
 
 
+@unittest.skipIf(Version(dask.__version__) >= Version('2024.12.1'),
+                 'There is a bug in ray with recent dask releases. '
+                 f'Current is {dask.__version__}')
 class TestRayExecutor(unittest.TestCase):
     def test_ray_executor_from_existing_nodes(self):
         proc = subprocess.run(["ray", "start", "--head", "--port=9191"],