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