diff --git a/internal/scheduler/service/utils/status/hpc_task_sync.go b/internal/scheduler/service/utils/status/hpc_task_sync.go index 38e6034d..cd3cb88d 100644 --- a/internal/scheduler/service/utils/status/hpc_task_sync.go +++ b/internal/scheduler/service/utils/status/hpc_task_sync.go @@ -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())