fix(RHOAIENG-25120): remove kueue as mandatory in RayCluster

Signed-off-by: Pat O'Connor <paoconno@redhat.com>

Author: chipspeak

src/codeflare_sdk/ray/cluster/build_ray_cluster.py

@@ -488,9 +488,11 @@ def add_queue_label(cluster: "codeflare_sdk.ray.cluster.Cluster", labels: dict):
     if lq_name == None:
         return
     elif not local_queue_exists(cluster):
-        raise ValueError(
+        # ValueError removed to pass validation to validating admission policy
+        print(
             "local_queue provided does not exist or is not in this namespace. Please provide the correct local_queue name in Cluster Configuration"
         )
+        return
     labels.update({"kueue.x-k8s.io/queue-name": lq_name})
 
 

src/codeflare_sdk/ray/cluster/cluster.py

@@ -183,6 +183,14 @@ def up(self):
                     f"Ray Cluster: '{self.config.name}' has successfully been created"
                 )
         except Exception as e:  # pragma: no cover
+            if e.status == 422:
+                print(
+                    "WARNING: RayCluster creation rejected by the validating admission policy. Please contact your administrator."
+                )
+            else:
+                print(
+                    "WARNING: Failed to create RayCluster due to unexpected error. Please contact your administrator."
+                )
             return _kube_api_error_handling(e)
 
     # Applies a new cluster with the provided or default spec
@@ -231,6 +239,14 @@ def apply(self, force=False):
         except AttributeError as e:
             raise RuntimeError(f"Failed to initialize DynamicClient: {e}")
         except Exception as e:  # pragma: no cover
+            if e.status == 422:
+                print(
+                    "WARNING: RayCluster creation rejected by the validating admission policy. Please contact your administrator."
+                )
+            else:
+                print(
+                    "WARNING: Failed to create RayCluster due to unexpected error. Please contact your administrator."
+                )
             return _kube_api_error_handling(e)
 
     def _throw_for_no_raycluster(self):