Fix

PostHog · Sep 5, 2024 · 2a5264f · 2a5264f
1 parent 20e5dcb
commit 2a5264f
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/plugin-server/src/main/ingestion-queues/session-recording/utils.ts b/plugin-server/src/main/ingestion-queues/session-recording/utils.ts
@@ -334,8 +334,7 @@ export const parseKafkaBatch = async (
         }
 
         for (const [windowId, events] of Object.entries(parsedMessage.eventsByWindowId)) {
-            existingMessage.eventsByWindowId[windowId] = existingMessage.eventsByWindowId[windowId] || []
-            existingMessage.eventsByWindowId[windowId].concat(events)
+            existingMessage.eventsByWindowId[windowId] = (existingMessage.eventsByWindowId[windowId] || []).concat(events)
         }
 
         existingMessage.metadata.rawSize += parsedMessage.metadata.rawSize