From d5fbda1a956256ff4e38365aef23273f94c5a5af Mon Sep 17 00:00:00 2001 From: blackroot Date: Thu, 24 Mar 2022 21:46:02 +0800 Subject: [PATCH] =?UTF-8?q?callci:=E8=A7=A3=E9=99=A4job=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E9=99=90=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- xdelay_queue/delay_queue.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go index 20b17031..c48806f5 100644 --- 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")