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