Browse Source

fix

Signed-off-by: jagger <cossjie@foxmail.com>
pull/481/head
jagger 6 months ago
parent
commit
af2be1c69d
1 changed files with 1 additions and 1 deletions
  1. +1
    -1
      internal/scheduler/service/utils/status/hpc_task_sync.go

+ 1
- 1
internal/scheduler/service/utils/status/hpc_task_sync.go View File

@@ -41,7 +41,7 @@ func UpdateHpcTaskStatus(svc *svc.ServiceContext) {
svc.Scheduler.HpcService.TaskSyncLock.Lock()
defer svc.Scheduler.HpcService.TaskSyncLock.Unlock()
taskList := make([]*models.TaskHpc, 0)
sqlStr := `select * from task_hpc where job_id!='' and status not in('Failed','Completed','Cancelled') order by created_time desc limit 10`
sqlStr := `select * from task_hpc where job_id!='' and status not in('Failed','Completed') order by created_time desc limit 10`
db := svc.DbEngin.Raw(sqlStr).Scan(&taskList)
if db.Error != nil {
logx.Errorf(db.Error.Error())


Loading…
Cancel
Save