Skip to content

Commit

Permalink
add redis put
Browse files Browse the repository at this point in the history
  • Loading branch information
victoria-yining-huang committed Nov 1, 2024
1 parent 8b5234b commit 3143ea2
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/sentry/ingest/consumer/processors.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
import os
from collections.abc import Mapping, MutableMapping
from typing import Any
from sentry.utils.event_tracker import EventTracker, EventStageStatus

import orjson
import sentry_sdk
Expand Down Expand Up @@ -202,6 +203,8 @@ def process_event(
else:
with metrics.timer("ingest_consumer._store_event"):
cache_key = processing_store.store(data)
tracker = EventTracker()
tracker.record_event_stage_status(event_id=data["event_id"], status=EventStageStatus.REDIS_PUT)
save_attachments(attachments, cache_key)

try:
Expand Down
1 change: 1 addition & 0 deletions src/sentry/utils/event_tracker.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
class EventStageStatus(Enum):
START = "start"
END = "end"
REDIS_PUT = "redis_put"
"""
i plan on adding the below enums for every step of the transactions pipeline
ingest_consumer_published
Expand Down

0 comments on commit 3143ea2

Please sign in to comment.