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