From 38ad01058bf4ffb679b5e9d7e0cad68960336a4d Mon Sep 17 00:00:00 2001 From: "stainless-app[bot]" <142633134+stainless-app[bot]@users.noreply.github.com> Date: Tue, 11 Mar 2025 04:28:09 +0000 Subject: [PATCH 1/2] feat(api): api update (#125) --- .stats.yml | 2 +- api.md | 3 +- src/arcadepy/resources/workers.py | 56 +++++++++++++++++---- src/arcadepy/types/__init__.py | 2 +- src/arcadepy/types/worker_tools_params.py | 15 ++++++ src/arcadepy/types/worker_tools_response.py | 20 -------- tests/api_resources/test_workers.py | 48 ++++++++++++------ 7 files changed, 96 insertions(+), 50 deletions(-) create mode 100644 src/arcadepy/types/worker_tools_params.py delete mode 100644 src/arcadepy/types/worker_tools_response.py diff --git a/.stats.yml b/.stats.yml index d7bbb3f3..9a0cc5e6 100644 --- a/.stats.yml +++ b/.stats.yml @@ -1,2 +1,2 @@ configured_endpoints: 19 -openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/arcade-ai%2Farcade-engine-633d84454335d704b205b7d730bcda184c858f96c36cf27b5ecf786a5bff7f42.yml +openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/arcade-ai%2Farcade-engine-3c7443a5e05ad4ade2ac36325d1def05cb3842bb53a180fc76feb565ea875cc7.yml diff --git a/api.md b/api.md index 09659de7..0f79d040 100644 --- a/api.md +++ b/api.md @@ -102,7 +102,6 @@ from arcadepy.types import ( UpdateWorkerRequest, WorkerHealthResponse, WorkerResponse, - WorkerToolsResponse, ) ``` @@ -114,4 +113,4 @@ Methods: - client.workers.delete(id) -> None - client.workers.get(id) -> WorkerResponse - client.workers.health(id) -> WorkerHealthResponse -- client.workers.tools(id) -> WorkerToolsResponse +- client.workers.tools(id, \*\*params) -> SyncOffsetPage[ToolDefinition] diff --git a/src/arcadepy/resources/workers.py b/src/arcadepy/resources/workers.py index 62266ae6..05893630 100644 --- a/src/arcadepy/resources/workers.py +++ b/src/arcadepy/resources/workers.py @@ -4,7 +4,7 @@ import httpx -from ..types import worker_list_params, worker_create_params, worker_update_params +from ..types import worker_list_params, worker_tools_params, worker_create_params, worker_update_params from .._types import NOT_GIVEN, Body, Query, Headers, NoneType, NotGiven from .._utils import ( maybe_transform, @@ -20,8 +20,8 @@ ) from ..pagination import SyncOffsetPage, AsyncOffsetPage from .._base_client import AsyncPaginator, make_request_options +from ..types.tool_definition import ToolDefinition from ..types.worker_response import WorkerResponse -from ..types.worker_tools_response import WorkerToolsResponse from ..types.worker_health_response import WorkerHealthResponse __all__ = ["WorkersResource", "AsyncWorkersResource"] @@ -281,17 +281,23 @@ def tools( self, id: str, *, + limit: int | NotGiven = NOT_GIVEN, + offset: int | NotGiven = NOT_GIVEN, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, - ) -> WorkerToolsResponse: + ) -> SyncOffsetPage[ToolDefinition]: """ Returns a page of tools Args: + limit: Number of items to return (default: 25, max: 100) + + offset: Offset from the start of the list (default: 0) + extra_headers: Send extra headers extra_query: Add additional query parameters to the request @@ -302,12 +308,23 @@ def tools( """ if not id: raise ValueError(f"Expected a non-empty value for `id` but received {id!r}") - return self._get( + return self._get_api_list( f"/v1/workers/{id}/tools", + page=SyncOffsetPage[ToolDefinition], options=make_request_options( - extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout + extra_headers=extra_headers, + extra_query=extra_query, + extra_body=extra_body, + timeout=timeout, + query=maybe_transform( + { + "limit": limit, + "offset": offset, + }, + worker_tools_params.WorkerToolsParams, + ), ), - cast_to=WorkerToolsResponse, + model=ToolDefinition, ) @@ -561,21 +578,27 @@ async def health( cast_to=WorkerHealthResponse, ) - async def tools( + def tools( self, id: str, *, + limit: int | NotGiven = NOT_GIVEN, + offset: int | NotGiven = NOT_GIVEN, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, - ) -> WorkerToolsResponse: + ) -> AsyncPaginator[ToolDefinition, AsyncOffsetPage[ToolDefinition]]: """ Returns a page of tools Args: + limit: Number of items to return (default: 25, max: 100) + + offset: Offset from the start of the list (default: 0) + extra_headers: Send extra headers extra_query: Add additional query parameters to the request @@ -586,12 +609,23 @@ async def tools( """ if not id: raise ValueError(f"Expected a non-empty value for `id` but received {id!r}") - return await self._get( + return self._get_api_list( f"/v1/workers/{id}/tools", + page=AsyncOffsetPage[ToolDefinition], options=make_request_options( - extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout + extra_headers=extra_headers, + extra_query=extra_query, + extra_body=extra_body, + timeout=timeout, + query=maybe_transform( + { + "limit": limit, + "offset": offset, + }, + worker_tools_params.WorkerToolsParams, + ), ), - cast_to=WorkerToolsResponse, + model=ToolDefinition, ) diff --git a/src/arcadepy/types/__init__.py b/src/arcadepy/types/__init__.py index 000f50c5..1b6a4beb 100644 --- a/src/arcadepy/types/__init__.py +++ b/src/arcadepy/types/__init__.py @@ -22,11 +22,11 @@ from .chat_message_param import ChatMessageParam as ChatMessageParam from .worker_list_params import WorkerListParams as WorkerListParams from .tool_execute_params import ToolExecuteParams as ToolExecuteParams +from .worker_tools_params import WorkerToolsParams as WorkerToolsParams from .worker_create_params import WorkerCreateParams as WorkerCreateParams from .worker_update_params import WorkerUpdateParams as WorkerUpdateParams from .auth_authorize_params import AuthAuthorizeParams as AuthAuthorizeParams from .execute_tool_response import ExecuteToolResponse as ExecuteToolResponse from .tool_authorize_params import ToolAuthorizeParams as ToolAuthorizeParams -from .worker_tools_response import WorkerToolsResponse as WorkerToolsResponse from .tool_execution_attempt import ToolExecutionAttempt as ToolExecutionAttempt from .worker_health_response import WorkerHealthResponse as WorkerHealthResponse diff --git a/src/arcadepy/types/worker_tools_params.py b/src/arcadepy/types/worker_tools_params.py new file mode 100644 index 00000000..1c16dc45 --- /dev/null +++ b/src/arcadepy/types/worker_tools_params.py @@ -0,0 +1,15 @@ +# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. + +from __future__ import annotations + +from typing_extensions import TypedDict + +__all__ = ["WorkerToolsParams"] + + +class WorkerToolsParams(TypedDict, total=False): + limit: int + """Number of items to return (default: 25, max: 100)""" + + offset: int + """Offset from the start of the list (default: 0)""" diff --git a/src/arcadepy/types/worker_tools_response.py b/src/arcadepy/types/worker_tools_response.py deleted file mode 100644 index 68e9355f..00000000 --- a/src/arcadepy/types/worker_tools_response.py +++ /dev/null @@ -1,20 +0,0 @@ -# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. - -from typing import List, Optional - -from .._models import BaseModel -from .tool_definition import ToolDefinition - -__all__ = ["WorkerToolsResponse"] - - -class WorkerToolsResponse(BaseModel): - items: Optional[List[ToolDefinition]] = None - - limit: Optional[int] = None - - offset: Optional[int] = None - - page_count: Optional[int] = None - - total_count: Optional[int] = None diff --git a/tests/api_resources/test_workers.py b/tests/api_resources/test_workers.py index eaa05851..ab065073 100644 --- a/tests/api_resources/test_workers.py +++ b/tests/api_resources/test_workers.py @@ -10,8 +10,8 @@ from arcadepy import Arcade, AsyncArcade from tests.utils import assert_matches_type from arcadepy.types import ( + ToolDefinition, WorkerResponse, - WorkerToolsResponse, WorkerHealthResponse, ) from arcadepy.pagination import SyncOffsetPage, AsyncOffsetPage @@ -272,31 +272,40 @@ def test_path_params_health(self, client: Arcade) -> None: @parametrize def test_method_tools(self, client: Arcade) -> None: worker = client.workers.tools( - "id", + id="id", ) - assert_matches_type(WorkerToolsResponse, worker, path=["response"]) + assert_matches_type(SyncOffsetPage[ToolDefinition], worker, path=["response"]) + + @parametrize + def test_method_tools_with_all_params(self, client: Arcade) -> None: + worker = client.workers.tools( + id="id", + limit=0, + offset=0, + ) + assert_matches_type(SyncOffsetPage[ToolDefinition], worker, path=["response"]) @parametrize def test_raw_response_tools(self, client: Arcade) -> None: response = client.workers.with_raw_response.tools( - "id", + id="id", ) assert response.is_closed is True assert response.http_request.headers.get("X-Stainless-Lang") == "python" worker = response.parse() - assert_matches_type(WorkerToolsResponse, worker, path=["response"]) + assert_matches_type(SyncOffsetPage[ToolDefinition], worker, path=["response"]) @parametrize def test_streaming_response_tools(self, client: Arcade) -> None: with client.workers.with_streaming_response.tools( - "id", + id="id", ) as response: assert not response.is_closed assert response.http_request.headers.get("X-Stainless-Lang") == "python" worker = response.parse() - assert_matches_type(WorkerToolsResponse, worker, path=["response"]) + assert_matches_type(SyncOffsetPage[ToolDefinition], worker, path=["response"]) assert cast(Any, response.is_closed) is True @@ -304,7 +313,7 @@ def test_streaming_response_tools(self, client: Arcade) -> None: def test_path_params_tools(self, client: Arcade) -> None: with pytest.raises(ValueError, match=r"Expected a non-empty value for `id` but received ''"): client.workers.with_raw_response.tools( - "", + id="", ) @@ -561,31 +570,40 @@ async def test_path_params_health(self, async_client: AsyncArcade) -> None: @parametrize async def test_method_tools(self, async_client: AsyncArcade) -> None: worker = await async_client.workers.tools( - "id", + id="id", ) - assert_matches_type(WorkerToolsResponse, worker, path=["response"]) + assert_matches_type(AsyncOffsetPage[ToolDefinition], worker, path=["response"]) + + @parametrize + async def test_method_tools_with_all_params(self, async_client: AsyncArcade) -> None: + worker = await async_client.workers.tools( + id="id", + limit=0, + offset=0, + ) + assert_matches_type(AsyncOffsetPage[ToolDefinition], worker, path=["response"]) @parametrize async def test_raw_response_tools(self, async_client: AsyncArcade) -> None: response = await async_client.workers.with_raw_response.tools( - "id", + id="id", ) assert response.is_closed is True assert response.http_request.headers.get("X-Stainless-Lang") == "python" worker = await response.parse() - assert_matches_type(WorkerToolsResponse, worker, path=["response"]) + assert_matches_type(AsyncOffsetPage[ToolDefinition], worker, path=["response"]) @parametrize async def test_streaming_response_tools(self, async_client: AsyncArcade) -> None: async with async_client.workers.with_streaming_response.tools( - "id", + id="id", ) as response: assert not response.is_closed assert response.http_request.headers.get("X-Stainless-Lang") == "python" worker = await response.parse() - assert_matches_type(WorkerToolsResponse, worker, path=["response"]) + assert_matches_type(AsyncOffsetPage[ToolDefinition], worker, path=["response"]) assert cast(Any, response.is_closed) is True @@ -593,5 +611,5 @@ async def test_streaming_response_tools(self, async_client: AsyncArcade) -> None async def test_path_params_tools(self, async_client: AsyncArcade) -> None: with pytest.raises(ValueError, match=r"Expected a non-empty value for `id` but received ''"): await async_client.workers.with_raw_response.tools( - "", + id="", ) From c205ca5448646f49807f9b9f0fc61f08ed675f30 Mon Sep 17 00:00:00 2001 From: "stainless-app[bot]" <142633134+stainless-app[bot]@users.noreply.github.com> Date: Tue, 11 Mar 2025 04:31:10 +0000 Subject: [PATCH 2/2] release: 1.3.1 --- .release-please-manifest.json | 2 +- CHANGELOG.md | 8 ++++++++ pyproject.toml | 2 +- src/arcadepy/_version.py | 2 +- 4 files changed, 11 insertions(+), 3 deletions(-) diff --git a/.release-please-manifest.json b/.release-please-manifest.json index 2a8f4ffd..0e5b256d 100644 --- a/.release-please-manifest.json +++ b/.release-please-manifest.json @@ -1,3 +1,3 @@ { - ".": "1.3.0" + ".": "1.3.1" } \ No newline at end of file diff --git a/CHANGELOG.md b/CHANGELOG.md index b3ff2a04..7525cc77 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,13 @@ # Changelog +## 1.3.1 (2025-03-11) + +Full Changelog: [v1.3.0...v1.3.1](https://github.com/ArcadeAI/arcade-py/compare/v1.3.0...v1.3.1) + +### Features + +* **api:** api update ([#125](https://github.com/ArcadeAI/arcade-py/issues/125)) ([38ad010](https://github.com/ArcadeAI/arcade-py/commit/38ad01058bf4ffb679b5e9d7e0cad68960336a4d)) + ## 1.3.0 (2025-03-10) Full Changelog: [v1.2.1...v1.3.0](https://github.com/ArcadeAI/arcade-py/compare/v1.2.1...v1.3.0) diff --git a/pyproject.toml b/pyproject.toml index 793004f7..03ab7607 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "arcadepy" -version = "1.3.0" +version = "1.3.1" description = "The official Python library for the Arcade API" dynamic = ["readme"] license = "MIT" diff --git a/src/arcadepy/_version.py b/src/arcadepy/_version.py index eaefeb23..710f3552 100644 --- a/src/arcadepy/_version.py +++ b/src/arcadepy/_version.py @@ -1,4 +1,4 @@ # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. __title__ = "arcadepy" -__version__ = "1.3.0" # x-release-please-version +__version__ = "1.3.1" # x-release-please-version