#2026

update

models/cloudbrain.go

@@ -1489,6 +1489,11 @@ func UpdateJob(job *Cloudbrain) error {
 	return updateJob(x, job)
 }
 
+func UpdateJobDurationWithDeleted(job *Cloudbrain) error {
+	_, err := x.Exec("update cloudbrain set start_time=?, end_time=?,train_job_duration=?,duration=? where id=?", job.StartTime, job.EndTime, job.TrainJobDuration, job.Duration, job.ID)
+	return err
+}
+
 func updateJob(e Engine, job *Cloudbrain) error {
 	_, err := e.ID(job.ID).AllCols().Update(job)
 	return err

routers/repo/cloudbrain.go

@@ -1572,7 +1572,7 @@ func handleNoDurationTask(cloudBrains []*models.Cloudbrain) {
 				}
 				task.Duration = task.EndTime.AsTime().Unix() - task.StartTime.AsTime().Unix()
 				task.TrainJobDuration = models.ConvertDurationToStr(task.Duration)
-				err = models.UpdateJob(task)
+				err = models.UpdateJobDurationWithDeleted(task)
 				if err != nil {
 					log.Error("UpdateJob(%s) failed:%v", task.JobName, err)
 				}
@@ -1597,7 +1597,7 @@ func handleNoDurationTask(cloudBrains []*models.Cloudbrain) {
 					}
 					task.CorrectCreateUnix()
 					task.ComputeAndSetDuration()
-					err = models.UpdateJob(task)
+					err = models.UpdateJobDurationWithDeleted(task)
 					if err != nil {
 						log.Error("UpdateJob(%s) failed:%v", task.JobName, err)
 						continue
@@ -1618,7 +1618,7 @@ func handleNoDurationTask(cloudBrains []*models.Cloudbrain) {
 						task.EndTime = task.StartTime.Add(result.Duration / 1000)
 					}
 					task.ComputeAndSetDuration()
-					err = models.UpdateJob(task)
+					err = models.UpdateJobDurationWithDeleted(task)
 					if err != nil {
 						log.Error("UpdateJob(%s) failed:%v", task.JobName, err)
 						continue
@@ -1639,7 +1639,7 @@ func updateDefaultDuration(task *models.Cloudbrain) {
 	task.StartTime = task.CreatedUnix
 	task.EndTime = task.UpdatedUnix
 	task.ComputeAndSetDuration()
-	err := models.UpdateJob(task)
+	err := models.UpdateJobDurationWithDeleted(task)
 	if err != nil {
 		log.Error("UpdateJob(%s) failed:%v", task.JobName, err)
 	}