From 061cdeba5765c475ea93eb2c56de2a85f004629e Mon Sep 17 00:00:00 2001 From: karthik2804 Date: Thu, 18 Jan 2024 13:41:24 -0800 Subject: [PATCH] Warn instead of trace when errors happen in the spin_redis_engine Signed-off-by: karthik2804 --- crates/redis/src/lib.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/crates/redis/src/lib.rs b/crates/redis/src/lib.rs index e672ef5716..eb11869fb7 100644 --- a/crates/redis/src/lib.rs +++ b/crates/redis/src/lib.rs @@ -94,7 +94,11 @@ impl TriggerExecutor for RedisTrigger { let mut stream = pubsub.on_message(); loop { match stream.next().await { - Some(msg) => drop(self.handle(msg).await), + Some(msg) => { + if let Err(err) = self.handle(msg).await { + tracing::warn!("Error handling message: {err}"); + } + } None => { tracing::trace!("Empty message"); if !client.check_connection() {