feat: Log errors in handle_streamer_message

near · Aug 1, 2023 · 4f18727 · 4f18727
1 parent 1276ca8
commit 4f18727
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/indexer/queryapi_coordinator/src/main.rs b/indexer/queryapi_coordinator/src/main.rs
@@ -111,7 +111,11 @@ async fn main() -> anyhow::Result<()> {
         })
         .buffer_unordered(1usize);
 
-    while let Some(_handle_message) = handlers.next().await {}
+    while let Some(handle_message) = handlers.next().await {
+        if let Err(err) = handle_message {
+            tracing::error!(target: INDEXER, "{:#?}", err);
+        }
+    }
     drop(handlers); // close the channel so the sender will stop
 
     // propagate errors from the sender
@@ -208,7 +212,7 @@ async fn handle_streamer_message(
                     &format!("{}:stream", indexer_function.get_full_name()),
                     &[("block_height", block_height)],
                 )
-                .await?
+                .await?;
             }
 
             stream::iter(indexer_function_messages.into_iter())