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