We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents be88d81 + 061cdeb commit c25b685Copy full SHA for c25b685
crates/redis/src/lib.rs
@@ -94,7 +94,11 @@ impl TriggerExecutor for RedisTrigger {
94
let mut stream = pubsub.on_message();
95
loop {
96
match stream.next().await {
97
- Some(msg) => drop(self.handle(msg).await),
+ Some(msg) => {
98
+ if let Err(err) = self.handle(msg).await {
99
+ tracing::warn!("Error handling message: {err}");
100
+ }
101
102
None => {
103
tracing::trace!("Empty message");
104
if !client.check_connection() {
0 commit comments