Class: Skylight::Core::Probes::DelayedJob::Probe Private
- Inherits:
-
Object
- Object
- Skylight::Core::Probes::DelayedJob::Probe
- Defined in:
- lib/skylight/core/probes/delayed_job.rb
This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.
Constant Summary collapse
- UNKNOWN =
This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.
"<Delayed::Job Unknown>".freeze
Instance Method Summary collapse
- #install ⇒ Object private
Instance Method Details
#install ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/skylight/core/probes/delayed_job.rb', line 7 def install return unless validate_version ::Delayed::Worker.class_eval do include Skylight::Core::Util::Logging alias_method :run_without_sk, :run alias_method :handle_failed_job_without_sk, :handle_failed_job def run(job, *args) t { "Delayed::Job beginning trace" } handler_name = begin if defined?(::Delayed::PerformableMethod) && job.payload_object.is_a?(::Delayed::PerformableMethod) job.name else job.payload_object.class.name end rescue UNKNOWN end Skylight.trace(handler_name, "app.delayed_job.worker", "Delayed::Worker#run", component: :worker, segment: job.queue) do run_without_sk(job, *args) end end def handle_failed_job(job, error, *args) handle_failed_job_without_sk(job, error, *args) return unless Skylight.trace Skylight.trace.segment = "error" end end end |