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`,