lib/sidekiq/limit_fetch/global/selector.rb in sidekiq-limit_fetch-2.1.3 vs lib/sidekiq/limit_fetch/global/selector.rb in sidekiq-limit_fetch-2.2.0
- old
+ new
@@ -80,10 +80,12 @@
process_locks = process_locks + 1
end
end
end
- blocking_mode = can_block and locks > 0
+ if not blocking_mode then
+ blocking_mode = can_block and locks > 0
+ end
if blocking_mode and can_block ~= 'true' then
for unblocked_queue in string.gmatch(can_block, "[^,]+") do
unblocked[unblocked_queue] = true
end