From 7744ef420c255126846c373bbcd00d18b975e5d7 Mon Sep 17 00:00:00 2001 From: Jonathan Dung Date: Tue, 12 May 2026 22:26:46 +0800 Subject: [PATCH 1/2] fix --- ddtrace/internal/telemetry/writer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ddtrace/internal/telemetry/writer.py b/ddtrace/internal/telemetry/writer.py index 40367091bd4..85f387fb677 100644 --- a/ddtrace/internal/telemetry/writer.py +++ b/ddtrace/internal/telemetry/writer.py @@ -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] = [] From 2c34f3ab8df88661f12700d3d440b4865be29e99 Mon Sep 17 00:00:00 2001 From: Jonathan Dung Date: Tue, 12 May 2026 22:31:58 +0800 Subject: [PATCH 2/2] forgot one --- ddtrace/internal/telemetry/writer.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ddtrace/internal/telemetry/writer.py b/ddtrace/internal/telemetry/writer.py index 85f387fb677..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"))) @@ -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()