class ElasticAPM::Spies::DelayedJobSpy
def self.job_name(job)
def self.job_name(job) payload_object = job.payload_object if payload_object.is_a?(::Delayed::PerformableMethod) performable_method_name(payload_object) elsif payload_object.instance_of?( ActiveJob::QueueAdapters::DelayedJobAdapter::JobWrapper ) payload_object.job_data['job_class'] else payload_object.class.name end rescue job.name end