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

Stringify perform_bulk's option hash, fixes #5081

Browse source
This commit is contained in:
Mike Perham 2021-12-07 14:02:59 -08:00
parent b0fd83f5fc
commit 41493f2623
2 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/sidekiq/worker.rb
View file

@ -235,8 +235,9 @@ module Sidekiq
alias_method :perform_sync, :perform_inline
def perform_bulk(args, batch_size: 1_000)
hash = @opts.transform_keys(&:to_s)
result = args.each_slice(batch_size).flat_map do |slice|
Sidekiq::Client.push_bulk(@opts.merge("class" => @klass, "args" => slice))
Sidekiq::Client.push_bulk(hash.merge("class" => @klass, "args" => slice))
end
result.is_a?(Enumerator::Lazy) ? result.force : result

4
test/test_worker.rb
View file

@ -85,7 +85,7 @@ describe Sidekiq::Worker do
q = Sidekiq::Queue.new('bar')
assert_equal 0, q.size
set = SetWorker.set('queue' => 'bar')
set = SetWorker.set(queue: 'bar')
jids = set.perform_bulk((1..1_001).to_a.map { |x| Array(x) })
assert_equal 1_001, q.size
@ -123,7 +123,7 @@ describe Sidekiq::Worker do
@name = name
@recorder = recorder
end
def call(*args)
@recorder << "#{@name}-before"
response = yield