Skip to content

Commit

Permalink
feat: Skip historical/delta lake processing for function/event rules
Browse files Browse the repository at this point in the history
  • Loading branch information
morgsmccauley committed Dec 21, 2023
1 parent 2750d93 commit cb2021b
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions block-streamer/src/block_stream.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
use anyhow::{bail, Context};
use anyhow::Context;
use near_lake_framework::near_indexer_primitives;
use tokio::task::JoinHandle;

Expand Down Expand Up @@ -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![])
}
}?;

Expand Down

0 comments on commit cb2021b

Please sign in to comment.