fix: wrong span usage

ahdark-services · Apr 23, 2024 · 24766de · 24766de
1 parent 27db76d
commit 24766de
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 11 deletions.
diff --git a/rust-common/src/bot/utils.rs b/rust-common/src/bot/utils.rs
@@ -1,7 +1,6 @@
 use std::collections::HashMap;
 
 use lapin::types::AMQPValue;
-use opentelemetry::trace::{SpanKind, TraceContextExt, Tracer};
 use opentelemetry::{global, Context};
 
 pub fn extract_span_from_delivery(delivery: &lapin::message::Delivery) -> Context {
@@ -34,13 +33,5 @@ pub fn extract_span_from_delivery(delivery: &lapin::message::Delivery) -> Contex
         propagator.extract(&trace_data_map)
     });
 
-    let tracer = global::tracer("pegasus/rust-common/bot/channel");
-    let span = tracer
-        .span_builder("UpdateListener::as_stream")
-        .with_kind(SpanKind::Consumer)
-        .start_with_context(&tracer, &parent_cx);
-
-    let cx = parent_cx.with_span(span);
-
-    cx
+    parent_cx
 }
diff --git a/rust-common/src/observability/tracing.rs b/rust-common/src/observability/tracing.rs
@@ -22,7 +22,7 @@ pub fn init_tracer(service_name: &str, settings: &Settings) {
             .unwrap_or_default(),
         endpoint: format!(
             "{}{}",
-            if tracing_config.exporter.insecure.unwrap_or_default() {
+            if tracing_config.exporter.insecure.unwrap_or(true) {
                 "http://"
             } else {
                 "https://"