diff --git a/ddtrace/internal/telemetry/writer.py b/ddtrace/internal/telemetry/writer.py index 40367091bd4..78362351217 100644 --- a/ddtrace/internal/telemetry/writer.py +++ b/ddtrace/internal/telemetry/writer.py @@ -44,7 +44,7 @@ log = get_logger(__name__) -class LogData(dict): +class LogData(dict[str, Any]): def __hash__(self): return hash((self["message"], self["level"], self.get("tags"), self.get("stack_trace"))) @@ -160,7 +160,7 @@ def __init__(self, is_periodic: bool = True, agentless: Optional[bool] = None) - self._is_periodic = is_periodic self._integrations_queue: dict[str, dict] = dict() self._namespace = MetricNamespace() - self._logs: set[dict[str, Any]] = set() + self._logs: set[LogData] = set() self._events_queue: list[dict[str, Any]] = [] self._queued_configs: list[dict] = [] self._sent_configs: list[dict] = [] @@ -588,7 +588,7 @@ def add_distribution_metric( tags, ) - def _report_logs(self) -> set[dict[str, Any]]: + def _report_logs(self) -> set[LogData]: with self._service_lock: logs = self._logs self._logs = set()