test: revert e2e workflow

Author: kryanbeane

.github/workflows/e2e_tests.yaml

@@ -5,13 +5,13 @@ on:
   pull_request:
     branches:
       - main
-      - 'release-*'
+      - "release-*"
       - ray-jobs-feature
     paths-ignore:
-      - 'docs/**'
-      - '**.adoc'
-      - '**.md'
-      - 'LICENSE'
+      - "docs/**"
+      - "**.adoc"
+      - "**.md"
+      - "LICENSE"
 
 concurrency:
   group: ${{ github.head_ref }}-${{ github.workflow }}
@@ -33,9 +33,9 @@ jobs:
       - name: Checkout common repo code
         uses: actions/checkout@v4
         with:
-          repository: 'project-codeflare/codeflare-common'
-          ref: 'main'
-          path: 'common'
+          repository: "project-codeflare/codeflare-common"
+          ref: "main"
+          path: "common"
 
       - name: Checkout CodeFlare operator repository
         uses: actions/checkout@v4
@@ -46,7 +46,7 @@ jobs:
       - name: Set Go
         uses: actions/setup-go@v5
         with:
-          go-version-file: './codeflare-operator/go.mod'
+          go-version-file: "./codeflare-operator/go.mod"
           cache-dependency-path: "./codeflare-operator/go.sum"
 
       - name: Set up gotestfmt
@@ -57,8 +57,8 @@ jobs:
       - name: Set up specific Python version
         uses: actions/setup-python@v5
         with:
-          python-version: '3.11'
-          cache: 'pip' # caching pip dependencies
+          python-version: "3.11"
+          cache: "pip" # caching pip dependencies
 
       - name: Setup NVidia GPU environment for KinD
         uses: ./common/github-actions/nvidia-gpu-setup
@@ -146,7 +146,7 @@ jobs:
         if: always() && steps.deploy.outcome == 'success'
         run: |
           echo "Printing KubeRay operator logs"
-          kubectl logs -n ray-system --tail -1 -l app.kubernetes.io/name=kuberay | tee ${CODEFLARE_TEST_OUTPUT_DIR}/kuberay.log
+          kubectl logs -n default --tail -1 -l app.kubernetes.io/name=kuberay | tee ${CODEFLARE_TEST_OUTPUT_DIR}/kuberay.log
 
       - name: Export all KinD pod logs
         uses: ./common/github-actions/kind-export-logs

src/codeflare_sdk/ray/cluster/cluster.py

@@ -391,6 +391,7 @@ def is_dashboard_ready(self) -> bool:
             bool:
                 True if the dashboard is ready, False otherwise.
         """
+
         dashboard_uri = self.cluster_dashboard_uri()
         if dashboard_uri is None:
             return False
@@ -516,6 +517,8 @@ def cluster_dashboard_uri(self) -> str:
                 ):
                     protocol = "https" if route["spec"].get("tls") else "http"
                     return f"{protocol}://{route['spec']['host']}"
+            # No route found for this cluster
+            return "Dashboard not available yet, have you run cluster.up()?"
         else:
             try:
                 api_instance = client.NetworkingV1Api(get_api_client())
@@ -534,25 +537,9 @@ def cluster_dashboard_uri(self) -> str:
                         protocol = "http"
                     elif "route.openshift.io/termination" in annotations:
                         protocol = "https"
-                return f"{protocol}://{ingress.spec.rules[0].host}"
+                    return f"{protocol}://{ingress.spec.rules[0].host}"
 
-        # For local/test environments without ingress controller (e.g., KIND)
-        # Try to find the Ray head service
-        try:
-            api_instance = client.CoreV1Api(get_api_client())
-            services = api_instance.list_namespaced_service(
-                self.config.namespace,
-                label_selector=f"ray.io/cluster={self.config.name},ray.io/node-type=head",
-            )
-            for service in services.items:
-                if service.metadata.name == f"{self.config.name}-head-svc":
-                    # For ClusterIP services in local environments, return a placeholder
-                    # The actual connection would need port-forwarding or NodePort
-                    return f"http://{service.metadata.name}.{self.config.namespace}.svc.cluster.local:8265"
-        except Exception:  # pragma: no cover
-            pass
-
-        return None
+        return "Dashboard not available yet, have you run cluster.up()?"
 
     def list_jobs(self) -> List:
         """
@@ -813,11 +800,6 @@ def remove_autogenerated_fields(resource):
             else:
                 remove_autogenerated_fields(resource[key])
 
-        # After cleaning, remove empty metadata sections
-        if "metadata" in resource and isinstance(resource["metadata"], dict):
-            if len(resource["metadata"]) == 0:
-                del resource["metadata"]
-
     elif isinstance(resource, list):
         for item in resource:
             remove_autogenerated_fields(item)

src/codeflare_sdk/ray/cluster/test_cluster.py

@@ -322,8 +322,10 @@ def test_cluster_uris(mocker):
     mocker.patch(
         "kubernetes.client.NetworkingV1Api.list_namespaced_ingress",
     )
-    # When no ingress/route/service is found, the method should return None
-    assert cluster.cluster_dashboard_uri() is None
+    assert (
+        cluster.cluster_dashboard_uri()
+        == "Dashboard not available yet, have you run cluster.up()?"
+    )
 
     mocker.patch(
         "codeflare_sdk.ray.cluster.cluster._is_openshift_cluster", return_value=True

tests/e2e/support.py

@@ -383,9 +383,6 @@ def create_kueue_resources(
 
 
 def delete_kueue_resources(self):
-    # Delete if given cluster-queue exists
-    if not hasattr(self, "cluster_queues"):
-        return
     for cq in self.cluster_queues:
         try:
             self.custom_api.delete_cluster_custom_object(