diff --git a/src/sentry/replays/consumers/recording.py b/src/sentry/replays/consumers/recording.py index 77382dc03dda89..090f3f9fe32de6 100644 --- a/src/sentry/replays/consumers/recording.py +++ b/src/sentry/replays/consumers/recording.py @@ -25,7 +25,7 @@ process_recording_event, track_recording_metadata, ) -from sentry.utils import json +from sentry.utils import json, metrics RECORDINGS_CODEC: Codec[ReplayRecording] = get_topic_codec(Topic.INGEST_REPLAYS_RECORDINGS) @@ -108,6 +108,9 @@ def parse_recording_event(message: bytes) -> Event: if replay_event_json: replay_event = json.loads(cast(bytes, replay_event_json)) else: + # Check if any events are not present in the pipeline. We need + # to know because we want to write to Snuba from here soon. + metrics.incr("sentry.replays.consumer.recording.missing-replay-event") replay_event = None replay_video_raw = recording.get("replay_video")