Skip to content

Commit

Permalink
Rename _apply_resources into _apply_ray_cluster
Browse files Browse the repository at this point in the history
  • Loading branch information
akram committed Jan 17, 2025
1 parent 225db7b commit c17095a
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions src/codeflare_sdk/ray/cluster/cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -218,7 +218,9 @@ def apply(self, force=False):
body=body,
force_conflicts=force,
)
print(f"AppWrapper: '{name}' configuration has successfully been applied")
print(
f"AppWrapper: '{name}' configuration has successfully been applied"
)
else:
api_version = "ray.io/v1"
api_instance = crds.get(api_version=api_version, kind="RayCluster")
Expand Down Expand Up @@ -568,9 +570,9 @@ def _component_resources_apply(
if self.config.write_to_file:
with open(self.resource_yaml) as f:
ray_cluster = yaml.safe_load(f)
_apply_resources(ray_cluster, namespace, api_instance)
_apply_ray_cluster(ray_cluster, namespace, api_instance)
else:
_apply_resources(self.resource_yaml, namespace, api_instance)
_apply_ray_cluster(self.resource_yaml, namespace, api_instance)

def _component_resources_down(
self, namespace: str, api_instance: client.CustomObjectsApi
Expand Down Expand Up @@ -809,7 +811,7 @@ def _create_resources(yamls, namespace: str, api_instance: client.CustomObjectsA
)


def _apply_resources(
def _apply_ray_cluster(
yamls, namespace: str, api_instance: client.CustomObjectsApi, force=False
):
api_instance.server_side_apply(
Expand Down

0 comments on commit c17095a

Please sign in to comment.