Merge pull request 'fix task status' (#187) from tzwang/pcm-coordinator:master into master
Former-commit-id: 08601cbd584aadcc4d4d79ccfb6a6af0065e6ff4
This commit is contained in:
commit
4555a50afa
|
@ -120,9 +120,14 @@ func (l *PageListTaskLogic) updateTaskStatus(tasks []*types.TaskModel, ch chan<-
|
||||||
}
|
}
|
||||||
|
|
||||||
if len(aiTask) == 1 {
|
if len(aiTask) == 1 {
|
||||||
task.Status = aiTask[0].Status
|
if aiTask[0].Status == constants.Completed {
|
||||||
|
task.Status = constants.Succeeded
|
||||||
|
} else {
|
||||||
|
task.Status = aiTask[0].Status
|
||||||
|
}
|
||||||
task.StartTime = aiTask[0].StartTime
|
task.StartTime = aiTask[0].StartTime
|
||||||
task.EndTime = aiTask[0].EndTime
|
task.EndTime = aiTask[0].EndTime
|
||||||
|
task.UpdatedTime = time.Now().Format(constants.Layout)
|
||||||
tx = l.svcCtx.DbEngin.Model(task).Table("task").Where("deleted_at is null").Updates(task)
|
tx = l.svcCtx.DbEngin.Model(task).Table("task").Where("deleted_at is null").Updates(task)
|
||||||
if tx.Error != nil {
|
if tx.Error != nil {
|
||||||
logx.Errorf(tx.Error.Error())
|
logx.Errorf(tx.Error.Error())
|
||||||
|
|
Loading…
Reference in New Issue