|
|
@@ -1084,7 +1084,7 @@ func HandleTaskWithNoDuration(ctx *context.Context) { |
|
|
|
} |
|
|
|
} |
|
|
|
log.Info("HandleTaskWithNoTrainJobDuration:count=%d", count) |
|
|
|
|
|
|
|
ctx.JSON(200, "success") |
|
|
|
} |
|
|
|
|
|
|
|
func handleNoDurationTask(cloudBrains []*models.Cloudbrain) { |
|
|
@@ -1241,13 +1241,16 @@ func CloudBrainBenchmarkIndex(ctx *context.Context) { |
|
|
|
ciTasks[i].CanDel = cloudbrain.CanDeleteJob(ctx, &task.Cloudbrain) |
|
|
|
ciTasks[i].Cloudbrain.ComputeResource = task.ComputeResource |
|
|
|
if ciTasks[i].TrainJobDuration == "" { |
|
|
|
var duration int64 |
|
|
|
if task.Status == string(models.JobRunning) { |
|
|
|
duration = time.Now().Unix() - int64(task.Cloudbrain.CreatedUnix) |
|
|
|
} else { |
|
|
|
duration = int64(task.Cloudbrain.UpdatedUnix) - int64(task.Cloudbrain.CreatedUnix) |
|
|
|
if ciTasks[i].Duration == 0 { |
|
|
|
var duration int64 |
|
|
|
if task.Status == string(models.JobRunning) { |
|
|
|
duration = time.Now().Unix() - int64(task.Cloudbrain.CreatedUnix) |
|
|
|
} else { |
|
|
|
duration = int64(task.Cloudbrain.UpdatedUnix) - int64(task.Cloudbrain.CreatedUnix) |
|
|
|
} |
|
|
|
ciTasks[i].Duration = duration |
|
|
|
} |
|
|
|
ciTasks[i].TrainJobDuration = models.ConvertDurationToStr(duration) |
|
|
|
ciTasks[i].TrainJobDuration = models.ConvertDurationToStr(ciTasks[i].Duration) |
|
|
|
} |
|
|
|
|
|
|
|
ciTasks[i].BenchmarkTypeName = "" |
|
|
|