aboutsummaryrefslogtreecommitdiffstats
path: root/crates/aggregator/src
diff options
context:
space:
mode:
authorrtkay123 <dev@kanjala.com>2025-10-18 10:48:48 +0200
committerrtkay123 <dev@kanjala.com>2025-10-18 10:48:48 +0200
commitc7e21fbae10bc84fcc8fff7fb69d9e0178885538 (patch)
tree7583f72a03e5be41761115357e88e697256511e8 /crates/aggregator/src
parent707b117cfa1b56c36bfedf5026efa36e0dacdbb3 (diff)
downloadwarden-c7e21fbae10bc84fcc8fff7fb69d9e0178885538.tar.bz2
warden-c7e21fbae10bc84fcc8fff7fb69d9e0178885538.zip
fix: clippy
Diffstat (limited to 'crates/aggregator/src')
-rw-r--r--crates/aggregator/src/processor/aggregate.rs7
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())?;