callci:æ�解除跟他æ更新执行过的äºä任务

plum330 · Mar 24, 2022 · e729075 · e729075
1 parent 0624620
commit e729075
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go
@@ -146,9 +146,9 @@ func (dq *DelayQueue) UpdateJob(jobCore *JobCore) error {
 		bucketIdx = job.BucketIndex
 		doneTimes = job.DoneTimes
 	}
-	if doneTimes > 0 {
-		return errors.New("job is doing")
-	}
+	//if doneTimes > 0 {
+	//	return errors.New("job is doing")
+	//}
 	value, err := json.Marshal(&Job{
 		JobCore: jobCore,
 		JobBucket: &JobBucket{