feat: Capture errors thrown in sync block streams

near · Feb 11, 2024 · 3ffed37 · 3ffed37
1 parent 5808997
commit 3ffed37
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/coordinator/src/block_streams/synchronise.rs b/coordinator/src/block_streams/synchronise.rs
@@ -23,13 +23,21 @@ pub async fn synchronise_block_streams(
                 })
                 .map(|index| active_block_streams.swap_remove(index));
 
-            synchronise_block_stream(
+            let _ = synchronise_block_stream(
                 active_block_stream,
                 indexer_config,
                 redis_client,
                 block_streams_handler,
             )
-            .await?;
+            .await
+            .map_err(|err| {
+                tracing::error!(
+                    account_id = account_id.as_str(),
+                    function_name,
+                    version = indexer_config.get_registry_version(),
+                    "failed to sync block stream: {err:?}"
+                )
+            });
         }
     }