Sha256: c6a6a83ed37d2c969f5287b649722940717af47eb040b07369de94edf3a74455
Contents?: true
Size: 895 Bytes
Versions: 4
Compression:
Stored size: 895 Bytes
Contents
module Sidekiq module Middleware module Server class Logging def call(worker, item, queue) # If we're using a wrapper class, like ActiveJob, use the "wrapped" # attribute to expose the underlying thing. klass = item['wrapped'] || worker.class.to_s Sidekiq::Logging.with_context("#{klass} JID-#{item['jid']}#{" BID-#{item['bid']}" if item['bid']}") 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).round(3) end def logger Sidekiq.logger end end end end end
Version data entries
4 entries across 4 versions & 1 rubygems