Sha256: 980159b608fd97e7ffd5fa9bf1e748093617193bc65662f6ba3f662ad1ad48b4
Contents?: true
Size: 685 Bytes
Versions: 4
Compression:
Stored size: 685 Bytes
Contents
module Sidekiq module Middleware module Server class Logging def call(worker, item, queue) Sidekiq::Logging.with_context("#{worker.class.to_s} MSG-#{item['jid']}") do begin start = Time.now logger.info { "start" } yield logger.info { "done: #{elapsed(start)} sec" } rescue Exception logger.info { "fail: #{elapsed(start)} sec" } raise end end end def elapsed(start) (Time.now - start).to_f.round(3) end def logger Sidekiq.logger end end end end end
Version data entries
4 entries across 4 versions & 1 rubygems