release: 0.5.0 (#7)

stainless-app[bot] · web-flow · commit 45a7f0b9e9d0 · 2025-11-06T00:21:59.000-08:00
* chore: bump `httpx-aiohttp` version to 0.1.9

* fix(client): close streams without requiring full consumption

* chore(internal/tests): avoid race condition with implicit client cleanup

* chore(internal): grammar fix (it's -&gt; its)

* feat(api): manual updates

added agents

* release: 0.5.0

---------

Co-authored-by: stainless-app[bot] &lt;142633134+stainless-app[bot]@users.noreply.github.com&gt;
diff --git a/.release-please-manifest.json b/.release-please-manifest.json
@@ -1,3 +1,3 @@
 {
-  ".": "0.4.0"
+  ".": "0.5.0"
 }
diff --git a/.stats.yml b/.stats.yml
@@ -1,4 +1,4 @@
 configured_endpoints: 3
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/agentbase%2Fagentbase-461274f650eccdf115b96ee1dbf1c0d4eb31485992cedc84ee0187aec72d63a5.yml
-openapi_spec_hash: b8fa5fd0c89d9004d608af6061d0bf28
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/agentbase%2Fagentbase-c12be3e0fb0d0456a9dfdb9ba32d89ef3ffcd3561e945b22aff45ead12453358.yml
+openapi_spec_hash: fea6f0cc71a01188f51a84d6a7ba7258
 config_hash: 8d9b688cf969a1760b1300b65b80e796
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,25 @@
 # Changelog
 
+## 0.5.0 (2025-11-06)
+
+Full Changelog: [v0.4.0...v0.5.0](https://github.com/AgentbaseHQ/agentbase-python/compare/v0.4.0...v0.5.0)
+
+### Features
+
+* **api:** manual updates ([bd37cc0](https://github.com/AgentbaseHQ/agentbase-python/commit/bd37cc02bc033ed9a02a0fe412304620b1312884))
+
+
+### Bug Fixes
+
+* **client:** close streams without requiring full consumption ([600e68b](https://github.com/AgentbaseHQ/agentbase-python/commit/600e68b0722c43c174af329d83a866dba0e62e7c))
+
+
+### Chores
+
+* bump `httpx-aiohttp` version to 0.1.9 ([1a2887c](https://github.com/AgentbaseHQ/agentbase-python/commit/1a2887c6b9db2682267a3a28999227c3f5d857de))
+* **internal/tests:** avoid race condition with implicit client cleanup ([c01d166](https://github.com/AgentbaseHQ/agentbase-python/commit/c01d166af2db0d272a571f244c088ff3dcd91bed))
+* **internal:** grammar fix (it's -&gt; its) ([e501e14](https://github.com/AgentbaseHQ/agentbase-python/commit/e501e1463942a61a8eea51fb86e83ed56cb76b59))
+
 ## 0.4.0 (2025-10-11)
 
 Full Changelog: [v0.3.1...v0.4.0](https://github.com/AgentbaseHQ/agentbase-python/compare/v0.3.1...v0.4.0)
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "agentbase-sdk"
-version = "0.4.0"
+version = "0.5.0"
 description = "The official Python library for the agentbase API"
 dynamic = ["readme"]
 license = "Apache-2.0"
@@ -39,7 +39,7 @@ Homepage = "https://github.com/AgentbaseHQ/agentbase-python"
 Repository = "https://github.com/AgentbaseHQ/agentbase-python"
 
 [project.optional-dependencies]
-aiohttp = ["aiohttp", "httpx_aiohttp>=0.1.8"]
+aiohttp = ["aiohttp", "httpx_aiohttp>=0.1.9"]
 
 [tool.rye]
 managed = true
diff --git a/requirements-dev.lock b/requirements-dev.lock
@@ -56,7 +56,7 @@ httpx==0.28.1
     # via agentbase-sdk
     # via httpx-aiohttp
     # via respx
-httpx-aiohttp==0.1.8
+httpx-aiohttp==0.1.9
     # via agentbase-sdk
 idna==3.4
     # via anyio
diff --git a/requirements.lock b/requirements.lock
@@ -43,7 +43,7 @@ httpcore==1.0.9
 httpx==0.28.1
     # via agentbase-sdk
     # via httpx-aiohttp
-httpx-aiohttp==0.1.8
+httpx-aiohttp==0.1.9
     # via agentbase-sdk
 idna==3.4
     # via anyio
diff --git a/src/agentbase/_client.py b/src/agentbase/_client.py
@@ -202,6 +202,7 @@ def run_agent(
         *,
         message: str,
         session: str | Omit = omit,
+        agents: Iterable[client_run_agent_params.Agent] | Omit = omit,
         background: bool | Omit = omit,
         callback: client_run_agent_params.Callback | Omit = omit,
         datastores: Iterable[client_run_agent_params.Datastore] | Omit = omit,
@@ -236,6 +237,10 @@ def run_agent(
           session: The session ID to continue the agent session conversation. If not provided, a
               new session will be created.
 
+          agents: A set of agent configurations that enables the agent to transfer conversations
+              to other specialized agents. When provided, the main agent will have access to
+              seamless handoffs between agents based on the conversation context.
+
           background: Whether to run the agent asynchronously on the server. When set to true, use
               callback parameter to receive events.
 
@@ -282,6 +287,7 @@ def run_agent(
             body=maybe_transform(
                 {
                     "message": message,
+                    "agents": agents,
                     "background": background,
                     "callback": callback,
                     "datastores": datastores,
@@ -483,6 +489,7 @@ async def run_agent(
         *,
         message: str,
         session: str | Omit = omit,
+        agents: Iterable[client_run_agent_params.Agent] | Omit = omit,
         background: bool | Omit = omit,
         callback: client_run_agent_params.Callback | Omit = omit,
         datastores: Iterable[client_run_agent_params.Datastore] | Omit = omit,
@@ -517,6 +524,10 @@ async def run_agent(
           session: The session ID to continue the agent session conversation. If not provided, a
               new session will be created.
 
+          agents: A set of agent configurations that enables the agent to transfer conversations
+              to other specialized agents. When provided, the main agent will have access to
+              seamless handoffs between agents based on the conversation context.
+
           background: Whether to run the agent asynchronously on the server. When set to true, use
               callback parameter to receive events.
 
@@ -563,6 +574,7 @@ async def run_agent(
             body=await async_maybe_transform(
                 {
                     "message": message,
+                    "agents": agents,
                     "background": background,
                     "callback": callback,
                     "datastores": datastores,
diff --git a/src/agentbase/_streaming.py b/src/agentbase/_streaming.py
@@ -57,9 +57,8 @@ def __stream__(self) -> Iterator[_T]:
         for sse in iterator:
             yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-        # Ensure the entire stream is consumed
-        for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        response.close()
 
     def __enter__(self) -> Self:
         return self
@@ -121,9 +120,8 @@ async def __stream__(self) -> AsyncIterator[_T]:
         async for sse in iterator:
             yield process_data(data=sse.json(), cast_to=cast_to, response=response)
 
-        # Ensure the entire stream is consumed
-        async for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        await response.aclose()
 
     async def __aenter__(self) -> Self:
         return self
diff --git a/src/agentbase/_utils/_utils.py b/src/agentbase/_utils/_utils.py
@@ -133,7 +133,7 @@ def is_given(obj: _T | NotGiven | Omit) -> TypeGuard[_T]:
 # Type safe methods for narrowing types with TypeVars.
 # The default narrowing for isinstance(obj, dict) is dict[unknown, unknown],
 # however this cause Pyright to rightfully report errors. As we know we don't
-# care about the contained types we can safely use `object` in it's place.
+# care about the contained types we can safely use `object` in its place.
 #
 # There are two separate functions defined, `is_*` and `is_*_t` for different use cases.
 # `is_*` is for when you're dealing with an unknown input
diff --git a/src/agentbase/_version.py b/src/agentbase/_version.py
@@ -1,4 +1,4 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
 __title__ = "agentbase"
-__version__ = "0.4.0"  # x-release-please-version
+__version__ = "0.5.0"  # x-release-please-version
diff --git a/src/agentbase/resources/agent.py b/src/agentbase/resources/agent.py
@@ -50,6 +50,7 @@ def run(
         *,
         message: str,
         session: str | Omit = omit,
+        agents: Iterable[agent_run_params.Agent] | Omit = omit,
         background: bool | Omit = omit,
         callback: agent_run_params.Callback | Omit = omit,
         datastores: Iterable[agent_run_params.Datastore] | Omit = omit,
@@ -85,6 +86,10 @@ def run(
           session: The session ID to continue the agent session conversation. If not provided, a
               new session will be created.
 
+          agents: A set of agent configurations that enables the agent to transfer conversations
+              to other specialized agents. When provided, the main agent will have access to
+              seamless handoffs between agents based on the conversation context.
+
           background: Whether to run the agent asynchronously on the server. When set to true, use
               callback parameter to receive events.
 
@@ -131,6 +136,7 @@ def run(
             body=maybe_transform(
                 {
                     "message": message,
+                    "agents": agents,
                     "background": background,
                     "callback": callback,
                     "datastores": datastores,
@@ -183,6 +189,7 @@ async def run(
         *,
         message: str,
         session: str | Omit = omit,
+        agents: Iterable[agent_run_params.Agent] | Omit = omit,
         background: bool | Omit = omit,
         callback: agent_run_params.Callback | Omit = omit,
         datastores: Iterable[agent_run_params.Datastore] | Omit = omit,
@@ -218,6 +225,10 @@ async def run(
           session: The session ID to continue the agent session conversation. If not provided, a
               new session will be created.
 
+          agents: A set of agent configurations that enables the agent to transfer conversations
+              to other specialized agents. When provided, the main agent will have access to
+              seamless handoffs between agents based on the conversation context.
+
           background: Whether to run the agent asynchronously on the server. When set to true, use
               callback parameter to receive events.
 
@@ -264,6 +275,7 @@ async def run(
             body=await async_maybe_transform(
                 {
                     "message": message,
+                    "agents": agents,
                     "background": background,
                     "callback": callback,
                     "datastores": datastores,
diff --git a/src/agentbase/types/agent_run_params.py b/src/agentbase/types/agent_run_params.py
@@ -10,6 +10,7 @@
 
 __all__ = [
     "AgentRunParams",
+    "Agent",
     "Callback",
     "Datastore",
     "FinalOutput",
@@ -31,6 +32,13 @@ class AgentRunParams(TypedDict, total=False):
     If not provided, a new session will be created.
     """
 
+    agents: Iterable[Agent]
+    """
+    A set of agent configurations that enables the agent to transfer conversations
+    to other specialized agents. When provided, the main agent will have access to
+    seamless handoffs between agents based on the conversation context.
+    """
+
     background: bool
     """Whether to run the agent asynchronously on the server.
 
@@ -92,6 +100,14 @@ class AgentRunParams(TypedDict, total=False):
     """
 
 
+class Agent(TypedDict, total=False):
+    description: Required[str]
+    """Description of what this agent handles"""
+
+    name: Required[str]
+    """The name of the agent to transfer to"""
+
+
 class Callback(TypedDict, total=False):
     url: Required[str]
     """The webhook URL to send events to."""
diff --git a/src/agentbase/types/client_run_agent_params.py b/src/agentbase/types/client_run_agent_params.py
@@ -10,6 +10,7 @@
 
 __all__ = [
     "ClientRunAgentParams",
+    "Agent",
     "Callback",
     "Datastore",
     "FinalOutput",
@@ -31,6 +32,13 @@ class ClientRunAgentParams(TypedDict, total=False):
     If not provided, a new session will be created.
     """
 
+    agents: Iterable[Agent]
+    """
+    A set of agent configurations that enables the agent to transfer conversations
+    to other specialized agents. When provided, the main agent will have access to
+    seamless handoffs between agents based on the conversation context.
+    """
+
     background: bool
     """Whether to run the agent asynchronously on the server.
 
@@ -92,6 +100,14 @@ class ClientRunAgentParams(TypedDict, total=False):
     """
 
 
+class Agent(TypedDict, total=False):
+    description: Required[str]
+    """Description of what this agent handles"""
+
+    name: Required[str]
+    """The name of the agent to transfer to"""
+
+
 class Callback(TypedDict, total=False):
     url: Required[str]
     """The webhook URL to send events to."""
diff --git a/tests/api_resources/test_agent.py b/tests/api_resources/test_agent.py
@@ -29,6 +29,12 @@ def test_method_run_with_all_params(self, client: Agentbase) -> None:
         agent_stream = client.agent.run(
             message="message",
             session="session",
+            agents=[
+                {
+                    "description": "description",
+                    "name": "name",
+                }
+            ],
             background=True,
             callback={
                 "url": "https://example.com",
@@ -131,6 +137,12 @@ async def test_method_run_with_all_params(self, async_client: AsyncAgentbase) ->
         agent_stream = await async_client.agent.run(
             message="message",
             session="session",
+            agents=[
+                {
+                    "description": "description",
+                    "name": "name",
+                }
+            ],
             background=True,
             callback={
                 "url": "https://example.com",
diff --git a/tests/api_resources/test_client.py b/tests/api_resources/test_client.py
@@ -29,6 +29,12 @@ def test_method_run_agent_with_all_params(self, client: Agentbase) -> None:
         client_stream = client.run_agent(
             message="message",
             session="session",
+            agents=[
+                {
+                    "description": "description",
+                    "name": "name",
+                }
+            ],
             background=True,
             callback={
                 "url": "https://example.com",
@@ -131,6 +137,12 @@ async def test_method_run_agent_with_all_params(self, async_client: AsyncAgentba
         client_stream = await async_client.run_agent(
             message="message",
             session="session",
+            agents=[
+                {
+                    "description": "description",
+                    "name": "name",
+                }
+            ],
             background=True,
             callback={
                 "url": "https://example.com",
diff --git a/tests/test_client.py b/tests/test_client.py

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,3 @@`
`1`	`1`	`{`
`2`		`- ".": "0.4.0"`
	`2`	`+ ".": "0.5.0"`
`3`	`3`	`}`
Original file line number	Diff line number	Diff line change
`@@ -133,7 +133,7 @@ def is_given(obj: _T \| NotGiven \| Omit) -> TypeGuard[_T]:`
`133`	`133`	`# Type safe methods for narrowing types with TypeVars.`
`134`	`134`	`# The default narrowing for isinstance(obj, dict) is dict[unknown, unknown],`
`135`	`135`	`# however this cause Pyright to rightfully report errors. As we know we don't`
`136`		-# care about the contained types we can safely use `object` in it's place.
	`136`	+# care about the contained types we can safely use `object` in its place.
`137`	`137`	`#`
`138`	`138`	# There are two separate functions defined, `is_` and `is__t` for different use cases.
`139`	`139`	# `is_*` is for when you're dealing with an unknown input