Sha256: a8a176868e995fe146d99b62979d978b5af17269c1d49f8dfb470c492e866733
Contents?: true
Size: 1.07 KB
Versions: 33
Compression:
Stored size: 1.07 KB
Contents
# frozen_string_literal: true module Labkit module Middleware module Sidekiq module Tracing # SidekiqCommon is a mixin for the sidekiq middleware components module SidekiqCommon def job_class(job) # Active Job wrapping can be found at # https://github.com/rails/rails/blob/v6.0.3.1/activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb job["wrapped"].presence || job["class"].presence || "undefined" end def wrapped?(job) job["wrapped"].present? end def tags_from_job(job, kind) tags = { "component" => "sidekiq", "span.kind" => kind, "sidekiq.wrapped" => wrapped?(job), "sidekiq.queue" => job["queue"], "sidekiq.jid" => job["jid"], "sidekiq.retry" => job["retry"].to_s, "sidekiq.args" => job["args"]&.join(", "), } tags["sidekiq.at"] = job["at"] if job["at"] tags end end end end end end
Version data entries
33 entries across 33 versions & 1 rubygems