From f4e8a6db9a8a2f181d78990f9f68cc6f68fef49a Mon Sep 17 00:00:00 2001 From: Morgan Mccauley Date: Wed, 8 Nov 2023 17:15:47 +1300 Subject: [PATCH] feat: Log on historical processing cancellation --- .../queryapi_coordinator/src/historical_block_processing.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/indexer/queryapi_coordinator/src/historical_block_processing.rs b/indexer/queryapi_coordinator/src/historical_block_processing.rs index f091c3f86..a0e9ea707 100644 --- a/indexer/queryapi_coordinator/src/historical_block_processing.rs +++ b/indexer/queryapi_coordinator/src/historical_block_processing.rs @@ -51,6 +51,12 @@ impl Streamer { let handle = tokio::spawn(async move { tokio::select! { _ = cancellation_token_clone.cancelled() => { + tracing::info!( + target: crate::INDEXER, + "Cancelling existing historical backfill for indexer: {:?}", + indexer.get_full_name(), + ); + storage::del( &redis_connection_manager, storage::generate_historical_stream_key(&indexer.get_full_name()),