feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 45
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp/agentex-sdk-77d6129c9334f3e5fafbbfe9e6e31b5328a90042d36a83b7ebdf5ac803c84fad.yml
-openapi_spec_hash: 29b1c8e19be86501217b5a6c1858f73a
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp/agentex-sdk-b997afde6595db62caea38bca035fda2812ea52cc8f360dab829b71178e826e6.yml
+openapi_spec_hash: d195a98bf64b6edb826bc420773ca52e
 config_hash: fb079ef7936611b032568661b8165f19

src/agentex/resources/tasks.py

@@ -109,17 +109,27 @@ def list(
         order_direction: str | Omit = omit,
         page_number: int | Omit = omit,
         relationships: List[Literal["agents"]] | Omit = omit,
+        status: Optional[Literal["CANCELED", "COMPLETED", "FAILED", "RUNNING", "TERMINATED", "TIMED_OUT", "DELETED"]]
+        | Omit = omit,
+        task_metadata: Optional[str] | Omit = omit,
         # 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,
     ) -> TaskListResponse:
-        """
-        List all tasks.
+        """List all tasks.
 
         Args:
+          status: Filter tasks by status (e.g.
+
+        RUNNING, COMPLETED).
+
+          task_metadata:
+              JSON-encoded object used to filter tasks via JSONB containment. Example:
+              {"created_by_user_id": "abc-123"}.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -144,6 +154,8 @@ def list(
                         "order_direction": order_direction,
                         "page_number": page_number,
                         "relationships": relationships,
+                        "status": status,
+                        "task_metadata": task_metadata,
                     },
                     task_list_params.TaskListParams,
                 ),
@@ -679,17 +691,27 @@ async def list(
         order_direction: str | Omit = omit,
         page_number: int | Omit = omit,
         relationships: List[Literal["agents"]] | Omit = omit,
+        status: Optional[Literal["CANCELED", "COMPLETED", "FAILED", "RUNNING", "TERMINATED", "TIMED_OUT", "DELETED"]]
+        | Omit = omit,
+        task_metadata: Optional[str] | Omit = omit,
         # 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,
     ) -> TaskListResponse:
-        """
-        List all tasks.
+        """List all tasks.
 
         Args:
+          status: Filter tasks by status (e.g.
+
+        RUNNING, COMPLETED).
+
+          task_metadata:
+              JSON-encoded object used to filter tasks via JSONB containment. Example:
+              {"created_by_user_id": "abc-123"}.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -714,6 +736,8 @@ async def list(
                         "order_direction": order_direction,
                         "page_number": page_number,
                         "relationships": relationships,
+                        "status": status,
+                        "task_metadata": task_metadata,
                     },
                     task_list_params.TaskListParams,
                 ),

src/agentex/types/agent_rpc_by_name_params.py

@@ -35,6 +35,13 @@ class ParamsCreateTaskRequest(TypedDict, total=False):
     params: Optional[Dict[str, object]]
     """The parameters for the task"""
 
+    task_metadata: Optional[Dict[str, object]]
+    """Caller-provided metadata to persist on the task row.
+
+    Only applied at task creation; ignored if a task with this name already exists.
+    Forwarded to the agent inside the ACP payload for backward compatibility.
+    """
+
 
 class ParamsCancelTaskRequest(TypedDict, total=False):
     task_id: Optional[str]

src/agentex/types/agent_rpc_params.py

@@ -35,6 +35,13 @@ class ParamsCreateTaskRequest(TypedDict, total=False):
     params: Optional[Dict[str, object]]
     """The parameters for the task"""
 
+    task_metadata: Optional[Dict[str, object]]
+    """Caller-provided metadata to persist on the task row.
+
+    Only applied at task creation; ignored if a task with this name already exists.
+    Forwarded to the agent inside the ACP payload for backward compatibility.
+    """
+
 
 class ParamsCancelTaskRequest(TypedDict, total=False):
     task_id: Optional[str]

src/agentex/types/task_list_params.py

@@ -22,3 +22,12 @@ class TaskListParams(TypedDict, total=False):
     page_number: int
 
     relationships: List[Literal["agents"]]
+
+    status: Optional[Literal["CANCELED", "COMPLETED", "FAILED", "RUNNING", "TERMINATED", "TIMED_OUT", "DELETED"]]
+    """Filter tasks by status (e.g. RUNNING, COMPLETED)."""
+
+    task_metadata: Optional[str]
+    """JSON-encoded object used to filter tasks via JSONB containment.
+
+    Example: {"created_by_user_id": "abc-123"}.
+    """

tests/api_resources/test_agents.py

@@ -250,6 +250,7 @@ def test_method_rpc_with_all_params(self, client: Agentex) -> None:
             params={
                 "name": "name",
                 "params": {"foo": "bar"},
+                "task_metadata": {"foo": "bar"},
             },
             id=0,
             jsonrpc="2.0",
@@ -315,6 +316,7 @@ def test_method_rpc_by_name_with_all_params(self, client: Agentex) -> None:
             params={
                 "name": "name",
                 "params": {"foo": "bar"},
+                "task_metadata": {"foo": "bar"},
             },
             id=0,
             jsonrpc="2.0",
@@ -594,6 +596,7 @@ async def test_method_rpc_with_all_params(self, async_client: AsyncAgentex) -> N
             params={
                 "name": "name",
                 "params": {"foo": "bar"},
+                "task_metadata": {"foo": "bar"},
             },
             id=0,
             jsonrpc="2.0",
@@ -659,6 +662,7 @@ async def test_method_rpc_by_name_with_all_params(self, async_client: AsyncAgent
             params={
                 "name": "name",
                 "params": {"foo": "bar"},
+                "task_metadata": {"foo": "bar"},
             },
             id=0,
             jsonrpc="2.0",

tests/api_resources/test_tasks.py

@@ -93,6 +93,8 @@ def test_method_list_with_all_params(self, client: Agentex) -> None:
             order_direction="order_direction",
             page_number=0,
             relationships=["agents"],
+            status="CANCELED",
+            task_metadata="task_metadata",
         )
         assert_matches_type(TaskListResponse, task, path=["response"])
 
@@ -818,6 +820,8 @@ async def test_method_list_with_all_params(self, async_client: AsyncAgentex) ->
             order_direction="order_direction",
             page_number=0,
             relationships=["agents"],
+            status="CANCELED",
+            task_metadata="task_metadata",
         )
         assert_matches_type(TaskListResponse, task, path=["response"])