Browse Source

调整任务队列删除的逻辑,只要超过过期时间的,都删除

Signed-off-by: allan716 <[email protected]>
allan716 3 years ago
parent
commit
d7ea0084d2
1 changed files with 3 additions and 3 deletions
  1. 3 3
      internal/pkg/task_queue/get.go

+ 3 - 3
internal/pkg/task_queue/get.go

@@ -14,9 +14,9 @@ func (t *TaskQueue) BeforeGetOneJob() {
 		t.taskPriorityMapList[TaskPriority].Each(func(key interface{}, value interface{}) {
 
 			nowOneJob := value.(task_queue.OneJob)
-			if nowOneJob.JobStatus == task_queue.Done &&
-				// 默认是 90day, A.After(B) : A > B == true
-				(time.Time)(nowOneJob.UpdateTime).AddDate(0, 0, t.settings.AdvancedSettings.TaskQueue.ExpirationTime).After(time.Now()) == false {
+			if //nowOneJob.JobStatus == task_queue.Done &&
+			// 默认是 90day, A.After(B) : A > B == true
+			(time.Time)(nowOneJob.UpdateTime).AddDate(0, 0, t.settings.AdvancedSettings.TaskQueue.ExpirationTime).After(time.Now()) == false {
 				// 找到就删除
 				bok, err := t.del(nowOneJob.Id)
 				if err != nil {