RHOAIENG-5344 - E2E test for Ray local interactive

tests/e2e/local_interactive_sdk_kind_test.py

@@ -0,0 +1,71 @@
+from codeflare_sdk import Cluster, ClusterConfiguration
+
+import pytest
+import ray
+import math
+
+from support import *
+
+
+@pytest.mark.kind
+class TestRayLocalInteractiveOauth:
+    def setup_method(self):
+        initialize_kubernetes_client(self)
+
+    def teardown_method(self):
+        delete_namespace(self)
+
+    def test_local_interactives(self):
+        self.setup_method()
+        create_namespace(self)
+        create_kueue_resources(self)
+        self.run_local_interactives()
+
+    def run_local_interactives(self):
+        ray_image = get_ray_image()
+
+        cluster_name = "test-ray-cluster"
+
+        cluster = Cluster(
+            ClusterConfiguration(
+                namespace=self.namespace,
+                name=cluster_name,
+                num_workers=1,
+                min_cpus=1,
+                max_cpus=1,
+                min_memory=4,
+                max_memory=4,
+                num_gpus=0,
+                image=ray_image,
+                verify_tls=False,
+            )
+        )
+        cluster.up()
+        cluster.wait_ready()
+
+        ray.shutdown()
+        ray.init(address=cluster.local_client_url(), logging_level="DEBUG")
+
+        @ray.remote
+        def heavy_calculation_part(num_iterations):
+            result = 0.0
+            for i in range(num_iterations):
+                for j in range(num_iterations):
+                    for k in range(num_iterations):
+                        result += math.sin(i) * math.cos(j) * math.tan(k)
+            return result
+
+        @ray.remote
+        def heavy_calculation(num_iterations):
+            results = ray.get(
+                [heavy_calculation_part.remote(num_iterations // 30) for _ in range(30)]
+            )
+            return sum(results)
+
+        ref = heavy_calculation.remote(3000)
+        result = ray.get(ref)
+        assert result == 1789.4644387076714
+        ray.cancel(ref)
+        ray.shutdown()
+
+        cluster.down()

tests/e2e/local_interactive_sdk_oauth_test.py

@@ -0,0 +1,86 @@
+from codeflare_sdk import (
+    Cluster,
+    ClusterConfiguration,
+    TokenAuthentication,
+    generate_cert,
+)
+
+import math
+import pytest
+import ray
+
+from support import *
+
+
+@pytest.mark.openshift
+class TestRayLocalInteractiveOauth:
+    def setup_method(self):
+        initialize_kubernetes_client(self)
+
+    def teardown_method(self):
+        delete_namespace(self)
+
+    def test_local_interactives(self):
+        self.setup_method()
+        create_namespace(self)
+        create_kueue_resources(self)
+        self.run_local_interactives()
+
+    def run_local_interactives(self):
+        ray_image = get_ray_image()
+
+        auth = TokenAuthentication(
+            token=run_oc_command(["whoami", "--show-token=true"]),
+            server=run_oc_command(["whoami", "--show-server=true"]),
+            skip_tls=True,
+        )
+        auth.login()
+
+        cluster_name = "test-ray-cluster"
+
+        cluster = Cluster(
+            ClusterConfiguration(
+                namespace=self.namespace,
+                name=cluster_name,
+                num_workers=1,
+                min_cpus=1,
+                max_cpus=1,
+                min_memory=4,
+                max_memory=4,
+                num_gpus=0,
+                image=ray_image,
+                verify_tls=False,
+            )
+        )
+        cluster.up()
+        cluster.wait_ready()
+
+        generate_cert.generate_tls_cert(cluster_name, self.namespace)
+        generate_cert.export_env(cluster_name, self.namespace)
+
+        ray.shutdown()
+        ray.init(address=cluster.local_client_url(), logging_level="DEBUG")
+
+        @ray.remote
+        def heavy_calculation_part(num_iterations):
+            result = 0.0
+            for i in range(num_iterations):
+                for j in range(num_iterations):
+                    for k in range(num_iterations):
+                        result += math.sin(i) * math.cos(j) * math.tan(k)
+            return result
+
+        @ray.remote
+        def heavy_calculation(num_iterations):
+            results = ray.get(
+                [heavy_calculation_part.remote(num_iterations // 30) for _ in range(30)]
+            )
+            return sum(results)
+
+        ref = heavy_calculation.remote(3000)
+        result = ray.get(ref)
+        assert result == 1789.4644387076714
+        ray.cancel(ref)
+        ray.shutdown()
+
+        cluster.down()