kotovalexarian-likes-github/deanpcmad--sidekiq-limit_fetch
1
0
Fork 0
mirror of https://github.com/deanpcmad/sidekiq-limit_fetch.git synced 2022-11-09 13:54:36 -05:00
Code Releases Activity

fixed redis v4.6.0 pipelines deprecation warning for the changed multi method.

Browse source 
https://github.com/redis/redis-rb/tree/v4.6.0#pipelining
This commit is contained in:
Vitalii Iurev 2022-02-16 18:08:19 +03:00
parent bf9cee3b81
commit ec7c421dec
3 changed files with 12 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lib/sidekiq/limit_fetch/global/monitor.rb
View file

@ -46,10 +46,10 @@ module Sidekiq::LimitFetch::Global
def update_heartbeat(ttl)
Sidekiq.redis do |it|
it.multi do
it.set heartbeat_key, true
it.sadd PROCESS_SET, Selector.uuid
it.expire heartbeat_key, ttl
it.multi do |pipeline|
pipeline.set heartbeat_key, true
pipeline.sadd PROCESS_SET, Selector.uuid
pipeline.expire heartbeat_key, ttl
end
end
end

1
sidekiq-limit_fetch.gemspec
View file

@ -16,6 +16,7 @@ Gem::Specification.new do |gem|
gem.require_paths = %w(lib)
gem.add_dependency 'sidekiq', '>= 4'
gem.add_dependency 'redis', '>= 4.6.0'
gem.add_development_dependency 'redis-namespace', '~> 1.5', '>= 1.5.2'
gem.add_development_dependency 'rspec'
gem.add_development_dependency 'rake'

14
spec/spec_helper.rb
View file

@ -11,13 +11,13 @@ RSpec.configure do |config|
Sidekiq::Queue.reset_instances!
Sidekiq.redis do |it|
clean_redis = ->(queue) do
it.pipelined do
it.del "limit_fetch:limit:#{queue}"
it.del "limit_fetch:process_limit:#{queue}"
it.del "limit_fetch:busy:#{queue}"
it.del "limit_fetch:probed:#{queue}"
it.del "limit_fetch:pause:#{queue}"
it.del "limit_fetch:block:#{queue}"
it.pipelined do |pipeline|
pipeline.del "limit_fetch:limit:#{queue}"
pipeline.del "limit_fetch:process_limit:#{queue}"
pipeline.del "limit_fetch:busy:#{queue}"
pipeline.del "limit_fetch:probed:#{queue}"
pipeline.del "limit_fetch:pause:#{queue}"
pipeline.del "limit_fetch:block:#{queue}"
end
end