mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Don't count manual retries against 25 retry limit, #212
This commit is contained in:
parent
b1b58f2acb
commit
f7b8d98d4d
1 changed files with 2 additions and 1 deletions
|
@ -170,7 +170,8 @@ module Sidekiq
|
|||
conn.zremrangebyscore('retry', score, score)
|
||||
results.map do |message|
|
||||
msg = Sidekiq.load_json(message)
|
||||
conn.rpush("queue:#{msg['queue']}", message)
|
||||
msg['retry_count'] = msg['retry_count'] - 1
|
||||
conn.rpush("queue:#{msg['queue']}", Sidekiq.dump_json(msg))
|
||||
end
|
||||
end
|
||||
when :delete
|
||||
|
|
Loading…
Add table
Reference in a new issue