From ab9a16a743681c4238a1d50b0ff9db2dc8e52da1 Mon Sep 17 00:00:00 2001
From: Mustafa Eyceoz <meyceoz@redhat.com>
Date: Tue, 26 Sep 2023 18:03:09 -0400
Subject: [PATCH] Cluster.up on ray cluster object

---
 src/codeflare_sdk/cluster/cluster.py | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/src/codeflare_sdk/cluster/cluster.py b/src/codeflare_sdk/cluster/cluster.py
index 573eae7f3..93de529de 100644
--- a/src/codeflare_sdk/cluster/cluster.py
+++ b/src/codeflare_sdk/cluster/cluster.py
@@ -179,14 +179,16 @@ def up(self):
                 with open(self.app_wrapper_yaml) as f:
                     yamls = yaml.load_all(f, Loader=yaml.FullLoader)
                     for resource in yamls:
-                        print(resource["kind"])
-                # api_instance.create_namespaced_custom_object(
-                #    group="ray.io",
-                #    version="v1alpha1",
-                #    namespace=namespace,
-                #    plural="rayclusters",
-                #    body=aw,
-                # )
+                        if resource["kind"] == "RayCluster":
+                            api_instance.create_namespaced_custom_object(
+                                group="ray.io",
+                                version="v1alpha1",
+                                namespace=namespace,
+                                plural="rayclusters",
+                                body=resource,
+                            )
+                        else:
+                            print(resource["kind"])
         except Exception as e:  # pragma: no cover
             return _kube_api_error_handling(e)