aboutsummaryrefslogtreecommitdiffstats
path: root/crates/router/src/processor
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/router/src/processor
parent707b117cfa1b56c36bfedf5026efa36e0dacdbb3 (diff)
downloadwarden-c7e21fbae10bc84fcc8fff7fb69d9e0178885538.tar.bz2
warden-c7e21fbae10bc84fcc8fff7fb69d9e0178885538.zip
fix: clippy
Diffstat (limited to 'crates/router/src/processor')
-rw-r--r--crates/router/src/processor/route.rs6
1 files changed, 4 insertions, 2 deletions
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())?;