Skip to content

Commit

Permalink
🛠️ apply pre-commit fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
getsantry[bot] authored Nov 1, 2024
1 parent c09a7c4 commit 2ebf8d5
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/sentry/utils/event_tracker.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
import logging
from abc import ABC, abstractmethod
from enum import Enum
import logging


class EventStageStatus(Enum):
START = "start"
Expand All @@ -26,10 +27,12 @@ class EventStageStatus(Enum):
post_process_finished / the same as redis_deleted
"""


class EventTrackerBackend(ABC):
"""
Abstract base class for event lineage tracking within a pipeline component.
"""

@abstractmethod
def record_processing_phase(self, event_id: str, status: EventStageStatus):
"""
Expand All @@ -41,10 +44,12 @@ def record_processing_phase(self, event_id: str, status: EventStageStatus):
"""
raise NotImplementedError


class EventTracker(EventTrackerBackend):
"""
Logger-based implementation of EventTrackerBackend. The data will be saved in BigQuery using Google Log Sink
"""

def __init__(self):
self.logger = logging.getLogger("EventTracker")
logging.basicConfig(level=logging.INFO)
Expand Down

0 comments on commit 2ebf8d5

Please sign in to comment.