release: 0.43.1

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.43.0"
+  ".": "0.43.1"
 }

CHANGELOG.md

@@ -1,5 +1,21 @@
 # Changelog
 
+## 0.43.1 (2025-01-17)
+
+Full Changelog: [v0.43.0...v0.43.1](https://github.com/anthropics/anthropic-sdk-python/compare/v0.43.0...v0.43.1)
+
+### Bug Fixes
+
+* **docs:** correct results return type ([69ad511](https://github.com/anthropics/anthropic-sdk-python/commit/69ad5112596f6e9aaf5cd2d495cb57516f2afbd4))
+
+
+### Chores
+
+* **internal:** bump pyright dependency ([#822](https://github.com/anthropics/anthropic-sdk-python/issues/822)) ([f8ddb90](https://github.com/anthropics/anthropic-sdk-python/commit/f8ddb90112a432a750fd4123c747ca581cff54ab))
+* **internal:** fix lint ([483cc27](https://github.com/anthropics/anthropic-sdk-python/commit/483cc277b66cb5b1a767e9d91347f22bcf69dc28))
+* **streaming:** add runtime type check for better error messages ([#826](https://github.com/anthropics/anthropic-sdk-python/issues/826)) ([cf69e09](https://github.com/anthropics/anthropic-sdk-python/commit/cf69e091d230aa0befb6ace74e64357b1cf2e4cd))
+* **types:** add more discriminator metadata ([#825](https://github.com/anthropics/anthropic-sdk-python/issues/825)) ([d0de8e5](https://github.com/anthropics/anthropic-sdk-python/commit/d0de8e564038cc6f801dc663b1938ac571ab47be))
+
 ## 0.43.0 (2025-01-14)
 
 Full Changelog: [v0.42.0...v0.43.0](https://github.com/anthropics/anthropic-sdk-python/compare/v0.42.0...v0.43.0)

api.md

@@ -95,7 +95,7 @@ Methods:
 - <code title="get /v1/messages/batches">client.messages.batches.<a href="./src/anthropic/resources/messages/batches.py">list</a>(\*\*<a href="src/anthropic/types/messages/batch_list_params.py">params</a>) -> <a href="./src/anthropic/types/messages/message_batch.py">SyncPage[MessageBatch]</a></code>
 - <code title="delete /v1/messages/batches/{message_batch_id}">client.messages.batches.<a href="./src/anthropic/resources/messages/batches.py">delete</a>(message_batch_id) -> <a href="./src/anthropic/types/messages/deleted_message_batch.py">DeletedMessageBatch</a></code>
 - <code title="post /v1/messages/batches/{message_batch_id}/cancel">client.messages.batches.<a href="./src/anthropic/resources/messages/batches.py">cancel</a>(message_batch_id) -> <a href="./src/anthropic/types/messages/message_batch.py">MessageBatch</a></code>
-- <code title="get /v1/messages/batches/{message_batch_id}/results">client.messages.batches.<a href="./src/anthropic/resources/messages/batches.py">results</a>(message_batch_id) -> BinaryAPIResponse</code>
+- <code title="get /v1/messages/batches/{message_batch_id}/results">client.messages.batches.<a href="./src/anthropic/resources/messages/batches.py">results</a>(message_batch_id) -> JSONLDecoder[MessageBatchIndividualResponse]</code>
 
 # Models
 
@@ -218,4 +218,4 @@ Methods:
 - <code title="get /v1/messages/batches?beta=true">client.beta.messages.batches.<a href="./src/anthropic/resources/beta/messages/batches.py">list</a>(\*\*<a href="src/anthropic/types/beta/messages/batch_list_params.py">params</a>) -> <a href="./src/anthropic/types/beta/messages/beta_message_batch.py">SyncPage[BetaMessageBatch]</a></code>
 - <code title="delete /v1/messages/batches/{message_batch_id}?beta=true">client.beta.messages.batches.<a href="./src/anthropic/resources/beta/messages/batches.py">delete</a>(message_batch_id) -> <a href="./src/anthropic/types/beta/messages/beta_deleted_message_batch.py">BetaDeletedMessageBatch</a></code>
 - <code title="post /v1/messages/batches/{message_batch_id}/cancel?beta=true">client.beta.messages.batches.<a href="./src/anthropic/resources/beta/messages/batches.py">cancel</a>(message_batch_id) -> <a href="./src/anthropic/types/beta/messages/beta_message_batch.py">BetaMessageBatch</a></code>
-- <code title="get /v1/messages/batches/{message_batch_id}/results?beta=true">client.beta.messages.batches.<a href="./src/anthropic/resources/beta/messages/batches.py">results</a>(message_batch_id) -> BinaryAPIResponse</code>
+- <code title="get /v1/messages/batches/{message_batch_id}/results?beta=true">client.beta.messages.batches.<a href="./src/anthropic/resources/beta/messages/batches.py">results</a>(message_batch_id) -> JSONLDecoder[MessageBatchIndividualResponse]</code>

pyproject.toml

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

requirements-dev.lock

@@ -91,7 +91,7 @@ pydantic-core==2.27.1
     # via pydantic
 pygments==2.18.0
     # via rich
-pyright==1.1.391
+pyright==1.1.392.post0
 pytest==8.3.3
     # via pytest-asyncio
 pytest-asyncio==0.24.0

src/anthropic/_legacy_response.py

@@ -294,7 +294,9 @@ def _parse(self, *, to: type[_T] | None = None) -> R | _T:
         if origin == LegacyAPIResponse:
             raise RuntimeError("Unexpected state - cast_to is `APIResponse`")
 
-        if inspect.isclass(origin) and issubclass(origin, httpx.Response):
+        if inspect.isclass(
+            origin  # pyright: ignore[reportUnknownArgumentType]
+        ) and issubclass(origin, httpx.Response):
             # Because of the invariance of our ResponseT TypeVar, users can subclass httpx.Response
             # and pass that class to our request functions. We cannot change the variance to be either
             # covariant or contravariant as that makes our usage of ResponseT illegal. We could construct
@@ -304,7 +306,13 @@ def _parse(self, *, to: type[_T] | None = None) -> R | _T:
                 raise ValueError(f"Subclasses of httpx.Response cannot be passed to `cast_to`")
             return cast(R, response)
 
-        if inspect.isclass(origin) and not issubclass(origin, BaseModel) and issubclass(origin, pydantic.BaseModel):
+        if (
+            inspect.isclass(
+                origin  # pyright: ignore[reportUnknownArgumentType]
+            )
+            and not issubclass(origin, BaseModel)
+            and issubclass(origin, pydantic.BaseModel)
+        ):
             raise TypeError("Pydantic models must subclass our base model type, e.g. `from anthropic import BaseModel`")
 
         if (

src/anthropic/_response.py

@@ -226,7 +226,9 @@ def _parse(self, *, to: type[_T] | None = None) -> R | _T:
         if origin == APIResponse:
             raise RuntimeError("Unexpected state - cast_to is `APIResponse`")
 
-        if inspect.isclass(origin) and issubclass(origin, httpx.Response):
+        if inspect.isclass(
+            origin  # pyright: ignore[reportUnknownArgumentType]
+        ) and issubclass(origin, httpx.Response):
             # Because of the invariance of our ResponseT TypeVar, users can subclass httpx.Response
             # and pass that class to our request functions. We cannot change the variance to be either
             # covariant or contravariant as that makes our usage of ResponseT illegal. We could construct
@@ -236,7 +238,13 @@ def _parse(self, *, to: type[_T] | None = None) -> R | _T:
                 raise ValueError(f"Subclasses of httpx.Response cannot be passed to `cast_to`")
             return cast(R, response)
 
-        if inspect.isclass(origin) and not issubclass(origin, BaseModel) and issubclass(origin, pydantic.BaseModel):
+        if (
+            inspect.isclass(
+                origin  # pyright: ignore[reportUnknownArgumentType]
+            )
+            and not issubclass(origin, BaseModel)
+            and issubclass(origin, pydantic.BaseModel)
+        ):
             raise TypeError("Pydantic models must subclass our base model type, e.g. `from anthropic import BaseModel`")
 
         if (

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.43.0"  # x-release-please-version
+__version__ = "0.43.1"  # x-release-please-version

src/anthropic/lib/streaming/_beta_types.py

@@ -1,5 +1,5 @@
 from typing import Union
-from typing_extensions import Literal
+from typing_extensions import Literal, Annotated
 
 from ..._models import BaseModel
 from ...types.beta import (
@@ -12,6 +12,7 @@
     BetaRawContentBlockDeltaEvent,
     BetaRawContentBlockStartEvent,
 )
+from ..._utils._transform import PropertyInfo
 
 
 class BetaTextEvent(BaseModel):
@@ -53,13 +54,16 @@ class BetaContentBlockStopEvent(BetaRawContentBlockStopEvent):
     content_block: BetaContentBlock
 
 
-BetaMessageStreamEvent = Union[
-    BetaTextEvent,
-    BetaInputJsonEvent,
-    BetaRawMessageStartEvent,
-    BetaRawMessageDeltaEvent,
-    BetaMessageStopEvent,
-    BetaRawContentBlockStartEvent,
-    BetaRawContentBlockDeltaEvent,
-    BetaContentBlockStopEvent,
+BetaMessageStreamEvent = Annotated[
+    Union[
+        BetaTextEvent,
+        BetaInputJsonEvent,
+        BetaRawMessageStartEvent,
+        BetaRawMessageDeltaEvent,
+        BetaMessageStopEvent,
+        BetaRawContentBlockStartEvent,
+        BetaRawContentBlockDeltaEvent,
+        BetaContentBlockStopEvent,
+    ],
+    PropertyInfo(discriminator="type"),
 ]

src/anthropic/lib/streaming/_messages.py

@@ -5,6 +5,7 @@
 from typing_extensions import Self, Iterator, Awaitable, AsyncIterator, assert_never
 
 import httpx
+from pydantic import BaseModel
 
 from ._types import (
     TextEvent,
@@ -346,6 +347,9 @@ 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 current_snapshot is None:
         if event.type == "message_start":
             return Message.construct(**cast(Any, event.message.to_dict()))

src/anthropic/lib/streaming/_types.py

@@ -1,5 +1,5 @@
 from typing import Union
-from typing_extensions import Literal
+from typing_extensions import Literal, Annotated
 
 from ...types import (
     Message,
@@ -12,6 +12,7 @@
     RawContentBlockStopEvent,
 )
 from ..._models import BaseModel
+from ..._utils._transform import PropertyInfo
 
 
 class TextEvent(BaseModel):
@@ -53,13 +54,16 @@ class ContentBlockStopEvent(RawContentBlockStopEvent):
     content_block: ContentBlock
 
 
-MessageStreamEvent = Union[
-    TextEvent,
-    InputJsonEvent,
-    RawMessageStartEvent,
-    RawMessageDeltaEvent,
-    MessageStopEvent,
-    RawContentBlockStartEvent,
-    RawContentBlockDeltaEvent,
-    ContentBlockStopEvent,
+MessageStreamEvent = Annotated[
+    Union[
+        TextEvent,
+        InputJsonEvent,
+        RawMessageStartEvent,
+        RawMessageDeltaEvent,
+        MessageStopEvent,
+        RawContentBlockStartEvent,
+        RawContentBlockDeltaEvent,
+        ContentBlockStopEvent,
+    ],
+    PropertyInfo(discriminator="type"),
 ]

src/anthropic/resources/beta/messages/messages.py

@@ -983,7 +983,6 @@ def stream(
             stream_cls=Stream[BetaRawMessageStreamEvent],
         )
         return BetaMessageStreamManager(make_request)
-
 
     def count_tokens(
         self,

src/anthropic/types/tool_param.py

@@ -16,6 +16,7 @@ class InputSchemaTyped(TypedDict, total=False):
 
     properties: Optional[object]
 
+
 set_pydantic_config(InputSchemaTyped, {"extra": "allow"})
 
 InputSchema: TypeAlias = Union[InputSchemaTyped, Dict[str, object]]