File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
src/sentry/replays/consumers Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change 25
25
process_recording_event ,
26
26
track_recording_metadata ,
27
27
)
28
- from sentry .utils import json
28
+ from sentry .utils import json , metrics
29
29
30
30
RECORDINGS_CODEC : Codec [ReplayRecording ] = get_topic_codec (Topic .INGEST_REPLAYS_RECORDINGS )
31
31
@@ -108,6 +108,9 @@ def parse_recording_event(message: bytes) -> Event:
108
108
if replay_event_json :
109
109
replay_event = json .loads (cast (bytes , replay_event_json ))
110
110
else :
111
+ # Check if any events are not present in the pipeline. We need
112
+ # to know because we want to write to Snuba from here soon.
113
+ metrics .incr ("sentry.replays.consumer.recording.missing-replay-event" )
111
114
replay_event = None
112
115
113
116
replay_video_raw = recording .get ("replay_video" )
You can’t perform that action at this time.
0 commit comments