chore: log when we fail to normalize the event or parse the timestamp (…

…#17628)

plugin-server/src/worker/ingestion/event-pipeline/processPersonsStep.ts

@@ -1,7 +1,9 @@
 import { PluginEvent } from '@posthog/plugin-scaffold'
+import { DateTime } from 'luxon'
 import { Person } from 'types'
 
 import { normalizeEvent } from '../../../utils/event'
+import { status } from '../../../utils/status'
 import { PersonState } from '../person-state'
 import { parseEventTimestamp } from '../timestamps'
 import { EventPipelineRunner } from './runner'
@@ -10,9 +12,15 @@ export async function processPersonsStep(
     runner: EventPipelineRunner,
     pluginEvent: PluginEvent
 ): Promise<[PluginEvent, Person]> {
-    const event = normalizeEvent(pluginEvent)
-
-    const timestamp = parseEventTimestamp(event)
+    let event: PluginEvent
+    let timestamp: DateTime
+    try {
+        event = normalizeEvent(pluginEvent)
+        timestamp = parseEventTimestamp(event)
+    } catch (error) {
+        status.warn('⚠️', 'Failed normalizing event', { team_id: pluginEvent.team_id, uuid: pluginEvent.uuid, error })
+        throw error
+    }
 
     const person = await new PersonState(
         event,