release: 0.45.2

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.45.1"
+  ".": "0.45.2"
 }

CHANGELOG.md

@@ -1,5 +1,13 @@
 # Changelog
 
+## 0.45.2 (2025-01-27)
+
+Full Changelog: [v0.45.1...v0.45.2](https://github.com/anthropics/anthropic-sdk-python/compare/v0.45.1...v0.45.2)
+
+### Bug Fixes
+
+* **streaming:** avoid invalid deser type error ([#845](https://github.com/anthropics/anthropic-sdk-python/issues/845)) ([72a2585](https://github.com/anthropics/anthropic-sdk-python/commit/72a2585680a4cc5d007bf93935424dbc4cecf2bd))
+
 ## 0.45.1 (2025-01-27)
 
 Full Changelog: [v0.45.0...v0.45.1](https://github.com/anthropics/anthropic-sdk-python/compare/v0.45.0...v0.45.1)

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "anthropic"
-version = "0.45.1"
+version = "0.45.2"
 description = "The official Python library for the anthropic API"
 dynamic = ["readme"]
 license = "MIT"

src/anthropic/_version.py

@@ -1,4 +1,4 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
 __title__ = "anthropic"
-__version__ = "0.45.1"  # x-release-please-version
+__version__ = "0.45.2"  # x-release-please-version

src/anthropic/lib/streaming/_beta_messages.py

@@ -1,14 +1,14 @@
 from __future__ import annotations
 
 from types import TracebackType
-from typing import TYPE_CHECKING, Any, Callable, cast
+from typing import TYPE_CHECKING, Any, Type, Callable, cast
 from typing_extensions import Self, Iterator, Awaitable, AsyncIterator, assert_never
 
 import httpx
 from pydantic import BaseModel
 
 from ..._utils import consume_sync_iterator, consume_async_iterator
-from ..._models import build, construct_type
+from ..._models import build, construct_type, construct_type_unchecked
 from ._beta_types import (
     BetaTextEvent,
     BetaCitationEvent,
@@ -372,8 +372,16 @@ def accumulate_event(
     event: BetaRawMessageStreamEvent,
     current_snapshot: BetaMessage | None,
 ) -> BetaMessage:
-    if not isinstance(event, BaseModel):  # pyright: ignore[reportUnnecessaryIsInstance]
-        raise TypeError(f"Unexpected event runtime type - {event}")
+    if not isinstance(cast(Any, event), BaseModel):
+        event = cast(  # pyright: ignore[reportUnnecessaryCast]
+            BetaRawMessageStreamEvent,
+            construct_type_unchecked(
+                type_=cast(Type[BetaRawMessageStreamEvent], BetaRawMessageStreamEvent),
+                value=event,
+            ),
+        )
+        if not isinstance(cast(Any, event), BaseModel):
+            raise TypeError(f"Unexpected event runtime type, after deserialising twice - {event} - {type(event)}")
 
     if current_snapshot is None:
         if event.type == "message_start":

src/anthropic/lib/streaming/_messages.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 from types import TracebackType
-from typing import TYPE_CHECKING, Any, Callable, cast
+from typing import TYPE_CHECKING, Any, Type, Callable, cast
 from typing_extensions import Self, Iterator, Awaitable, AsyncIterator, assert_never
 
 import httpx
@@ -17,7 +17,7 @@
 )
 from ...types import Message, ContentBlock, RawMessageStreamEvent
 from ..._utils import consume_sync_iterator, consume_async_iterator
-from ..._models import build, construct_type
+from ..._models import build, construct_type, construct_type_unchecked
 from ..._streaming import Stream, AsyncStream
 
 
@@ -372,8 +372,16 @@ def accumulate_event(
     event: RawMessageStreamEvent,
     current_snapshot: Message | None,
 ) -> Message:
-    if not isinstance(event, BaseModel):  # pyright: ignore[reportUnnecessaryIsInstance]
-        raise TypeError(f"Unexpected event runtime type - {event}")
+    if not isinstance(cast(Any, event), BaseModel):
+        event = cast(  # pyright: ignore[reportUnnecessaryCast]
+            RawMessageStreamEvent,
+            construct_type_unchecked(
+                type_=cast(Type[RawMessageStreamEvent], RawMessageStreamEvent),
+                value=event,
+            ),
+        )
+        if not isinstance(cast(Any, event), BaseModel):
+            raise TypeError(f"Unexpected event runtime type, after deserialising twice - {event} - {type(event)}")
 
     if current_snapshot is None:
         if event.type == "message_start":