1 files changed, 5 insertions, 2 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())?;