Skip to content

Commit 112a83e

Browse files
Sidekiq 7 upgrade
- Replace fakeredis by a real redis because it is not compatible with Sidekiq 7 and the new redis-client gem [1]. - Fix tests. [1]: guilleiguaran/fakeredis#270
1 parent 163234c commit 112a83e

File tree

5 files changed

+12
-9
lines changed

5 files changed

+12
-9
lines changed

lib/sidekiq/batch.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ def parent
169169
end
170170

171171
def valid?(batch = self)
172-
valid = !Sidekiq.redis { |r| r.exists("invalidated-bid-#{batch.bid}") }
172+
valid = Sidekiq.redis { |r| r.exists("invalidated-bid-#{batch.bid}") }.zero?
173173
batch.parent ? valid && valid?(batch.parent) : valid
174174
end
175175

sidekiq-batch.gemspec

-1
Original file line numberDiff line numberDiff line change
@@ -24,5 +24,4 @@ Gem::Specification.new do |spec|
2424
spec.add_development_dependency "bundler", "~> 2.1"
2525
spec.add_development_dependency "rake", "~> 13.0"
2626
spec.add_development_dependency "rspec", "~> 3.0"
27-
spec.add_development_dependency "fakeredis", "~> 0.8.0"
2827
end

spec/sidekiq/batch/middleware_spec.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@
7979
end
8080

8181
describe Sidekiq::Batch::Middleware do
82-
let(:config) { class_double(Sidekiq) }
82+
let(:config) { instance_double(Sidekiq::Config) }
8383
let(:client_middleware) { double(Sidekiq::Middleware::Chain) }
8484

8585
context 'client' do

spec/sidekiq/batch_spec.rb

+4-4
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ def was_performed; end
170170
Sidekiq::Batch.process_failed_job(bid, 'failed-job-id')
171171
Sidekiq::Batch.process_failed_job(bid, failed_jid)
172172
failed = Sidekiq.redis { |r| r.smembers("BID-#{bid}-failed") }
173-
expect(failed).to eq(['xxx', 'failed-job-id'])
173+
expect(failed).to eq(['failed-job-id', 'xxx'])
174174
end
175175
end
176176
end
@@ -245,7 +245,7 @@ def was_performed; end
245245
it 'returns and does not enqueue callbacks' do
246246
batch = Sidekiq::Batch.new
247247
batch.on(event, SampleCallback)
248-
Sidekiq.redis { |r| r.hset("BID-#{batch.bid}", event, true) }
248+
Sidekiq.redis { |r| r.hset("BID-#{batch.bid}", event, 'true') }
249249

250250
expect(Sidekiq::Client).not_to receive(:push)
251251
Sidekiq::Batch.enqueue_callbacks(event, batch.bid)
@@ -290,8 +290,8 @@ def was_performed; end
290290
expect(Sidekiq::Client).to receive(:push_bulk).with(
291291
'class' => Sidekiq::Batch::Callback::Worker,
292292
'args' => [
293-
['SampleCallback2', event.to_s, opts2, batch.bid, nil],
294-
['SampleCallback', event.to_s, opts, batch.bid, nil]
293+
['SampleCallback', event.to_s, opts, batch.bid, nil],
294+
['SampleCallback2', event.to_s, opts2, batch.bid, nil]
295295
],
296296
'queue' => 'default'
297297
)

spec/spec_helper.rb

+6-2
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,9 @@
22
SimpleCov.start
33

44
$LOAD_PATH.unshift File.expand_path('../../lib', __FILE__)
5-
require 'fakeredis/rspec'
65
require 'sidekiq/batch'
76

87
redis_opts = { url: "redis://127.0.0.1:6379/1" }
9-
redis_opts[:driver] = Redis::Connection::Memory if defined?(Redis::Connection::Memory)
108

119
Sidekiq.configure_client do |config|
1210
config.redis = redis_opts
@@ -19,6 +17,12 @@
1917
RSpec.configure do |config|
2018
config.filter_run focus: true
2119
config.run_all_when_everything_filtered = true
20+
21+
config.before do
22+
Sidekiq.redis do |redis|
23+
redis.flushdb
24+
end
25+
end
2226
end
2327

2428
Dir[File.dirname(__FILE__) + "/support/**/*.rb"].each {|f| require f }

0 commit comments

Comments
 (0)