Class: Sidekiq::Parameters::Logging

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/parameters/logging.rb

Instance Method Summary collapse

Instance Method Details

#call(worker, item, queue) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# 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) ⇒ Object 



29
30
31
 
# File 'lib/sidekiq/parameters/logging.rb', line 29

def elapsed(start)
  (Time.now - start).to_f.round(3)
end

#logger ⇒ Object 



33
34
35
 
# File 'lib/sidekiq/parameters/logging.rb', line 33

def logger
  Sidekiq.logger
end