From c10b2e96790cf9e4dfb5d712a23053aa19e6a25e Mon Sep 17 00:00:00 2001 From: Will Liu Date: Fri, 15 Mar 2024 15:13:42 -0400 Subject: [PATCH] rename metric --- indexer/services/ender/__tests__/lib/on-message.test.ts | 2 +- indexer/services/ender/src/caches/block-cache.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/indexer/services/ender/__tests__/lib/on-message.test.ts b/indexer/services/ender/__tests__/lib/on-message.test.ts index 37c9f49263..9b5766006d 100644 --- a/indexer/services/ender/__tests__/lib/on-message.test.ts +++ b/indexer/services/ender/__tests__/lib/on-message.test.ts @@ -759,7 +759,7 @@ describe('on-message', () => { await onMessage(kafkaMessage); - expect(stats.increment).toHaveBeenCalledWith(`${config.SERVICE_NAME}.block_already_parsed.failure`, 1); + expect(stats.increment).toHaveBeenCalledWith(`${config.SERVICE_NAME}.block_already_parsed`, 1); expect(stats.increment).toHaveBeenCalledWith('ender.received_kafka_message', 1); expect(stats.timing).toHaveBeenCalledWith( 'ender.message_time_in_queue', expect.any(Number), 1, { topic: KafkaTopics.TO_ENDER }); diff --git a/indexer/services/ender/src/caches/block-cache.ts b/indexer/services/ender/src/caches/block-cache.ts index e4f359500f..1b7af459f6 100644 --- a/indexer/services/ender/src/caches/block-cache.ts +++ b/indexer/services/ender/src/caches/block-cache.ts @@ -51,7 +51,7 @@ export async function shouldSkipBlock( canRefreshCache: boolean = true, ): Promise { if (blockAlreadyProcessed(blockHeight)) { - stats.increment(`${config.SERVICE_NAME}.block_already_parsed.failure`, 1); + stats.increment(`${config.SERVICE_NAME}.block_already_parsed`, 1); logger.info({ at: 'onMessage#onMessage', message: `Already processed block with block height: ${blockHeight}, so skipping`,