Sha256: 516a1d24a1135c4e23f46f97239624a7bcdd0ee98f8619d570ffbc955d8d12bf
Contents?: true
Size: 1.32 KB
Versions: 10
Compression:
Stored size: 1.32 KB
Contents
if defined?(::Delayed::Plugin)
Appsignal.logger.info('Loading Delayed Job integration')
module Appsignal
module Integrations
class DelayedPlugin < ::Delayed::Plugin
callbacks do |lifecycle|
lifecycle.around(:invoke_job) do |job, &block|
invoke_with_instrumentation(job, block)
end
end
def self.invoke_with_instrumentation(job, block)
begin
Appsignal::Transaction.create(SecureRandom.uuid, ENV)
class_name, method_name = job.name.split('#')
ActiveSupport::Notifications.instrument(
'perform_job.delayed_job',
:class => class_name,
:method => method_name,
:priority => job.priority,
:attempts => job.attempts,
:queue => job.queue,
:queue_start => job.created_at
) do
block.call(job)
end
rescue Exception => exception
unless Appsignal.is_ignored_exception?(exception)
Appsignal::Transaction.current.add_exception(exception)
end
raise exception
ensure
Appsignal::Transaction.current.complete!
end
end
end
end
end
::Delayed::Worker.plugins << Appsignal::Integrations::DelayedPlugin
end
Version data entries
10 entries across 10 versions & 1 rubygems