Support OpenTelemetry SDK 1.33.0 (#1067)

Author: alexmojaki

logfire/_internal/exporters/console.py

@@ -18,7 +18,6 @@
 from opentelemetry.sdk._logs.export import LogExporter, LogExportResult
 from opentelemetry.sdk.trace import Event, ReadableSpan
 from opentelemetry.sdk.trace.export import SpanExporter, SpanExportResult
-from opentelemetry.util import types as otel_types
 from rich.columns import Columns
 from rich.console import Console, Group
 from rich.syntax import Syntax
@@ -52,7 +51,7 @@
 
 @dataclass
 class Record:
-    attributes: Mapping[str, otel_types.AttributeValue]
+    attributes: Mapping[str, object]
     timestamp: int
     message: str
     events: Sequence[Event]
@@ -476,7 +475,7 @@ def _parent_stack_text_parts(self, parent_id: int | None) -> TextParts:
         return parts
 
 
-def _pending_span_parent(attributes: Mapping[str, otel_types.AttributeValue]) -> int | None:
+def _pending_span_parent(attributes: Mapping[str, object]) -> int | None:
     """Pending span marks the start of a span.
 
     Since they're nested within another span we haven't seen yet,

logfire/_internal/integrations/redis.py

@@ -36,7 +36,7 @@ def instrument_redis(
     if capture_statement:
         request_hook = _capture_statement_hook(request_hook)
 
-    RedisInstrumentor().instrument(request_hook=request_hook, response_hook=response_hook, **kwargs)
+    RedisInstrumentor().instrument(request_hook=request_hook, response_hook=response_hook, **kwargs)  # type: ignore[reportUnknownMemberType]
 
 
 def _capture_statement_hook(request_hook: RequestHook | None = None) -> RequestHook:

logfire/_internal/logs.py

@@ -4,11 +4,13 @@
 import functools
 from dataclasses import dataclass
 from threading import Lock
-from typing import Any
+from typing import TYPE_CHECKING, Any
 from weakref import WeakSet
 
 from opentelemetry._logs import Logger, LoggerProvider, LogRecord, NoOpLoggerProvider
-from opentelemetry.util.types import Attributes
+
+if TYPE_CHECKING:
+    from opentelemetry.util.types import _ExtendedAttributes  # type: ignore
 
 
 @dataclass
@@ -22,7 +24,11 @@ class ProxyLoggerProvider(LoggerProvider):
     suppressed_scopes: set[str] = dataclasses.field(default_factory=set)  # type: ignore[reportUnknownVariableType]
 
     def get_logger(
-        self, name: str, version: str | None = None, schema_url: str | None = None, attributes: Attributes | None = None
+        self,
+        name: str,
+        version: str | None = None,
+        schema_url: str | None = None,
+        attributes: _ExtendedAttributes | None = None,
     ) -> Logger:
         with self.lock:
             if name in self.suppressed_scopes:
@@ -74,7 +80,7 @@ class ProxyLogger(Logger):
     name: str
     version: str | None = None
     schema_url: str | None = None
-    attributes: Attributes | None = None
+    attributes: _ExtendedAttributes | None = None
 
     def emit(self, record: LogRecord) -> None:
         self.logger.emit(record)

pyproject.toml

@@ -46,8 +46,8 @@ classifiers = [
     "Framework :: OpenTelemetry :: Instrumentations",
 ]
 dependencies = [
-    "opentelemetry-sdk >= 1.21.0, < 1.33.0",
-    "opentelemetry-exporter-otlp-proto-http >= 1.21.0, < 1.33.0",
+    "opentelemetry-sdk >= 1.21.0, < 1.34.0",
+    "opentelemetry-exporter-otlp-proto-http >= 1.21.0, < 1.34.0",
     "opentelemetry-instrumentation >= 0.41b0",
     "rich >= 13.4.2",
     "protobuf >= 4.23.4",