feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 34
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp%2Fagentex-sdk-ed22476258be08ff765c68dcb29c08baf3e4783c98edac50d1e8003e9487db37.yml
-openapi_spec_hash: d4010bb4bf479073328ca00be01a7b96
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp%2Fagentex-sdk-315b05c82c3c0fdc9f058422debc4edc09c04cef2f7ff8605953de11d16c489f.yml
+openapi_spec_hash: 1bc36f6ebe0d9d926c4312de7ec9222e
 config_hash: 7c1f6794a184ee175dd94f2f7c2b496b

api.md

@@ -35,14 +35,14 @@ Methods:
 Types:
 
 ```python
-from agentex.types import Task, TaskListResponse, TaskDeleteResponse, TaskDeleteByNameResponse
+from agentex.types import Task, TaskListResponse, TaskDeleteByNameResponse
 ```
 
 Methods:
 
 - <code title="get /tasks/{task_id}">client.tasks.<a href="./src/agentex/resources/tasks.py">retrieve</a>(task_id) -> <a href="./src/agentex/types/task.py">Task</a></code>
 - <code title="get /tasks">client.tasks.<a href="./src/agentex/resources/tasks.py">list</a>() -> <a href="./src/agentex/types/task_list_response.py">TaskListResponse</a></code>
-- <code title="delete /tasks/{task_id}">client.tasks.<a href="./src/agentex/resources/tasks.py">delete</a>(task_id) -> <a href="./src/agentex/types/task_delete_response.py">TaskDeleteResponse</a></code>
+- <code title="delete /tasks/{task_id}">client.tasks.<a href="./src/agentex/resources/tasks.py">delete</a>(task_id) -> <a href="./src/agentex/types/task.py">Task</a></code>
 - <code title="delete /tasks/name/{task_name}">client.tasks.<a href="./src/agentex/resources/tasks.py">delete_by_name</a>(task_name) -> <a href="./src/agentex/types/task_delete_by_name_response.py">TaskDeleteByNameResponse</a></code>
 - <code title="get /tasks/name/{task_name}">client.tasks.<a href="./src/agentex/resources/tasks.py">retrieve_by_name</a>(task_name) -> <a href="./src/agentex/types/task.py">Task</a></code>
 - <code title="get /tasks/{task_id}/stream">client.tasks.<a href="./src/agentex/resources/tasks.py">stream_events</a>(task_id) -> object</code>

src/agentex/resources/messages/messages.py

