Sha256: f55edcaa4f0dfb18aedb78914b9c17ce72ed7a69b3be97812be9db8e2c058aeb
Contents?: true
Size: 581 Bytes
Versions: 10
Compression:
Stored size: 581 Bytes
Contents
module Skylight
module Normalizers
module ActiveJob
class EnqueueAt < Normalizer
register "enqueue_at.active_job"
CAT = "other.job.enqueue_at".freeze
def normalize(_trace, _name, payload)
title = "Enqueue #{payload[:job].class}"
adapter_class_name = payload[:adapter].class.name
adapter_name = adapter_class_name.match(/^ActiveJob::QueueAdapters::(\w+)Adapter$/)[1].underscore
desc = "{ adapter: '#{adapter_name}', queue: '#{payload[:job].queue_name}' }"
[ CAT, title, desc ]
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems