Release v3.16.2 (#1114)

Author: alexmojaki

CHANGELOG.md

@@ -1,5 +1,12 @@
 # Release Notes
 
+## [v3.16.2] (2025-06-03)
+
+* Fixes for OpenAI Responses API and Agents SDK by @alexmojaki in [#1092](https://github.com/pydantic/logfire/pull/1092),  [#1093](https://github.com/pydantic/logfire/pull/1093), [#1094](https://github.com/pydantic/logfire/pull/1094), and [#1095](https://github.com/pydantic/logfire/pull/1095)
+* Fix verbose console formatting for enum, dates, and decimals by @sbhrwlr in [#1096](https://github.com/pydantic/logfire/pull/1096)
+* Allow setting `logfire.msg` in structlog integration by @alexmojaki in [#1113](https://github.com/pydantic/logfire/pull/1113)
+* Add ASGI instrumentation package to `django` extra by @alexmojaki in [#1097](https://github.com/pydantic/logfire/pull/1097)
+
 ## [v3.16.1] (2025-05-26)
 
 * Infer base URL from read token in query client by @Viicos in [#1088](https://github.com/pydantic/logfire/pull/1088)
@@ -706,3 +713,4 @@ First release from new repo!
 [v3.15.1]: https://github.com/pydantic/logfire/compare/v3.15.0...v3.15.1
 [v3.16.0]: https://github.com/pydantic/logfire/compare/v3.15.1...v3.16.0
 [v3.16.1]: https://github.com/pydantic/logfire/compare/v3.16.0...v3.16.1
+[v3.16.2]: https://github.com/pydantic/logfire/compare/v3.16.1...v3.16.2

logfire-api/logfire_api/_internal/collect_system_info.pyi

@@ -1,3 +1,6 @@
+from functools import lru_cache
+
+@lru_cache
 def collect_package_info() -> dict[str, str]:
     """Retrieve the package information for all installed packages.
 

logfire-api/logfire_api/_internal/formatter.pyi

@@ -6,6 +6,7 @@ from .scrubbing import BaseScrubber as BaseScrubber, NOOP_SCRUBBER as NOOP_SCRUB
 from .stack_info import warn_at_user_stacklevel as warn_at_user_stacklevel
 from .utils import log_internal_error as log_internal_error, truncate_string as truncate_string
 from _typeshed import Incomplete
+from functools import lru_cache
 from string import Formatter
 from types import CodeType as CodeType
 from typing import Any, Literal
@@ -27,6 +28,7 @@ chunks_formatter: Incomplete
 
 def logfire_format(format_string: str, kwargs: dict[str, Any], scrubber: BaseScrubber) -> str: ...
 def logfire_format_with_magic(format_string: str, kwargs: dict[str, Any], scrubber: BaseScrubber, fstring_frame: types.FrameType | None = None) -> tuple[str, dict[str, Any], str]: ...
+@lru_cache
 def compile_formatted_value(node: ast.FormattedValue, ex_source: executing.Source) -> tuple[str, CodeType, CodeType]:
     """Returns three things that can be expensive to compute.
 

logfire-api/logfire_api/_internal/integrations/fastapi.pyi

@@ -4,6 +4,7 @@ from ..utils import handle_internal_errors as handle_internal_errors, maybe_capt
 from .asgi import tweak_asgi_spans_tracer_provider as tweak_asgi_spans_tracer_provider
 from _typeshed import Incomplete
 from fastapi import FastAPI
+from functools import lru_cache
 from starlette.requests import Request
 from starlette.websockets import WebSocket
 from typing import Any, Awaitable, Callable, ContextManager, Iterable
@@ -15,6 +16,7 @@ def instrument_fastapi(logfire_instance: Logfire, app: FastAPI, *, capture_heade
 
     See `Logfire.instrument_fastapi` for more details.
     """
+@lru_cache
 def patch_fastapi():
     """Globally monkeypatch fastapi functions and return a dictionary for recording instrumentation config per app."""
 

logfire-api/logfire_api/_internal/integrations/httpx.pyi

@@ -1,8 +1,9 @@
+import contextlib
 import httpx
 from _typeshed import Incomplete
 from collections.abc import Generator
 from email.headerregistry import ContentTypeHeader
-from functools import cached_property
+from functools import cached_property, lru_cache
 from logfire import Logfire as Logfire, LogfireSpan as LogfireSpan
 from logfire._internal.main import set_user_attributes_on_raw_span as set_user_attributes_on_raw_span
 from logfire._internal.stack_info import warn_at_user_stacklevel as warn_at_user_stacklevel
@@ -54,6 +55,7 @@ class LogfireHttpxResponseInfo(ResponseInfo, LogfireHttpxInfoMixin):
     def on_response_read(self, hook: Callable[[LogfireSpan], None]): ...
     def wrap_response_read(self, hook: Callable[[Callable[[], bytes]], bytes]): ...
     def wrap_response_aread(self, hook: Callable[[Callable[[], Awaitable[bytes]]], Awaitable[bytes]]): ...
+    @contextlib.contextmanager
     def attach_original_span_context(self) -> Generator[None]: ...
     def capture_text_as_json(self, span: LogfireSpan, *, text: str, attr_name: str): ...
 
@@ -69,6 +71,8 @@ def capture_request_or_response_headers(span: Span, headers: httpx.Headers, requ
 
 CODES_FOR_METHODS_WITH_DATA_PARAM: Incomplete
 
+@lru_cache
 def content_type_header_from_string(content_type: str) -> ContentTypeHeader: ...
 def content_type_subtypes(subtype: str) -> set[str]: ...
+@lru_cache
 def is_json_type(content_type: str) -> bool: ...

logfire-api/logfire_api/_internal/integrations/openai_agents.pyi

@@ -8,6 +8,7 @@ from agents.tracing.spans import SpanError, TSpanData
 from dataclasses import dataclass
 from logfire import Logfire as Logfire, LogfireSpan as LogfireSpan
 from logfire._internal.formatter import logfire_format as logfire_format
+from logfire._internal.integrations.llm_providers.openai import inputs_to_events as inputs_to_events, responses_output_events as responses_output_events
 from logfire._internal.scrubbing import NOOP_SCRUBBER as NOOP_SCRUBBER
 from logfire._internal.utils import handle_internal_errors as handle_internal_errors, log_internal_error as log_internal_error, truncate_string as truncate_string
 from openai.types.responses import Response
@@ -55,6 +56,7 @@ class LogfireWrapperBase(Generic[T]):
 
 @dataclass
 class LogfireTraceWrapper(LogfireWrapperBase[Trace], Trace):
+    @handle_internal_errors
     def on_ending(self) -> None: ...
     token = ...
     def attach(self) -> None: ...
@@ -70,6 +72,7 @@ class LogfireSpanWrapper(LogfireWrapperBase[Span[TSpanData]], Span[TSpanData]):
     token = ...
     def attach(self) -> None: ...
     def detach(self) -> None: ...
+    @handle_internal_errors
     def on_ending(self) -> None: ...
     @property
     def trace_id(self) -> str: ...
@@ -92,5 +95,3 @@ def attributes_from_span_data(span_data: SpanData, msg_template: str) -> dict[st
 def get_basic_response_attributes(response: Response): ...
 def get_magic_response_attributes() -> dict[str, Any]: ...
 def get_response_span_events(span: ResponseSpanData): ...
-def input_to_events(inp: dict[str, Any]): ...
-def unknown_event(inp: dict[str, Any]): ...

logfire-api/logfire_api/_internal/json_encoder.pyi

@@ -1,5 +1,6 @@
 from .utils import JsonValue as JsonValue, safe_repr as safe_repr
 from _typeshed import Incomplete
+from functools import lru_cache
 from typing import Any
 
 NUMPY_DIMENSION_MAX_SIZE: int
@@ -9,4 +10,5 @@ def encoder_by_type() -> dict[type[Any], EncoderFunction]: ...
 def to_json_value(o: Any, seen: set[int]) -> JsonValue: ...
 def logfire_json_dumps(obj: Any) -> str: ...
 def is_sqlalchemy(obj: Any) -> bool: ...
+@lru_cache
 def is_attrs(cls) -> bool: ...

logfire-api/logfire_api/_internal/json_schema.pyi

@@ -1,5 +1,6 @@
 from .utils import JsonDict
 from _typeshed import Incomplete
+from functools import lru_cache
 from typing import Any
 
 __all__ = ['create_json_schema', 'attributes_json_schema_properties', 'attributes_json_schema', 'JsonSchemaProperties']

logfire-api/logfire_api/_internal/main.pyi

@@ -1062,24 +1062,28 @@ class FastLogfireSpan:
     """A simple version of `LogfireSpan` optimized for auto-tracing."""
     def __init__(self, span: trace_api.Span) -> None: ...
     def __enter__(self) -> FastLogfireSpan: ...
+    @handle_internal_errors
     def __exit__(self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: Any) -> None: ...
 
 class LogfireSpan(ReadableSpan):
     def __init__(self, span_name: str, otlp_attributes: dict[str, otel_types.AttributeValue], tracer: Tracer, json_schema_properties: JsonSchemaProperties, links: Sequence[tuple[SpanContext, otel_types.Attributes]]) -> None: ...
     def __getattr__(self, name: str) -> Any: ...
     def __enter__(self) -> LogfireSpan: ...
+    @handle_internal_errors
     def __exit__(self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: Any) -> None: ...
     @property
     def message_template(self) -> str | None: ...
     @property
     def tags(self) -> tuple[str, ...]: ...
     @tags.setter
+    @handle_internal_errors
     def tags(self, new_tags: Sequence[str]) -> None:
         """Set or add tags to the span."""
     @property
     def message(self) -> str: ...
     @message.setter
     def message(self, message: str): ...
+    @handle_internal_errors
     def set_attribute(self, key: str, value: Any) -> None:
         """Sets an attribute on the span.
 
@@ -1096,6 +1100,7 @@ class LogfireSpan(ReadableSpan):
         Delegates to the OpenTelemetry SDK `Span.record_exception` method.
         """
     def is_recording(self) -> bool: ...
+    @handle_internal_errors
     def set_level(self, level: LevelName | int):
         """Set the log level of this span."""
 

logfire-api/logfire_api/_internal/tracer.pyi

@@ -96,6 +96,7 @@ def should_sample(span_context: SpanContext, attributes: Mapping[str, otel_types
     This is used to sample spans that are not sampled by the OTEL sampler.
     """
 def get_sample_rate_from_attributes(attributes: otel_types.Attributes) -> float | None: ...
+@handle_internal_errors
 def record_exception(span: trace_api.Span, exception: BaseException, *, attributes: otel_types.Attributes = None, timestamp: int | None = None, escaped: bool = False) -> None:
     """Similar to the OTEL SDK Span.record_exception method, with our own additions."""
 def set_exception_status(span: trace_api.Span, exception: BaseException): ...

logfire-api/logfire_api/_internal/utils.pyi

@@ -1,5 +1,6 @@
 from _typeshed import Incomplete
 from collections.abc import Generator
+from contextlib import contextmanager
 from dataclasses import dataclass
 from logfire._internal.stack_info import is_user_code as is_user_code
 from logfire._internal.ulid import ulid as ulid
@@ -86,6 +87,7 @@ def is_instrumentation_suppressed() -> bool:
 
     This means that any logs/spans generated by logfire or OpenTelemetry will not be logged in any way.
     """
+@contextmanager
 def suppress_instrumentation() -> Generator[None]:
     """Context manager to suppress all logs/spans generated by logfire or OpenTelemetry."""
 def log_internal_error() -> None: ...

logfire-api/logfire_api/propagate.pyi

@@ -1,3 +1,4 @@
+from contextlib import contextmanager
 from dataclasses import dataclass
 from opentelemetry import context as otel_context
 from opentelemetry.propagators.textmap import TextMapPropagator
@@ -37,6 +38,7 @@ def get_context() -> ContextCarrier:
     ...
     ```
     """
+@contextmanager
 def attach_context(carrier: ContextCarrier, *, third_party: bool = False, propagator: TextMapPropagator | None = None) -> Iterator[None]:
     """Attach a context as generated by [`get_context`][logfire.propagate.get_context] to the current execution context.
 

logfire-api/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "logfire-api"
-version = "3.16.1"
+version = "3.16.2"
 description = "Shim for the Logfire SDK which does nothing unless Logfire is installed"
 authors = [
     { name = "Pydantic Team", email = "[email protected]" },

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "logfire"
-version = "3.16.1"
+version = "3.16.2"
 description = "The best Python observability tool! 🪵🔥"
 requires-python = ">=3.8"
 authors = [