SDK regeneration

Author: fern-api[bot]

.fern/metadata.json

@@ -1,7 +1,7 @@
 {
   "cliVersion": "4.4.1",
   "generatorName": "fernapi/fern-python-sdk",
-  "generatorVersion": "4.57.2",
+  "generatorVersion": "4.61.4",
   "generatorConfig": {
     "client": {
       "class_name": "BaseClient",

src/deepgram/agent/v1/socket_client.py

@@ -1,6 +1,7 @@
 # This file was auto-generated by Fern from our API Definition.
 
 import json
+import logging
 import typing
 from json.decoder import JSONDecodeError
 
@@ -37,6 +38,7 @@
 except ImportError:
     from websockets import WebSocketClientProtocol  # type: ignore
 
+_logger = logging.getLogger(__name__)
 V1SocketClientResponse = typing.Union[
     AgentV1ReceiveFunctionCallResponse,
     AgentV1PromptUpdated,
@@ -67,7 +69,13 @@ async def __aiter__(self):
             if isinstance(message, bytes):
                 yield message
             else:
-                yield parse_obj_as(V1SocketClientResponse, json.loads(message))  # type: ignore
+                try:
+                    yield parse_obj_as(V1SocketClientResponse, json.loads(message))  # type: ignore
+                except Exception:
+                    _logger.warning(
+                        "Skipping unknown WebSocket message; update your SDK version to support new message types."
+                    )
+                    continue
 
     async def start_listening(self):
         """
@@ -86,7 +94,13 @@ async def start_listening(self):
                     parsed = raw_message
                 else:
                     json_data = json.loads(raw_message)
-                    parsed = parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+                    try:
+                        parsed = parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+                    except Exception:
+                        _logger.warning(
+                            "Skipping unknown WebSocket message; update your SDK version to support new message types."
+                        )
+                        continue
                 await self._emit_async(EventType.MESSAGE, parsed)
         except (websockets.WebSocketException, JSONDecodeError) as exc:
             await self._emit_async(EventType.ERROR, exc)
@@ -164,7 +178,11 @@ async def recv(self) -> V1SocketClientResponse:
         if isinstance(data, bytes):
             return data  # type: ignore
         json_data = json.loads(data)
-        return parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+        try:
+            return parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+        except Exception:
+            _logger.warning("Skipping unknown WebSocket message; update your SDK version to support new message types.")
+            return json_data  # type: ignore
 
     async def _send(self, data: typing.Any) -> None:
         """
@@ -191,7 +209,13 @@ def __iter__(self):
             if isinstance(message, bytes):
                 yield message
             else:
-                yield parse_obj_as(V1SocketClientResponse, json.loads(message))  # type: ignore
+                try:
+                    yield parse_obj_as(V1SocketClientResponse, json.loads(message))  # type: ignore
+                except Exception:
+                    _logger.warning(
+                        "Skipping unknown WebSocket message; update your SDK version to support new message types."
+                    )
+                    continue
 
     def start_listening(self):
         """
@@ -210,7 +234,13 @@ def start_listening(self):
                     parsed = raw_message
                 else:
                     json_data = json.loads(raw_message)
-                    parsed = parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+                    try:
+                        parsed = parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+                    except Exception:
+                        _logger.warning(
+                            "Skipping unknown WebSocket message; update your SDK version to support new message types."
+                        )
+                        continue
                 self._emit(EventType.MESSAGE, parsed)
         except (websockets.WebSocketException, JSONDecodeError) as exc:
             self._emit(EventType.ERROR, exc)
@@ -288,7 +318,11 @@ def recv(self) -> V1SocketClientResponse:
         if isinstance(data, bytes):
             return data  # type: ignore
         json_data = json.loads(data)
-        return parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+        try:
+            return parse_obj_as(V1SocketClientResponse, json_data)  # type: ignore
+        except Exception:
+            _logger.warning("Skipping unknown WebSocket message; update your SDK version to support new message types.")
+            return json_data  # type: ignore
 
     def _send(self, data: typing.Any) -> None:
         """

src/deepgram/base_client.py

@@ -8,6 +8,7 @@
 import httpx
 from .core.api_error import ApiError
 from .core.client_wrapper import AsyncClientWrapper, SyncClientWrapper
+from .core.logging import LogConfig, Logger
 from .environment import DeepgramClientEnvironment
 
 if typing.TYPE_CHECKING:
@@ -48,6 +49,9 @@ class BaseClient:
     httpx_client : typing.Optional[httpx.Client]
         The httpx client to use for making requests, a preconfigured client is used by default, however this is useful should you want to pass in any custom httpx configuration.
 
+    logging : typing.Optional[typing.Union[LogConfig, Logger]]
+        Configure logging for the SDK. Accepts a LogConfig dict with 'level' (debug/info/warn/error), 'logger' (custom logger implementation), and 'silent' (boolean, defaults to True) fields. You can also pass a pre-configured Logger instance.
+
     Examples
     --------
     from deepgram import DeepgramClient
@@ -66,6 +70,7 @@ def __init__(
         timeout: typing.Optional[float] = None,
         follow_redirects: typing.Optional[bool] = True,
         httpx_client: typing.Optional[httpx.Client] = None,
+        logging: typing.Optional[typing.Union[LogConfig, Logger]] = None,
     ):
         _defaulted_timeout = (
             timeout if timeout is not None else 60 if httpx_client is None else httpx_client.timeout.read
@@ -84,6 +89,7 @@ def __init__(
             if follow_redirects is not None
             else httpx.Client(timeout=_defaulted_timeout),
             timeout=_defaulted_timeout,
+            logging=logging,
         )
         self._agent: typing.Optional[AgentClient] = None
         self._auth: typing.Optional[AuthClient] = None
@@ -178,6 +184,9 @@ class AsyncBaseClient:
     httpx_client : typing.Optional[httpx.AsyncClient]
         The httpx client to use for making requests, a preconfigured client is used by default, however this is useful should you want to pass in any custom httpx configuration.
 
+    logging : typing.Optional[typing.Union[LogConfig, Logger]]
+        Configure logging for the SDK. Accepts a LogConfig dict with 'level' (debug/info/warn/error), 'logger' (custom logger implementation), and 'silent' (boolean, defaults to True) fields. You can also pass a pre-configured Logger instance.
+
     Examples
     --------
     from deepgram import AsyncDeepgramClient
@@ -196,6 +205,7 @@ def __init__(
         timeout: typing.Optional[float] = None,
         follow_redirects: typing.Optional[bool] = True,
         httpx_client: typing.Optional[httpx.AsyncClient] = None,
+        logging: typing.Optional[typing.Union[LogConfig, Logger]] = None,
     ):
         _defaulted_timeout = (
             timeout if timeout is not None else 60 if httpx_client is None else httpx_client.timeout.read
@@ -214,6 +224,7 @@ def __init__(
             if follow_redirects is not None
             else httpx.AsyncClient(timeout=_defaulted_timeout),
             timeout=_defaulted_timeout,
+            logging=logging,
         )
         self._agent: typing.Optional[AsyncAgentClient] = None
         self._auth: typing.Optional[AsyncAuthClient] = None

src/deepgram/core/__init__.py

@@ -8,12 +8,13 @@
 if typing.TYPE_CHECKING:
     from .api_error import ApiError
     from .client_wrapper import AsyncClientWrapper, BaseClientWrapper, SyncClientWrapper
-    from .datetime_utils import serialize_datetime
+    from .datetime_utils import Rfc2822DateTime, parse_rfc2822_datetime, serialize_datetime
     from .events import EventEmitterMixin, EventType
     from .file import File, convert_file_dict_to_httpx_tuples, with_content_type
     from .http_client import AsyncHttpClient, HttpClient
     from .http_response import AsyncHttpResponse, HttpResponse
     from .jsonable_encoder import jsonable_encoder
+    from .logging import ConsoleLogger, ILogger, LogConfig, LogLevel, Logger, create_logger
     from .pydantic_utilities import (
         IS_PYDANTIC_V2,
         UniversalBaseModel,
@@ -35,15 +36,21 @@
     "AsyncHttpClient": ".http_client",
     "AsyncHttpResponse": ".http_response",
     "BaseClientWrapper": ".client_wrapper",
+    "ConsoleLogger": ".logging",
     "EventEmitterMixin": ".events",
     "EventType": ".events",
     "FieldMetadata": ".serialization",
     "File": ".file",
     "HttpClient": ".http_client",
     "HttpResponse": ".http_response",
+    "ILogger": ".logging",
     "IS_PYDANTIC_V2": ".pydantic_utilities",
     "InvalidWebSocketStatus": ".websocket_compat",
+    "LogConfig": ".logging",
+    "LogLevel": ".logging",
+    "Logger": ".logging",
     "RequestOptions": ".request_options",
+    "Rfc2822DateTime": ".datetime_utils",
     "SyncClientWrapper": ".client_wrapper",
     "UncheckedBaseModel": ".unchecked_base_model",
     "UnionMetadata": ".unchecked_base_model",
@@ -52,10 +59,12 @@
     "construct_type": ".unchecked_base_model",
     "convert_and_respect_annotation_metadata": ".serialization",
     "convert_file_dict_to_httpx_tuples": ".file",
+    "create_logger": ".logging",
     "encode_query": ".query_encoder",
     "get_status_code": ".websocket_compat",
     "jsonable_encoder": ".jsonable_encoder",
     "parse_obj_as": ".pydantic_utilities",
+    "parse_rfc2822_datetime": ".datetime_utils",
     "remove_none_from_dict": ".remove_none_from_dict",
     "serialize_datetime": ".datetime_utils",
     "universal_field_validator": ".pydantic_utilities",
@@ -92,15 +101,21 @@ def __dir__():
     "AsyncHttpClient",
     "AsyncHttpResponse",
     "BaseClientWrapper",
+    "ConsoleLogger",
     "EventEmitterMixin",
     "EventType",
     "FieldMetadata",
     "File",
     "HttpClient",
     "HttpResponse",
+    "ILogger",
     "IS_PYDANTIC_V2",
     "InvalidWebSocketStatus",
+    "LogConfig",
+    "LogLevel",
+    "Logger",
     "RequestOptions",
+    "Rfc2822DateTime",
     "SyncClientWrapper",
     "UncheckedBaseModel",
     "UnionMetadata",
@@ -109,10 +124,12 @@ def __dir__():
     "construct_type",
     "convert_and_respect_annotation_metadata",
     "convert_file_dict_to_httpx_tuples",
+    "create_logger",
     "encode_query",
     "get_status_code",
     "jsonable_encoder",
     "parse_obj_as",
+    "parse_rfc2822_datetime",
     "remove_none_from_dict",
     "serialize_datetime",
     "universal_field_validator",

src/deepgram/core/client_wrapper.py

@@ -5,6 +5,7 @@
 import httpx
 from ..environment import DeepgramClientEnvironment
 from .http_client import AsyncHttpClient, HttpClient
+from .logging import LogConfig, Logger
 
 
 class BaseClientWrapper:
@@ -15,11 +16,13 @@ def __init__(
         headers: typing.Optional[typing.Dict[str, str]] = None,
         environment: DeepgramClientEnvironment,
         timeout: typing.Optional[float] = None,
+        logging: typing.Optional[typing.Union[LogConfig, Logger]] = None,
     ):
         self.api_key = api_key
         self._headers = headers
         self._environment = environment
         self._timeout = timeout
+        self._logging = logging
 
     def get_headers(self) -> typing.Dict[str, str]:
         import platform
@@ -54,11 +57,15 @@ def __init__(
         headers: typing.Optional[typing.Dict[str, str]] = None,
         environment: DeepgramClientEnvironment,
         timeout: typing.Optional[float] = None,
+        logging: typing.Optional[typing.Union[LogConfig, Logger]] = None,
         httpx_client: httpx.Client,
     ):
-        super().__init__(api_key=api_key, headers=headers, environment=environment, timeout=timeout)
+        super().__init__(api_key=api_key, headers=headers, environment=environment, timeout=timeout, logging=logging)
         self.httpx_client = HttpClient(
-            httpx_client=httpx_client, base_headers=self.get_headers, base_timeout=self.get_timeout
+            httpx_client=httpx_client,
+            base_headers=self.get_headers,
+            base_timeout=self.get_timeout,
+            logging_config=self._logging,
         )
 
 
@@ -70,16 +77,18 @@ def __init__(
         headers: typing.Optional[typing.Dict[str, str]] = None,
         environment: DeepgramClientEnvironment,
         timeout: typing.Optional[float] = None,
+        logging: typing.Optional[typing.Union[LogConfig, Logger]] = None,
         async_token: typing.Optional[typing.Callable[[], typing.Awaitable[str]]] = None,
         httpx_client: httpx.AsyncClient,
     ):
-        super().__init__(api_key=api_key, headers=headers, environment=environment, timeout=timeout)
+        super().__init__(api_key=api_key, headers=headers, environment=environment, timeout=timeout, logging=logging)
         self._async_token = async_token
         self.httpx_client = AsyncHttpClient(
             httpx_client=httpx_client,
             base_headers=self.get_headers,
             base_timeout=self.get_timeout,
             async_base_headers=self.async_get_headers,
+            logging_config=self._logging,
         )
 
     async def async_get_headers(self) -> typing.Dict[str, str]:

src/deepgram/core/datetime_utils.py

@@ -1,6 +1,48 @@
 # This file was auto-generated by Fern from our API Definition.
 
 import datetime as dt
+from email.utils import parsedate_to_datetime
+from typing import Any
+
+import pydantic
+
+IS_PYDANTIC_V2 = pydantic.VERSION.startswith("2.")
+
+
+def parse_rfc2822_datetime(v: Any) -> dt.datetime:
+    """
+    Parse an RFC 2822 datetime string (e.g., "Wed, 02 Oct 2002 13:00:00 GMT")
+    into a datetime object. If the value is already a datetime, return it as-is.
+    Falls back to ISO 8601 parsing if RFC 2822 parsing fails.
+    """
+    if isinstance(v, dt.datetime):
+        return v
+    if isinstance(v, str):
+        try:
+            return parsedate_to_datetime(v)
+        except Exception:
+            pass
+        # Fallback to ISO 8601 parsing
+        return dt.datetime.fromisoformat(v.replace("Z", "+00:00"))
+    raise ValueError(f"Expected str or datetime, got {type(v)}")
+
+
+class Rfc2822DateTime(dt.datetime):
+    """A datetime subclass that parses RFC 2822 date strings.
+
+    On Pydantic V1, uses __get_validators__ for pre-validation.
+    On Pydantic V2, uses __get_pydantic_core_schema__ for BeforeValidator-style parsing.
+    """
+
+    @classmethod
+    def __get_validators__(cls):  # type: ignore[no-untyped-def]
+        yield parse_rfc2822_datetime
+
+    @classmethod
+    def __get_pydantic_core_schema__(cls, _source_type: Any, _handler: Any) -> Any:  # type: ignore[override]
+        from pydantic_core import core_schema
+
+        return core_schema.no_info_before_validator_function(parse_rfc2822_datetime, core_schema.datetime_schema())
 
 
 def serialize_datetime(v: dt.datetime) -> str: