feat: Reset PUBLISHED_BLOCKS_COUNT on new stream

near · Feb 23, 2024 · 95cbfef · 95cbfef
1 parent 8e349d5
commit 95cbfef
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/block-streamer/src/block_stream.rs b/block-streamer/src/block_stream.rs
@@ -136,6 +136,10 @@ pub(crate) async fn start_block_stream(
 ) -> anyhow::Result<()> {
     tracing::info!("Starting block stream",);
 
+    metrics::PUBLISHED_BLOCKS_COUNT
+        .with_label_values(&[&indexer.get_full_name()])
+        .reset();
+
     let last_indexed_delta_lake_block = process_delta_lake_blocks(
         start_block_height,
         delta_lake_client,