From 10189d63ddccaa8ee14b4499751a60f5fd796259 Mon Sep 17 00:00:00 2001 From: roy-dydx <133032749+roy-dydx@users.noreply.github.com> Date: Thu, 12 Sep 2024 14:19:46 -0400 Subject: [PATCH] Fix vulcan post processing metrics not emitted for short term orders (#2244) --- indexer/services/vulcan/src/lib/on-message.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/indexer/services/vulcan/src/lib/on-message.ts b/indexer/services/vulcan/src/lib/on-message.ts index 590799439a..cc81a9a326 100644 --- a/indexer/services/vulcan/src/lib/on-message.ts +++ b/indexer/services/vulcan/src/lib/on-message.ts @@ -122,10 +122,10 @@ export async function onMessage(message: KafkaMessage): Promise { await handler.handleUpdate(update, headers); const postProcessingTime: number = Date.now(); - if (originalMessageTimestamp !== undefined) { + if (headers.message_received_timestamp !== undefined) { stats.timing( `${config.SERVICE_NAME}.message_time_since_received_post_processing`, - postProcessingTime - Number(originalMessageTimestamp), + postProcessingTime - Number(headers.message_received_timestamp), STATS_NO_SAMPLING, { topic: KafkaTopics.TO_VULCAN,