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 Oct 31, 2024
1 parent ee51aa6 commit a147a53
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 Down Expand Up @@ -30,10 +31,12 @@ class EventStageStatus(Enum):
post_process_finished / is it 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 @@ -45,10 +48,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 a147a53

Please sign in to comment.