Sha256: ff6e1512844865d429a2b7047833b6b1963079b549754c0117c5878dbbef7376
Contents?: true
Size: 985 Bytes
Versions: 17
Compression:
Stored size: 985 Bytes
Contents
module RailsPerformance
module Gems
class SidekiqExt
def initialize(options=nil)
end
def call(worker, msg, queue)
now = Time.now
record = RailsPerformance::Models::SidekiqRecord.new(
enqueued_ati: msg['enqueued_at'].to_i,
datetimei: msg['created_at'].to_i,
jid: msg['jid'],
queue: queue,
start_timei: now.to_i,
datetime: now.strftime(RailsPerformance::FORMAT),
worker: msg['wrapped'.freeze] || worker.class.to_s
)
begin
result = yield
record.status = "success"
result
rescue Exception => ex
record.status = "exception"
record.message = ex.message
raise ex
ensure
# store in ms instead of seconds
record.duration = (Time.now - now) * 1000
record.save
result
end
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems