lib/sidekiq-status/client_middleware.rb in sidekiq-status-0.2.0 vs lib/sidekiq-status/client_middleware.rb in sidekiq-status-0.3.0
- old
+ new
@@ -5,12 +5,10 @@
# Uses msg['jid'] id and puts :queued status in the job's Redis hash
# @param [Class] worker_class if includes Sidekiq::Status::Worker, the job gets processed with the plugin
# @param [Array] msg job arguments
# @param [String] queue the queue's name
def call(worker_class, msg, queue)
- if worker_class.include? Worker
- store_for_id(msg['jid'], :status => :queued)
- end
+ store_status msg['jid'], :queued
yield
end
end
end