| @@ -309,7 +309,7 @@ func queryTaskStatusFromModelSafetyTestServer(job *models.Cloudbrain) { | |||||
| log.Info("The task is running....") | log.Info("The task is running....") | ||||
| } else { | } else { | ||||
| job.EndTime = timeutil.TimeStampNow() | job.EndTime = timeutil.TimeStampNow() | ||||
| job.Duration = (int64(job.EndTime) - int64(job.StartTime)) / 1000 | |||||
| job.Duration = (job.EndTime.AsTime().Unix() - job.StartTime.AsTime().Unix()) / 1000 | |||||
| job.TrainJobDuration = models.ConvertDurationToStr(job.Duration) | job.TrainJobDuration = models.ConvertDurationToStr(job.Duration) | ||||
| if result.Data.Code == 0 { | if result.Data.Code == 0 { | ||||
| job.ResultJson = result.Data.StandardJson | job.ResultJson = result.Data.StandardJson | ||||
| @@ -445,7 +445,7 @@ func updateJobFailed(job *models.Cloudbrain, msg string) { | |||||
| job.Status = string(models.ModelArtsTrainJobFailed) | job.Status = string(models.ModelArtsTrainJobFailed) | ||||
| job.ResultJson = msg | job.ResultJson = msg | ||||
| job.EndTime = timeutil.TimeStampNow() | job.EndTime = timeutil.TimeStampNow() | ||||
| job.Duration = (int64(job.EndTime) - int64(job.StartTime)) / 1000 | |||||
| job.Duration = (job.EndTime.AsTime().Unix() - job.StartTime.AsTime().Unix()) / 1000 | |||||
| job.TrainJobDuration = models.ConvertDurationToStr(job.Duration) | job.TrainJobDuration = models.ConvertDurationToStr(job.Duration) | ||||
| err := models.UpdateJob(job) | err := models.UpdateJob(job) | ||||
| if err != nil { | if err != nil { | ||||