Sha256: a7aac047c484ad72d2fd47a830b7ec265ac6e549007fa4f1280e04ab6093cafc
Contents?: true
Size: 1.74 KB
Versions: 5
Compression:
Stored size: 1.74 KB
Contents
module RailsPerformance
module Gems
class DelayedJobExt
class Plugin < ::Delayed::Plugin
callbacks do |lifecycle|
lifecycle.around(:invoke_job) do |job, *args, &block|
now = RailsPerformance::Utils.time
block.call(job, *args)
status = "success"
rescue Exception => error # rubocop:disable Lint/RescueException
status = "error"
raise error
ensure
meta_data = RailsPerformance::Gems::DelayedJobExt::Plugin.meta(job.payload_object)
record = RailsPerformance::Models::DelayedJobRecord.new(
jid: job.id,
duration: (RailsPerformance::Utils.time - now) * 1000,
datetime: now.strftime(RailsPerformance::FORMAT),
datetimei: now.to_i,
source_type: meta_data[0],
class_name: meta_data[1],
method_name: meta_data[2],
status: status
)
record.save
end
end
# [source_type, class_name, method_name, duration]
def self.meta(payload_object)
if payload_object.is_a?(::Delayed::PerformableMethod)
if payload_object.object.is_a?(Module)
[:class_method, payload_object.object.name, payload_object.method_name.to_s]
else
[:instance_method, payload_object.object.class.name, payload_object.method_name.to_s]
end
else
[:instance_method, payload_object.class.name, "perform"]
end
rescue
[:unknown, :unknown, :unknown]
end
end
def self.init
::Delayed::Worker.plugins += [::RailsPerformance::Gems::DelayedJobExt::Plugin]
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems