#1654

fix bug

routers/repo/cloudbrain.go

@@ -1094,17 +1094,15 @@ func handleNoDurationTask(cloudBrains []*models.Cloudbrain) {
 			result, err := cloudbrain.GetJob(task.JobID)
 			if err != nil {
 				log.Error("GetJob(%s) failed:%v", task.JobName, err)
-				task.StartTime = task.CreatedUnix
-				task.EndTime = task.UpdatedUnix
-				task.ComputeAndSetDuration()
-				err = models.UpdateJob(task)
-				if err != nil {
-					log.Error("UpdateJob(%s) failed:%v", task.JobName, err)
-				}
+				updateDefaultDuration(task)
 				continue
 			}
 
 			if result != nil {
+				if result.Msg != "success" {
+					updateDefaultDuration(task)
+					continue
+				}
 				jobRes, _ := models.ConvertToJobResultPayload(result.Payload)
 				taskRoles := jobRes.TaskRoles
 				taskRes, _ := models.ConvertToTaskPod(taskRoles[cloudbrain.SubTaskName].(map[string]interface{}))
@@ -1196,6 +1194,17 @@ func handleNoDurationTask(cloudBrains []*models.Cloudbrain) {
 	}
 }
 
+func updateDefaultDuration(task *models.Cloudbrain) {
+	log.Info("updateDefaultDuration: taskId=%d", task.ID)
+	task.StartTime = task.CreatedUnix
+	task.EndTime = task.UpdatedUnix
+	task.ComputeAndSetDuration()
+	err := models.UpdateJob(task)
+	if err != nil {
+		log.Error("UpdateJob(%s) failed:%v", task.JobName, err)
+	}
+}
+
 func CloudBrainBenchmarkIndex(ctx *context.Context) {
 	MustEnableCloudbrain(ctx)
 	repo := ctx.Repo.Repository