Sha256: a77d20e39023339c10938ab45933a355a1c4454618b36e93e86f43b994e32f71
Contents?: true
Size: 1.52 KB
Versions: 7
Compression:
Stored size: 1.52 KB
Contents
module Loga
module Sidekiq5
# The approach of using a custom job logger in sidekiq was introduced
# in v5.0: https://github.com/mperham/sidekiq/pull/3235
class JobLogger
include Loga::Utilities
EVENT_TYPE = 'sidekiq'.freeze
def started_at
@started_at ||= Time.now
end
def data
@data ||= {}
end
def call(item, _queue)
reset_data
yield
rescue Exception => ex # rubocop:disable Lint/RescueException
data['exception'] = ex
raise
ensure
assign_data(item)
send_message
end
private
def reset_data
@data = {}
@started_at = Time.now
end
def assign_data(item)
data['created_at'] = item['created_at']
data['enqueued_at'] = item['enqueued_at']
data['jid'] = item['jid']
data['queue'] = item['queue']
data['retry'] = item['retry']
data['params'] = item['args']
data['class'] = item['class']
data['duration'] = duration_in_ms(started_at)
end
def short_message
"#{data['class']} with jid: '#{data['jid']}' executed in #{data['duration']}ms"
end
def send_message
event = Event.new(data: data, message: short_message, type: EVENT_TYPE)
logger.public_send(compute_level, event)
end
def compute_level
data.key?('exception') ? :warn : :info
end
def logger
Loga.logger
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems