fix: clippy

5 files changed, 20 insertions, 7 deletions

diff --git a/crates/aggregator/src/processor/aggregate.rs b/crates/aggregator/src/processor/aggregate.rs
index d9d8482..666b6f9 100644
--- a/crates/aggregator/src/processor/aggregate.rs
+++ b/crates/aggregator/src/processor/aggregate.rs
@@ -17,10 +17,13 @@ pub async fn handle(message: Message, state: AppHandle) -> anyhow::Result<()> {
     let span = Span::current();
 
     if let Some(ref headers) = message.headers {
-        let context = global::get_text_map_propagator(|propagator| {
+        let cx = global::get_text_map_propagator(|propagator| {
             propagator.extract(&extractor::HeaderMap(headers))
         });
-        span.set_parent(context);
+
+        if let Err(e) = span.set_parent(cx) {
+            tracing::error!("{e:?}");
+        };
     };
 
     let mut payload: Payload = prost::Message::decode(message.payload.as_ref())?;
diff --git a/crates/pseudonyms/src/server/interceptor.rs b/crates/pseudonyms/src/server/interceptor.rs
index eeb36c2..ff4631a 100644
--- a/crates/pseudonyms/src/server/interceptor.rs
+++ b/crates/pseudonyms/src/server/interceptor.rs
@@ -16,7 +16,9 @@ impl Interceptor for MyInterceptor {
             propagator.extract(&extractor::MetadataMap(request.metadata()))
         });
 
-        span.set_parent(cx);
+        if let Err(e) = span.set_parent(cx) {
+            tracing::error!("{e:?}");
+        };
 
         Ok(request)
     }
diff --git a/crates/router/src/processor/route.rs b/crates/router/src/processor/route.rs
index d51a86a..3248e03 100644
--- a/crates/router/src/processor/route.rs
+++ b/crates/router/src/processor/route.rs
@@ -3,7 +3,7 @@ use std::{collections::HashSet, sync::Arc};
 
 use opentelemetry::global;
 use prost::Message;
-use tracing::{Instrument, Span, info_span, instrument, trace, trace_span, warn};
+use tracing::{Instrument, Span, error, info_span, instrument, trace, trace_span, warn};
 use tracing_opentelemetry::OpenTelemetrySpanExt;
 use warden_core::{google, message::Payload};
 use warden_stack::tracing::telemetry::nats;
@@ -18,7 +18,9 @@ pub async fn route(message: async_nats::jetstream::Message, state: AppHandle) ->
         let context = global::get_text_map_propagator(|propagator| {
             propagator.extract(&nats::extractor::HeaderMap(headers))
         });
-        span.set_parent(context);
+        if let Err(e) = span.set_parent(context) {
+            error!("{e:?}");
+        };
     };
 
     let payload: Payload = Message::decode(message.payload.as_ref())?;
diff --git a/crates/rule-executor/src/processor/rule.rs b/crates/rule-executor/src/processor/rule.rs
index 6eaf25c..8ea0a9f 100644
--- a/crates/rule-executor/src/processor/rule.rs
+++ b/crates/rule-executor/src/processor/rule.rs
@@ -26,7 +26,10 @@ pub async fn process_rule(message: jetstream::Message, state: AppHandle) -> Resu
         let context = global::get_text_map_propagator(|propagator| {
             propagator.extract(&nats::extractor::HeaderMap(headers))
         });
-        span.set_parent(context);
+
+        if let Err(e) = span.set_parent(context) {
+            error!("{e:?}");
+        };
     };
 
     let mut payload: Payload = prost::Message::decode(message.payload.as_ref())?;
diff --git a/crates/typologies/src/processor/typology.rs b/crates/typologies/src/processor/typology.rs
index 62e7089..0aeae3b 100644
--- a/crates/typologies/src/processor/typology.rs
+++ b/crates/typologies/src/processor/typology.rs
@@ -30,7 +30,10 @@ pub async fn process_typology(
         let context = global::get_text_map_propagator(|propagator| {
             propagator.extract(&extractor::HeaderMap(headers))
         });
-        span.set_parent(context);
+
+        if let Err(e) = span.set_parent(context) {
+            error!("{e:?}");
+        };
     };
 
     let payload: Payload = Message::decode(message.payload.as_ref())?;