|
|
@@ -381,7 +381,7 @@ func cloudBrainShow(ctx *context.Context, tpName base.TplName) { |
|
|
task.Status = taskRes.TaskStatuses[0].State |
|
|
task.Status = taskRes.TaskStatuses[0].State |
|
|
task.ContainerID = taskRes.TaskStatuses[0].ContainerID |
|
|
task.ContainerID = taskRes.TaskStatuses[0].ContainerID |
|
|
task.ContainerIp = taskRes.TaskStatuses[0].ContainerIP |
|
|
task.ContainerIp = taskRes.TaskStatuses[0].ContainerIP |
|
|
if task.StartTime == 0 { |
|
|
|
|
|
|
|
|
if task.StartTime == 0 && !taskRes.TaskStatuses[0].StartAt.IsZero() { |
|
|
task.StartTime = timeutil.TimeStamp(taskRes.TaskStatuses[0].StartAt.Unix()) |
|
|
task.StartTime = timeutil.TimeStamp(taskRes.TaskStatuses[0].StartAt.Unix()) |
|
|
} |
|
|
} |
|
|
err = models.UpdateJob(task) |
|
|
err = models.UpdateJob(task) |
|
|
@@ -961,7 +961,7 @@ func SyncCloudbrainStatus() { |
|
|
task.Status = taskRes.TaskStatuses[0].State |
|
|
task.Status = taskRes.TaskStatuses[0].State |
|
|
if task.Status != string(models.JobWaiting) { |
|
|
if task.Status != string(models.JobWaiting) { |
|
|
task.Duration = time.Now().Unix() - taskRes.TaskStatuses[0].StartAt.Unix() |
|
|
task.Duration = time.Now().Unix() - taskRes.TaskStatuses[0].StartAt.Unix() |
|
|
if task.StartTime == 0 { |
|
|
|
|
|
|
|
|
if task.StartTime == 0 && !taskRes.TaskStatuses[0].StartAt.IsZero() { |
|
|
task.StartTime = timeutil.TimeStamp(taskRes.TaskStatuses[0].StartAt.Unix()) |
|
|
task.StartTime = timeutil.TimeStamp(taskRes.TaskStatuses[0].StartAt.Unix()) |
|
|
} |
|
|
} |
|
|
//if task.Status == string(models.JobFailed) { |
|
|
//if task.Status == string(models.JobFailed) { |
|
|
@@ -1008,7 +1008,7 @@ func SyncCloudbrainStatus() { |
|
|
|
|
|
|
|
|
if result != nil { |
|
|
if result != nil { |
|
|
task.Status = result.Status |
|
|
task.Status = result.Status |
|
|
if task.StartTime == 0 { |
|
|
|
|
|
|
|
|
if task.StartTime == 0 && result.Lease.CreateTime > 0 { |
|
|
task.StartTime = timeutil.TimeStamp(result.Lease.CreateTime / 1000) |
|
|
task.StartTime = timeutil.TimeStamp(result.Lease.CreateTime / 1000) |
|
|
} |
|
|
} |
|
|
if task.EndTime == 0 && task.Status == string(models.ModelArtsStopped) { |
|
|
if task.EndTime == 0 && task.Status == string(models.ModelArtsStopped) { |
|
|
@@ -1033,7 +1033,7 @@ func SyncCloudbrainStatus() { |
|
|
task.Duration = result.Duration / 1000 |
|
|
task.Duration = result.Duration / 1000 |
|
|
task.TrainJobDuration = result.TrainJobDuration |
|
|
task.TrainJobDuration = result.TrainJobDuration |
|
|
|
|
|
|
|
|
if task.StartTime == 0 { |
|
|
|
|
|
|
|
|
if task.StartTime == 0 && result.StartTime > 0 { |
|
|
task.StartTime = timeutil.TimeStamp(result.StartTime / 1000) |
|
|
task.StartTime = timeutil.TimeStamp(result.StartTime / 1000) |
|
|
} |
|
|
} |
|
|
if result.Duration != 0 { |
|
|
if result.Duration != 0 { |
|
|
|