Cluster.up on ray cluster object

project-codeflare · Sep 26, 2023 · ab9a16a · ab9a16a
1 parent dc540c1
commit ab9a16a
Showing 1 changed file with 10 additions and 8 deletions.
diff --git 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)