@@ -859,7 +859,6 @@ func initRayJobStatusIfNeed(ctx context.Context, rayJob *rayv1.RayJob) error {
859
859
if rayJob .Status .JobStatus == "" {
860
860
rayJob .Status .JobStatus = rayv1 .JobStatusNew
861
861
}
862
-
863
862
rayJob .Status .JobDeploymentStatus = rayv1 .JobDeploymentStatusInitializing
864
863
rayJob .Status .StartTime = & metav1.Time {Time : time .Now ()}
865
864
return nil
@@ -954,7 +953,6 @@ func (r *RayJobReconciler) constructRayClusterForRayJob(rayJobInstance *rayv1.Ra
954
953
955
954
func (r * RayJobReconciler ) getNextAndPreviousScheduleDistance (ctx context.Context , currentTime time.Time , rayJobInstance * rayv1.RayJob ) (time.Duration , time.Duration , error ) {
956
955
logger := ctrl .LoggerFrom (ctx )
957
- logger .Info ("Calculating next schedule for the RayJob" )
958
956
formatedCron := utils .FormatSchedule (rayJobInstance , r .Recorder )
959
957
cronSchedule , err := cron .ParseStandard (formatedCron )
960
958
if err != nil {
@@ -963,7 +961,6 @@ func (r *RayJobReconciler) getNextAndPreviousScheduleDistance(ctx context.Contex
963
961
r .Recorder .Eventf (rayJobInstance , corev1 .EventTypeWarning , "UnparseableSchedule" , "unparseable schedule: %q : %s" , rayJobInstance .Spec .Schedule , err )
964
962
return 0 , 0 , fmt .Errorf ("the cron schedule provided is unparseable: %w" , err )
965
963
}
966
- logger .Info ("Successfully parsed cron schedule" , "CronSchedule" , formatedCron )
967
964
968
965
t1 := utils .NextScheduleTimeDuration (logger , rayJobInstance , currentTime , cronSchedule )
969
966
t2 := utils .LastScheduleTimeDuration (logger , rayJobInstance , currentTime , cronSchedule )
0 commit comments