module Yabeda::Faktory
Constants
- JOB_ENQUEUE_TIME_BUCKETS
- LONG_RUNNING_JOB_RUNTIME_BUCKETS
- VERSION
Public Class Methods
labelize(payload)
click to toggle source
# File lib/yabeda/faktory.rb, line 60 def labelize(payload) { queue: payload["queue"], worker: worker_class(payload) } end
worker_class(payload)
click to toggle source
# File lib/yabeda/faktory.rb, line 64 def worker_class(payload) worker = payload["jobtype"] if defined?(ActiveJob::QueueAdapters::FaktoryAdapter::JobWrapper) if worker.is_a?(ActiveJob::QueueAdapters::FaktoryAdapter::JobWrapper) || worker == "ActiveJob::QueueAdapters::FaktoryAdapter::JobWrapper" return payload.dig("custom", "wrapped").to_s end end worker.to_s end