Merge pull request #970 from anthropics/release-please--branches--main--changes--next

release: 0.54.0

Author: michael-cohen-io

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.53.0"
+  ".": "0.54.0"
 }

CHANGELOG.md

@@ -1,5 +1,29 @@
 # Changelog
 
+## 0.54.0 (2025-06-10)
+
+Full Changelog: [v0.53.0...v0.54.0](https://github.com/anthropics/anthropic-sdk-python/compare/v0.53.0...v0.54.0)
+
+### Features
+
+* **client:** add support for fine-grained-tool-streaming-2025-05-14 ([07ec081](https://github.com/anthropics/anthropic-sdk-python/commit/07ec08119dbc328934fea5ec6eacd00c8dbda089))
+
+
+### Bug Fixes
+
+* **httpx:** resolve conflict between default transport and proxy settings ([#969](https://github.com/anthropics/anthropic-sdk-python/issues/969)) ([a6efded](https://github.com/anthropics/anthropic-sdk-python/commit/a6efdedcfef881ae3466bb77d92d0338c8338e20))
+* **tests:** update test ([99c2433](https://github.com/anthropics/anthropic-sdk-python/commit/99c243363e94f5f3f627cb8b80e3f238503c89f5))
+
+
+### Chores
+
+* **internal:** version bump ([45029f4](https://github.com/anthropics/anthropic-sdk-python/commit/45029f41c96f62f26ead99a5989c9ad974fc21b9))
+
+
+### Documentation
+
+* **contributing:** fix uv script for bootstrapping ([d2bde52](https://github.com/anthropics/anthropic-sdk-python/commit/d2bde52286ee8fa65995e73c579a8962087c1da4))
+
 ## 0.53.0 (2025-06-09)
 
 Full Changelog: [v0.52.2...v0.53.0](https://github.com/anthropics/anthropic-sdk-python/compare/v0.52.2...v0.53.0)

CONTRIBUTING.md

@@ -11,7 +11,7 @@ $ ./scripts/bootstrap
 Or [install uv manually](https://docs.astral.sh/uv/getting-started/installation/) and run:
 
 ```sh
-$ uv sync
+$ uv sync --all-extras
 ```
 
 You can then run scripts using `uv run python script.py` or by manually activating the virtual environment:

pyproject.toml

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

src/anthropic/_base_client.py

@@ -38,7 +38,7 @@
 import httpx
 import distro
 import pydantic
-from httpx import URL
+from httpx import URL, Proxy, HTTPTransport, AsyncHTTPTransport
 from pydantic import PrivateAttr
 
 from . import _exceptions
@@ -86,6 +86,7 @@
     APIConnectionError,
     APIResponseValidationError,
 )
+from ._utils._httpx import get_environment_proxies
 from ._legacy_response import LegacyAPIResponse
 
 log: logging.Logger = logging.getLogger(__name__)
@@ -826,11 +827,24 @@ def __init__(self, **kwargs: Any) -> None:
             if TCP_KEEPIDLE is not None:
                 socket_options.append((socket.IPPROTO_TCP, TCP_KEEPIDLE, 60))
 
-            kwargs["transport"] = httpx.HTTPTransport(
-                # note: limits is always set above
-                limits=kwargs["limits"],
-                socket_options=socket_options,
-            )
+            proxy_map = {key: None if url is None else Proxy(url=url) for key, url in get_environment_proxies().items()}
+
+            transport_kwargs = {
+                arg: kwargs[arg] for arg in ("verify", "cert", "trust_env", "http1", "http2", "limits") if arg in kwargs
+            }
+
+            proxy_mounts = {
+                key: None if proxy is None else HTTPTransport(proxy=proxy, **transport_kwargs)
+                for key, proxy in proxy_map.items()
+            }
+            default_transport = HTTPTransport(**transport_kwargs)
+
+            # Prioritize the mounts set by the user over the environment variables.
+            proxy_mounts.update(kwargs.get("mounts", {}))
+            kwargs["mounts"] = proxy_mounts
+
+            # Sets the default transport so that HTTPX won't automatically configure proxies.
+            kwargs["transport"] = kwargs.get("transport", default_transport)
 
         super().__init__(**kwargs)
 
@@ -1367,11 +1381,24 @@ def __init__(self, **kwargs: Any) -> None:
             if TCP_KEEPIDLE is not None:
                 socket_options.append((socket.IPPROTO_TCP, TCP_KEEPIDLE, 60))
 
-            kwargs["transport"] = httpx.AsyncHTTPTransport(
-                # note: limits is always set above
-                limits=kwargs["limits"],
-                socket_options=socket_options,
-            )
+            proxy_map = {key: None if url is None else Proxy(url=url) for key, url in get_environment_proxies().items()}
+
+            transport_kwargs = {
+                arg: kwargs[arg] for arg in ("verify", "cert", "trust_env", "http1", "http2", "limits") if arg in kwargs
+            }
+
+            proxy_mounts = {
+                key: None if proxy is None else AsyncHTTPTransport(proxy=proxy, **transport_kwargs)
+                for key, proxy in proxy_map.items()
+            }
+            default_transport = AsyncHTTPTransport(**transport_kwargs)
+
+            # Prioritize the mounts set by the user over the environment variables.
+            proxy_mounts.update(kwargs.get("mounts", {}))
+            kwargs["mounts"] = proxy_mounts
+
+            # Sets the default transport so that HTTPX won't automatically configure proxies.
+            kwargs["transport"] = kwargs.get("transport", default_transport)
 
         super().__init__(**kwargs)
 

src/anthropic/_utils/_httpx.py

@@ -0,0 +1,64 @@
+"""
+This file includes code adapted from HTTPX's utility module
+(https://github.com/encode/httpx/blob/336204f0121a9aefdebac5cacd81f912bafe8057/httpx/_utils.py).
+We implement custom proxy handling to support configurations like `socket_options`,
+which are not currently configurable through the HTTPX client.
+For more context, see: https://github.com/encode/httpx/discussions/3514
+"""
+
+from __future__ import annotations
+
+import ipaddress
+from typing import Mapping
+from urllib.request import getproxies
+
+
+def is_ipv4_hostname(hostname: str) -> bool:
+    try:
+        ipaddress.IPv4Address(hostname.split("/")[0])
+    except Exception:
+        return False
+    return True
+
+
+def is_ipv6_hostname(hostname: str) -> bool:
+    try:
+        ipaddress.IPv6Address(hostname.split("/")[0])
+    except Exception:
+        return False
+    return True
+
+
+def get_environment_proxies() -> Mapping[str, str | None]:
+    """
+    Gets the proxy mappings based on environment variables.
+    We use our own logic to parse these variables, as HTTPX
+    doesn’t allow full configuration of the underlying
+    transport when proxies are set via environment variables.
+    """
+
+    proxy_info = getproxies()
+    mounts: dict[str, str | None] = {}
+
+    for scheme in ("http", "https", "all"):
+        if proxy_info.get(scheme):
+            hostname = proxy_info[scheme]
+            mounts[f"{scheme}://"] = hostname if "://" in hostname else f"http://{hostname}"
+
+    no_proxy_hosts = [host.strip() for host in proxy_info.get("no", "").split(",")]
+    for hostname in no_proxy_hosts:
+        if hostname == "*":
+            return {}
+        elif hostname:
+            if "://" in hostname:
+                mounts[hostname] = None
+            elif is_ipv4_hostname(hostname):
+                mounts[f"all://{hostname}"] = None
+            elif is_ipv6_hostname(hostname):
+                mounts[f"all://[{hostname}]"] = None
+            elif hostname.lower() == "localhost":
+                mounts[f"all://{hostname}"] = None
+            else:
+                mounts[f"all://*{hostname}"] = None
+
+    return mounts

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

src/anthropic/lib/streaming/_beta_messages.py

@@ -120,6 +120,7 @@ def __stream__(self) -> Iterator[BetaMessageStreamEvent]:
             self.__final_message_snapshot = accumulate_event(
                 event=sse_event,
                 current_snapshot=self.__final_message_snapshot,
+                request_headers=self.response.request.headers,
             )
 
             events_to_fire = build_events(event=sse_event, message_snapshot=self.current_message_snapshot)
@@ -257,6 +258,7 @@ async def __stream__(self) -> AsyncIterator[BetaMessageStreamEvent]:
             self.__final_message_snapshot = accumulate_event(
                 event=sse_event,
                 current_snapshot=self.__final_message_snapshot,
+                request_headers=self.response.request.headers,
             )
 
             events_to_fire = build_events(event=sse_event, message_snapshot=self.current_message_snapshot)
@@ -403,6 +405,7 @@ def accumulate_event(
     *,
     event: BetaRawMessageStreamEvent,
     current_snapshot: BetaMessage | None,
+    request_headers: httpx.Headers,
 ) -> BetaMessage:
     if not isinstance(cast(Any, event), BaseModel):
         event = cast(  # pyright: ignore[reportUnnecessaryCast]
@@ -445,7 +448,17 @@ def accumulate_event(
                 json_buf += bytes(event.delta.partial_json, "utf-8")
 
                 if json_buf:
-                    content.input = from_json(json_buf, partial_mode=True)
+                    try:
+                        anthropic_beta = request_headers.get("anthropic-beta", "") if request_headers else ""
+
+                        if "fine-grained-tool-streaming-2025-05-14" in anthropic_beta:
+                            content.input = from_json(json_buf, partial_mode="trailing-strings")
+                        else:
+                            content.input = from_json(json_buf, partial_mode=True)
+                    except ValueError as e:
+                        raise ValueError(
+                            f"Unable to parse tool parameter JSON from model. Please retry your request or adjust your prompt. Error: {e}. JSON: {json_buf.decode('utf-8')}"
+                        ) from e
 
                 setattr(content, JSON_BUF_PROPERTY, json_buf)
         elif event.delta.type == "citations_delta":

tests/lib/streaming/fixtures/incomplete_partial_json_response.txt

@@ -0,0 +1,47 @@
+event: message_start
+data: {"type":"message_start","message":{"id":"msg_01UdjYBBipA9omjYhicnevgq","type":"message","role":"assistant","model":"claude-3-7-sonnet-20250219","content":[],"stop_reason":null,"stop_sequence":null,"usage":{"input_tokens":450,"cache_creation_input_tokens":0,"cache_read_input_tokens":0,"output_tokens":1,"service_tier":"standard"}}          }
+
+event: content_block_start
+data: {"type":"content_block_start","index":0,"content_block":{"type":"text","text":""}         }
+
+event: ping
+data: {"type": "ping"}
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":0,"delta":{"type":"text_delta","text":"I"}       }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":0,"delta":{"type":"text_delta","text":"'ll create a comprehensive tax guide for"}        }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":0,"delta":{"type":"text_delta","text":" someone with multiple W2s an"}        }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":0,"delta":{"type":"text_delta","text":"d save it in a file called taxes.txt. Let"} }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":0,"delta":{"type":"text_delta","text":" me do that for you now."}           }
+
+event: content_block_stop
+data: {"type":"content_block_stop","index":0 }
+
+event: content_block_start
+data: {"type":"content_block_start","index":1,"content_block":{"type":"tool_use","id":"toolu_01EKqbqmZrGRXy18eN7m9kvY","name":"make_file","input":{}}     }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":1,"delta":{"type":"input_json_delta","partial_json":""}       }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":1,"delta":{"type":"input_json_delta","partial_json":"{\"filename\": \"taxes.txt"}   }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":1,"delta":{"type":"input_json_delta","partial_json":"\", \"lines_of_text\": [\n\"# COMPREHENSIVE TAX GUIDE FOR INDIVIDUALS WITH MULTIPLE W-2s\",\n\"\",\n\"## INTRODUCTION\",\n\"\","}        }
+
+event: content_block_delta
+data: {"type":"content_block_delta","index":1,"delta":{"type":"input_json_delta","partial_json":"\n\"Filing taxes"}               }
+
+event: message_delta
+data: {"type":"message_delta","delta":{"stop_reason":"max_tokens","stop_sequence":null},"usage":{"output_tokens":124}    }
+
+event: message_stop
+data: {"type":"message_stop" }