From 9c7f2b82793d93fc3f20278ce0a7119f08386718 Mon Sep 17 00:00:00 2001 From: Morgan Mccauley Date: Thu, 21 Dec 2023 16:29:50 +1300 Subject: [PATCH] feat: Skip historical/delta lake processing for function/event rules --- block-streamer/src/block_stream.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/block-streamer/src/block_stream.rs b/block-streamer/src/block_stream.rs index b60685a2e..8fb18da89 100644 --- a/block-streamer/src/block_stream.rs +++ b/block-streamer/src/block_stream.rs @@ -1,4 +1,4 @@ -use anyhow::{bail, Context}; +use anyhow::Context; use near_lake_framework::near_indexer_primitives; use tokio::task::JoinHandle; @@ -142,10 +142,12 @@ pub(crate) async fn start_block_stream( .await } MatchingRule::ActionFunctionCall { .. } => { - bail!("ActionFunctionCall matching rule not yet supported for historical processing, function: {:?} {:?}", indexer.account_id, indexer.function_name); + tracing::error!("ActionFunctionCall matching rule not yet supported for delta lake processing, function: {:?} {:?}", indexer.account_id, indexer.function_name); + Ok(vec![]) } MatchingRule::Event { .. } => { - bail!("Event matching rule not yet supported for historical processing, function {:?} {:?}", indexer.account_id, indexer.function_name); + tracing::error!("Event matching rule not yet supported for delta lake processing, function {:?} {:?}", indexer.account_id, indexer.function_name); + Ok(vec![]) } }?;