Skip to content

Commit 0357917

Browse files
authored
🔧 remove backticks in kubectl log (#99)
🔧 remove backticks in kubectl log --- this makes it easier for users to copy the command
1 parent 2a9e979 commit 0357917

1 file changed

Lines changed: 3 additions & 8 deletions

File tree

dagster_ray/kuberay/resources.py

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -129,8 +129,6 @@ def yield_for_execution(self, context: InitResourceContext) -> Generator[Self, N
129129

130130
self._cluster_name = self._get_ray_cluster_step_name(context)
131131

132-
# self._host = f"{self.cluster_name}-head-svc.{self.namespace}.svc.cluster.local"
133-
134132
try:
135133
# just a safety measure, no need to recreate the cluster for step retries or smth
136134
if not self.client.client.list(
@@ -157,13 +155,10 @@ def yield_for_execution(self, context: InitResourceContext) -> Generator[Self, N
157155
"head"
158156
]["serviceIP"]
159157

160-
context.log.info("RayCluster is ready! Connection command:")
161-
162-
context.log.info(
163-
f"`kubectl -n {self.namespace} port-forward svc/{self.cluster_name}-head-svc 8265:8265 6379:6379 10001:10001`"
164-
)
158+
msg = f"RayCluster {self.namespace}/{self.cluster_name} is ready! Connection command:\n"
159+
msg += f"kubectl -n {self.namespace} port-forward svc/{self.cluster_name}-head-svc 8265:8265 6379:6379 10001:10001"
165160

166-
context.log.debug(f"Ray host: {self.host}")
161+
context.log.info(msg)
167162

168163
if not self.skip_init:
169164
self.init_ray(context)

0 commit comments

Comments
 (0)