class DistributedTracing::SidekiqMiddleware::Server

Public Instance Methods

call(worker, job, queue) { || ... } click to toggle source
# File lib/rails_distributed_tracing/plugins/sidekiq.rb, line 16
def call(worker, job, queue)
  logger = worker.logger

  if logger.respond_to?(:tagged)
    DistributedTracing.trace_id = job[DistributedTracing::TRACE_ID]
    logger.tagged(DistributedTracing.trace_id) {yield}
    DistributedTracing.trace_id= nil
  else
    yield
  end
end