@@ -179,7 +179,6 @@ def update(
     def list(
         self,
         *,
-        task_id: str,
         limit: Optional[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.
@@ -207,13 +206,7 @@ def list(
                 extra_query=extra_query,
                 extra_body=extra_body,
                 timeout=timeout,
-                query=maybe_transform(
-                    {
-                        "task_id": task_id,
-                        "limit": limit,
-                    },
-                    message_list_params.MessageListParams,
-                ),
+                query=maybe_transform({"limit": limit}, message_list_params.MessageListParams),
             ),
             cast_to=MessageListResponse,
         )
@@ -364,7 +357,6 @@ async def update(
     async def list(
         self,
         *,
-        task_id: str,
         limit: Optional[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.
@@ -392,13 +384,7 @@ async def list(
                 extra_query=extra_query,
                 extra_body=extra_body,
                 timeout=timeout,
-                query=await async_maybe_transform(
-                    {
-                        "task_id": task_id,
-                        "limit": limit,
-                    },
-                    message_list_params.MessageListParams,
-                ),
+                query=await async_maybe_transform({"limit": limit}, message_list_params.MessageListParams),
             ),
             cast_to=MessageListResponse,
         )

src/agentex/resources/tasks.py

@@ -17,7 +17,6 @@
 from ..types.task import Task
 from .._base_client import make_request_options
 from ..types.task_list_response import TaskListResponse
-from ..types.task_delete_response import TaskDeleteResponse
 from ..types.task_delete_by_name_response import TaskDeleteByNameResponse
 
 __all__ = ["TasksResource", "AsyncTasksResource"]
@@ -105,7 +104,7 @@ def delete(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> TaskDeleteResponse:
+    ) -> Task:
         """
         Delete a task by its unique ID.
 
@@ -125,7 +124,7 @@ def delete(
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
-            cast_to=TaskDeleteResponse,
+            cast_to=Task,
         )
 
     def delete_by_name(
@@ -347,7 +346,7 @@ async def delete(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> TaskDeleteResponse:
+    ) -> Task:
         """
         Delete a task by its unique ID.
 
@@ -367,7 +366,7 @@ async def delete(
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
-            cast_to=TaskDeleteResponse,
+            cast_to=Task,
         )
 
     async def delete_by_name(

src/agentex/types/__init__.py

@@ -40,7 +40,6 @@
 from .task_message_update import TaskMessageUpdate as TaskMessageUpdate
 from .tool_response_delta import ToolResponseDelta as ToolResponseDelta
 from .tracker_list_params import TrackerListParams as TrackerListParams
-from .task_delete_response import TaskDeleteResponse as TaskDeleteResponse
 from .task_message_content import TaskMessageContent as TaskMessageContent
 from .tool_request_content import ToolRequestContent as ToolRequestContent
 from .message_create_params import MessageCreateParams as MessageCreateParams

src/agentex/types/message_list_params.py

@@ -3,12 +3,10 @@
 from __future__ import annotations
 
 from typing import Optional
-from typing_extensions import Required, TypedDict
+from typing_extensions import TypedDict
 
 __all__ = ["MessageListParams"]
 
 
 class MessageListParams(TypedDict, total=False):
-    task_id: Required[str]
-
     limit: Optional[int]

src/agentex/types/task_delete_response.py

@@ -229,26 +229,21 @@ def test_path_params_update(self, client: Agentex) -> None:
     @pytest.mark.skip()
     @parametrize
     def test_method_list(self, client: Agentex) -> None:
-        message = client.messages.list(
-            task_id="task_id",
-        )
+        message = client.messages.list()
         assert_matches_type(MessageListResponse, message, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
     def test_method_list_with_all_params(self, client: Agentex) -> None:
         message = client.messages.list(
-            task_id="task_id",
             limit=0,
         )
         assert_matches_type(MessageListResponse, message, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
     def test_raw_response_list(self, client: Agentex) -> None:
-        response = client.messages.with_raw_response.list(
-            task_id="task_id",
-        )
+        response = client.messages.with_raw_response.list()
 
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
@@ -258,9 +253,7 @@ def test_raw_response_list(self, client: Agentex) -> None:
     @pytest.mark.skip()
     @parametrize
     def test_streaming_response_list(self, client: Agentex) -> None:
-        with client.messages.with_streaming_response.list(
-            task_id="task_id",
-        ) as response:
+        with client.messages.with_streaming_response.list() as response:
             assert not response.is_closed
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
@@ -484,26 +477,21 @@ async def test_path_params_update(self, async_client: AsyncAgentex) -> None:
     @pytest.mark.skip()
     @parametrize
     async def test_method_list(self, async_client: AsyncAgentex) -> None:
-        message = await async_client.messages.list(
-            task_id="task_id",
-        )
+        message = await async_client.messages.list()
         assert_matches_type(MessageListResponse, message, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
     async def test_method_list_with_all_params(self, async_client: AsyncAgentex) -> None:
         message = await async_client.messages.list(
-            task_id="task_id",
             limit=0,
         )
         assert_matches_type(MessageListResponse, message, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
     async def test_raw_response_list(self, async_client: AsyncAgentex) -> None:
-        response = await async_client.messages.with_raw_response.list(
-            task_id="task_id",
-        )
+        response = await async_client.messages.with_raw_response.list()
 
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
@@ -513,9 +501,7 @@ async def test_raw_response_list(self, async_client: AsyncAgentex) -> None:
     @pytest.mark.skip()
     @parametrize
     async def test_streaming_response_list(self, async_client: AsyncAgentex) -> None:
-        async with async_client.messages.with_streaming_response.list(
-            task_id="task_id",
-        ) as response:
+        async with async_client.messages.with_streaming_response.list() as response:
             assert not response.is_closed
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 

tests/api_resources/test_messages.py

@@ -9,7 +9,7 @@
 
 from agentex import Agentex, AsyncAgentex
 from tests.utils import assert_matches_type
-from agentex.types import Task, TaskListResponse, TaskDeleteResponse, TaskDeleteByNameResponse
+from agentex.types import Task, TaskListResponse, TaskDeleteByNameResponse
 
 base_url = os.environ.get("TEST_API_BASE_URL", "http://127.0.0.1:4010")
 
@@ -93,7 +93,7 @@ def test_method_delete(self, client: Agentex) -> None:
         task = client.tasks.delete(
             "task_id",
         )
-        assert_matches_type(TaskDeleteResponse, task, path=["response"])
+        assert_matches_type(Task, task, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
@@ -105,7 +105,7 @@ def test_raw_response_delete(self, client: Agentex) -> None:
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
         task = response.parse()
-        assert_matches_type(TaskDeleteResponse, task, path=["response"])
+        assert_matches_type(Task, task, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
@@ -117,7 +117,7 @@ def test_streaming_response_delete(self, client: Agentex) -> None:
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
             task = response.parse()
-            assert_matches_type(TaskDeleteResponse, task, path=["response"])
+            assert_matches_type(Task, task, path=["response"])
 
         assert cast(Any, response.is_closed) is True
 
@@ -377,7 +377,7 @@ async def test_method_delete(self, async_client: AsyncAgentex) -> None:
         task = await async_client.tasks.delete(
             "task_id",
         )
-        assert_matches_type(TaskDeleteResponse, task, path=["response"])
+        assert_matches_type(Task, task, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
@@ -389,7 +389,7 @@ async def test_raw_response_delete(self, async_client: AsyncAgentex) -> None:
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
         task = await response.parse()
-        assert_matches_type(TaskDeleteResponse, task, path=["response"])
+        assert_matches_type(Task, task, path=["response"])
 
     @pytest.mark.skip()
     @parametrize
@@ -401,7 +401,7 @@ async def test_streaming_response_delete(self, async_client: AsyncAgentex) -> No
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
             task = await response.parse()
-            assert_matches_type(TaskDeleteResponse, task, path=["response"])
+            assert_matches_type(Task, task, path=["response"])
 
         assert cast(Any, response.is_closed) is True