Release v3.8.1 (#928)

Author: alexmojaki

CHANGELOG.md

@@ -1,5 +1,10 @@
 # Release Notes
 
+## [v3.8.1] (2025-03-13)
+
+* Upgrade to OpenTelemetry 1.31.0 by @alexmojaki in [#927](https://github.com/pydantic/logfire/pull/927)
+* Record exception with traceback for non-fatal function tool errors in OpenAI agents SDK by @alexmojaki in [#924](https://github.com/pydantic/logfire/pull/924)
+
 ## [v3.8.0] (2025-03-11)
 
 * OpenAI Agents Framework instrumentation by @alexmojaki in [#917](https://github.com/pydantic/logfire/pull/917)
@@ -622,3 +627,4 @@ First release from new repo!
 [v3.7.0]: https://github.com/pydantic/logfire/compare/v3.6.4...v3.7.0
 [v3.7.1]: https://github.com/pydantic/logfire/compare/v3.7.0...v3.7.1
 [v3.8.0]: https://github.com/pydantic/logfire/compare/v3.7.1...v3.8.0
+[v3.8.1]: https://github.com/pydantic/logfire/compare/v3.8.0...v3.8.1

logfire-api/logfire_api/_internal/ast_utils.pyi

@@ -23,7 +23,7 @@ class BaseTransformer(ast.NodeTransformer):
     logfire_method_name: str
     filename: str
     module_name: str
-    qualname_stack = ...
+    qualname_stack: list[str] = ...
     def __post_init__(self) -> None: ...
     def visit_ClassDef(self, node: ast.ClassDef): ...
     def visit_FunctionDef(self, node: ast.FunctionDef | ast.AsyncFunctionDef): ...

logfire-api/logfire_api/_internal/config.pyi

@@ -20,7 +20,7 @@ from .stack_info import warn_at_user_stacklevel as warn_at_user_stacklevel
 from .tracer import OPEN_SPANS as OPEN_SPANS, PendingSpanProcessor as PendingSpanProcessor, ProxyTracerProvider as ProxyTracerProvider
 from .utils import SeededRandomIdGenerator as SeededRandomIdGenerator, UnexpectedResponse as UnexpectedResponse, ensure_data_dir_exists as ensure_data_dir_exists, handle_internal_errors as handle_internal_errors, platform_is_emscripten as platform_is_emscripten, read_toml_file as read_toml_file, suppress_instrumentation as suppress_instrumentation
 from _typeshed import Incomplete
-from dataclasses import dataclass
+from dataclasses import dataclass, field
 from logfire.exceptions import LogfireConfigError as LogfireConfigError
 from logfire.sampling import SamplingOptions as SamplingOptions
 from logfire.sampling._tail_sampling import TailSamplingProcessor as TailSamplingProcessor
@@ -54,7 +54,7 @@ class ConsoleOptions:
 class AdvancedOptions:
     """Options primarily used for testing by Logfire developers."""
     base_url: str = ...
-    id_generator: IdGenerator = ...
+    id_generator: IdGenerator = dataclasses.field(default_factory=Incomplete)
     ns_timestamp_generator: Callable[[], int] = ...
     log_record_processors: Sequence[LogRecordProcessor] = ...
 
@@ -65,8 +65,8 @@ class PydanticPlugin:
     This class is deprecated for external use. Use `logfire.instrument_pydantic()` instead.
     """
     record: PydanticPluginRecordValues = ...
-    include: set[str] = ...
-    exclude: set[str] = ...
+    include: set[str] = field(default_factory=set)
+    exclude: set[str] = field(default_factory=set)
 
 @dataclass
 class MetricsOptions:

logfire-api/logfire_api/_internal/exporters/otlp.pyi

@@ -3,11 +3,14 @@ from ..stack_info import STACK_INFO_KEYS as STACK_INFO_KEYS
 from ..utils import logger as logger, platform_is_emscripten as platform_is_emscripten, truncate_string as truncate_string
 from .wrapper import WrapperLogExporter as WrapperLogExporter, WrapperSpanExporter as WrapperSpanExporter
 from _typeshed import Incomplete
+from collections import deque
 from functools import cached_property
 from opentelemetry.sdk._logs import LogData as LogData
 from opentelemetry.sdk.trace import ReadableSpan
 from opentelemetry.sdk.trace.export import SpanExportResult
+from pathlib import Path
 from requests import Session
+from threading import Thread
 from typing import Any, Mapping, Sequence
 
 class OTLPExporterHttpSession(Session):
@@ -29,8 +32,8 @@ class DiskRetryer:
     MAX_TASKS: int
     LOG_INTERVAL: int
     lock: Incomplete
-    thread: Incomplete
-    tasks: Incomplete
+    thread: Thread | None
+    tasks: deque[tuple[Path, dict[str, Any]]]
     session: Incomplete
     dir: Incomplete
     last_log_time: Incomplete

logfire-api/logfire_api/_internal/logs.pyi

@@ -1,3 +1,4 @@
+import dataclasses
 from dataclasses import dataclass
 from opentelemetry._logs import LogRecord, Logger, LoggerProvider
 from opentelemetry.util.types import Attributes
@@ -9,9 +10,9 @@ from weakref import WeakSet
 class ProxyLoggerProvider(LoggerProvider):
     """A logger provider that wraps another internal logger provider allowing it to be re-assigned."""
     provider: LoggerProvider
-    loggers: WeakSet[ProxyLogger] = ...
-    lock: Lock = ...
-    suppressed_scopes: set[str] = ...
+    loggers: WeakSet[ProxyLogger] = dataclasses.field(default_factory=WeakSet)
+    lock: Lock = dataclasses.field(default_factory=Lock)
+    suppressed_scopes: set[str] = dataclasses.field(default_factory=set)
     def get_logger(self, name: str, version: str | None = None, schema_url: str | None = None, attributes: Attributes | None = None) -> Logger: ...
     def suppress_scopes(self, *scopes: str) -> None: ...
     def set_provider(self, logger_provider: LoggerProvider) -> None: ...

logfire-api/logfire_api/_internal/metrics.pyi

@@ -12,9 +12,9 @@ Gauge: Incomplete
 @dataclasses.dataclass
 class ProxyMeterProvider(MeterProvider):
     provider: MeterProvider
-    meters: WeakSet[_ProxyMeter] = ...
-    lock: Lock = ...
-    suppressed_scopes: set[str] = ...
+    meters: WeakSet[_ProxyMeter] = dataclasses.field(default_factory=WeakSet)
+    lock: Lock = dataclasses.field(default_factory=Lock)
+    suppressed_scopes: set[str] = dataclasses.field(default_factory=set)
     def get_meter(self, name: str, version: str | None = None, schema_url: str | None = None, attributes: Attributes | None = None) -> Meter: ...
     def suppress_scopes(self, *scopes: str) -> None: ...
     def set_meter_provider(self, meter_provider: MeterProvider) -> None: ...

logfire-api/logfire_api/_internal/scrubbing.pyi

@@ -60,7 +60,7 @@ class SpanScrubber:
     This class is separate from Scrubber so that it can be instantiated more regularly
     and hold and mutate state about the span being scrubbed, specifically the scrubbed notes.
     """
-    scrubbed: Incomplete
+    scrubbed: list[ScrubbedNote]
     did_scrub: bool
     def __init__(self, parent: Scrubber) -> None: ...
     def scrub_span(self, span: ReadableSpanDict): ...

logfire-api/logfire_api/_internal/tracer.pyi

@@ -3,7 +3,7 @@ from .config import LogfireConfig as LogfireConfig
 from .constants import ATTRIBUTES_MESSAGE_KEY as ATTRIBUTES_MESSAGE_KEY, ATTRIBUTES_PENDING_SPAN_REAL_PARENT_KEY as ATTRIBUTES_PENDING_SPAN_REAL_PARENT_KEY, ATTRIBUTES_SAMPLE_RATE_KEY as ATTRIBUTES_SAMPLE_RATE_KEY, ATTRIBUTES_SPAN_TYPE_KEY as ATTRIBUTES_SPAN_TYPE_KEY, ATTRIBUTES_VALIDATION_ERROR_KEY as ATTRIBUTES_VALIDATION_ERROR_KEY, log_level_attributes as log_level_attributes
 from .utils import handle_internal_errors as handle_internal_errors
 from _typeshed import Incomplete
-from dataclasses import dataclass
+from dataclasses import dataclass, field
 from opentelemetry import context as context_api
 from opentelemetry.context import Context
 from opentelemetry.sdk.resources import Resource
@@ -23,9 +23,9 @@ class ProxyTracerProvider(TracerProvider):
     """A tracer provider that wraps another internal tracer provider allowing it to be re-assigned."""
     provider: TracerProvider
     config: LogfireConfig
-    tracers: WeakKeyDictionary[_ProxyTracer, Callable[[], Tracer]] = ...
-    lock: Lock = ...
-    suppressed_scopes: set[str] = ...
+    tracers: WeakKeyDictionary[_ProxyTracer, Callable[[], Tracer]] = field(default_factory=WeakKeyDictionary)
+    lock: Lock = field(default_factory=Lock)
+    suppressed_scopes: set[str] = field(default_factory=set)
     def set_provider(self, provider: SDKTracerProvider) -> None: ...
     def suppress_scopes(self, *scopes: str) -> None: ...
     def get_tracer(self, instrumenting_module_name: str, *args: Any, is_span_tracer: bool = True, **kwargs: Any) -> _ProxyTracer: ...

logfire-api/logfire_api/experimental/query_client.pyi

@@ -39,7 +39,7 @@ class _BaseLogfireQueryClient(Generic[T]):
     base_url: Incomplete
     read_token: Incomplete
     timeout: Incomplete
-    client: Incomplete
+    client: T
     def __init__(self, base_url: str, read_token: str, timeout: Timeout, client: type[T], **client_kwargs: Any) -> None: ...
     def build_query_params(self, sql: str, min_timestamp: datetime | None = None, max_timestamp: datetime | None = None, limit: int | None = None, row_oriented: bool = False) -> dict[str, str]: ...
     def handle_response_errors(self, response: Response) -> None: ...

logfire-api/logfire_api/sampling/_tail_sampling.pyi

@@ -81,7 +81,7 @@ def check_trace_id_ratio(trace_id: int, rate: float) -> bool: ...
 class TailSamplingProcessor(WrapperSpanProcessor):
     """Passes spans to the wrapped processor if any span in a trace meets the sampling criteria."""
     get_tail_sample_rate: Incomplete
-    traces: Incomplete
+    traces: dict[int, TraceBuffer]
     lock: Incomplete
     def __init__(self, processor: SpanProcessor, get_tail_sample_rate: Callable[[TailSamplingSpanInfo], float]) -> None: ...
     def on_start(self, span: Span, parent_context: context.Context | None = None) -> None: ...