Fix vulcan post processing metrics not emitted for short term orders (#…

…2244)
dydxprotocol · Sep 12, 2024 · 10189d6 · 10189d6
1 parent 5acd685
commit 10189d6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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<void> {
     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,