Skip to content

Commit 8780487

Browse files
Future-Outlier金嘉淇10353800
authored andcommitted
fix: add missing logging for RayJob HTTP mode status transition (ray-project#3936)
* Trigger CI Signed-off-by: Future-Outlier <[email protected]> * move log Signed-off-by: Future-Outlier <[email protected]> * fix: add missing logging for RayJob HTTP mode status transition Signed-off-by: Future-Outlier <[email protected]> --------- Signed-off-by: Future-Outlier <[email protected]>
1 parent deb515a commit 8780487

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

ray-operator/controllers/ray/rayjob_controller.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -212,10 +212,13 @@ func (r *RayJobReconciler) Reconcile(ctx context.Context, request ctrl.Request)
212212
if err := r.createK8sJobIfNeed(ctx, rayJobInstance, rayClusterInstance); err != nil {
213213
return ctrl.Result{RequeueAfter: RayJobDefaultRequeueDuration}, err
214214
}
215+
logger.Info("Both RayCluster and the submitter K8s Job are created. Transition the status from `Initializing` to `Running`.", "SubmissionMode", rayJobInstance.Spec.SubmissionMode, "RayCluster", rayJobInstance.Status.RayClusterName)
216+
}
217+
218+
if rayJobInstance.Spec.SubmissionMode == rayv1.HTTPMode {
219+
logger.Info("RayCluster is created. Transition the status from `Initializing` to `Running`.", "SubmissionMode", rayJobInstance.Spec.SubmissionMode, "RayCluster", rayJobInstance.Status.RayClusterName)
215220
}
216221

217-
logger.Info("Both RayCluster and the submitter K8s Job are created. Transition the status from `Initializing` to `Running`.", "SubmissionMode", rayJobInstance.Spec.SubmissionMode,
218-
"RayCluster", rayJobInstance.Status.RayClusterName)
219222
rayJobInstance.Status.JobDeploymentStatus = rayv1.JobDeploymentStatusRunning
220223
case rayv1.JobDeploymentStatusWaiting:
221224
// Try to get the Ray job id from rayJob.Spec.JobId

0 commit comments

Comments
 (0)