callci:解除job更新限制

plum330 · Mar 24, 2022 · d5fbda1 · d5fbda1
1 parent e729075
commit d5fbda1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go
@@ -133,7 +133,7 @@ func (dq *DelayQueue) UpdateJob(jobCore *JobCore) error {
 		jobId      string
 		bucketName string
 		bucketIdx  int
-		doneTimes  int64
+		//doneTimes  int64
 	)
 	if job == nil {
 		jobId = jobCore.Id
@@ -144,7 +144,7 @@ func (dq *DelayQueue) UpdateJob(jobCore *JobCore) error {
 		jobId = job.Id
 		bucketName = job.BucketName
 		bucketIdx = job.BucketIndex
-		doneTimes = job.DoneTimes
+		//doneTimes = job.DoneTimes
 	}
 	//if doneTimes > 0 {
 	//	return errors.New("job is doing")