class Sidekiq::Parameters::Logging
Public Instance Methods
call(worker, item, queue) { || ... }
click to toggle source
# File lib/sidekiq/parameters/logging.rb, line 4 def call(worker, item, queue) Sidekiq::Logging.with_context("#{worker.class.to_s} JID-#{item['jid']}") do begin start = Time.now # see whether filter_block is set worker_class = worker.class if worker_class.respond_to?(:filter_block) && worker_class.filter_block logger.info do # deep clone the arguments "start parameters: #{worker_class.filter_block.call(*(Marshal.load(Marshal.dump(item['args'])))).inspect}" end else logger.info { "start parameters: #{item['args'].inspect}" } end yield logger.info { "done: #{elapsed(start)} sec" } rescue Exception logger.info { "fail: #{elapsed(start)} sec" } raise end end end
elapsed(start)
click to toggle source
# File lib/sidekiq/parameters/logging.rb, line 29 def elapsed(start) (Time.now - start).to_f.round(3) end
logger()
click to toggle source
# File lib/sidekiq/parameters/logging.rb, line 33 def logger Sidekiq.logger end