|
|
|
@@ -1081,6 +1081,13 @@ func HandleTaskWithNoDuration(ctx *context.Context) { |
|
|
|
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) |
|
|
|
} |
|
|
|
continue |
|
|
|
} |
|
|
|
|
|
|
|
@@ -1121,6 +1128,13 @@ func HandleTaskWithNoDuration(ctx *context.Context) { |
|
|
|
result, err := modelarts.GetNotebook2(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) |
|
|
|
} |
|
|
|
continue |
|
|
|
} |
|
|
|
|
|
|
|
|