1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00

Avoid costly json parsing in JobSet#delete_by_jid for wrong values (#4326)

This commit is contained in:
fatkodima 2019-10-09 16:45:23 +03:00 committed by Mike Perham
parent d9d4728d0b
commit d6b00967ec

View file

@ -655,11 +655,13 @@ module Sidekiq
Sidekiq.redis do |conn|
elements = conn.zrangebyscore(name, score, score)
elements.each do |element|
message = Sidekiq.load_json(element)
if message["jid"] == jid
ret = conn.zrem(name, element)
@_size -= 1 if ret
break ret
if element.index(jid)
message = Sidekiq.load_json(element)
if message["jid"] == jid
ret = conn.zrem(name, element)
@_size -= 1 if ret
break ret
end
end
end
end