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() {