lib/sidekiq/debounce.rb in sidekiq-debounce-1.0.0 vs lib/sidekiq/debounce.rb in sidekiq-debounce-1.0.1
- old
+ new
@@ -2,10 +2,10 @@
require 'sidekiq/api'
module Sidekiq
class Debounce
def call(worker, msg, _queue, redis_pool)
- @worker = worker
+ @worker = worker.is_a?(String) ? worker.constantize : worker
@msg = msg
return yield unless debounce?
redis_pool.with do |conn|