lib/sidekiq/tracer/server_middleware.rb in sidekiq-instrumentation-2.1.0 vs lib/sidekiq/tracer/server_middleware.rb in sidekiq-instrumentation-2.2.0

- old
+ new

@@ -13,16 +13,11 @@ @after_trace = after_trace end # rubocop:disable Metrics/MethodLength def call(_worker, job, _queue) - parent_span_context = extract(job) - - follows_from = OpenTracing::Reference.follows_from(parent_span_context) - tracer.start_active_span(operation_name(job), - references: [follows_from], ignore_active_scope: true, tags: tags(job, "consumer")) do |scope| begin yield rescue StandardError => e @@ -38,16 +33,9 @@ private def tag_errors(span, error) span.set_tag("error", true) span.log_kv(**{ event: "error", 'error.object': error }) - end - - def extract(job) - carrier = job[TRACE_CONTEXT_KEY] - return unless carrier - - tracer.extract(OpenTracing::FORMAT_TEXT_MAP, carrier) end end end end