feat: Stop block stream on delta lake failure

near · Feb 13, 2024 · fabd604 · fabd604
1 parent 586c562
commit fabd604
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/block-streamer/src/block_stream.rs b/block-streamer/src/block_stream.rs
@@ -141,15 +141,7 @@ pub(crate) async fn start_block_stream(
         indexer,
         redis_stream.clone(),
     )
-    .await
-    .unwrap_or_else(|err| {
-        tracing::warn!(
-            "Failed to process Delta Lake blocks, continuing with original start block: {:?}",
-            err,
-        );
-
-        start_block_height
-    });
+    .await?;
 
     let last_indexed_near_lake_block = process_near_lake_blocks(
         last_indexed_delta_lake_block,