diff --git a/lib/resque_cleaner.rb b/lib/resque_cleaner.rb index 57d1298..e307ed4 100644 --- a/lib/resque_cleaner.rb +++ b/lib/resque_cleaner.rb @@ -124,19 +124,17 @@ def requeue(clear_after_requeue=false, options={}, &block) index = @limiter.start_index + i - requeued value = redis.lindex(:failed, index) - redis.multi do - # no change needed to support ActiveJob - Job.create(queue||job['queue'], job['payload']['class'], *job['payload']['args']) - - if clear_after_requeue - # remove job - # TODO: should use ltrim. not sure why i used lrem here... - redis.lrem(:failed, 1, value) - else - # mark retried - job['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S") - redis.lset(:failed, @limiter.start_index+i, Resque.encode(job)) - end + # no change needed to support ActiveJob + Job.create(queue||job['queue'], job['payload']['class'], *job['payload']['args']) + + if clear_after_requeue + # remove job + # TODO: should use ltrim. not sure why i used lrem here... + redis.lrem(:failed, 1, value) + else + # mark retried + job['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S") + redis.lset(:failed, @limiter.start_index+i, Resque.encode(job)) end requeued += 1