diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go index 3a28a534..20b17031 100644 --- 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{