feat(api): add webhook endpoint

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 64
+configured_endpoints: 65
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/sgp/agentex-sdk-cd43ba4b554ca024dd7ee7b74e4f4700a743282c17def704a0967e6ff251c09b.yml
 openapi_spec_hash: 9369ccc9c0289e9d6f641a526d244d1c
-config_hash: 138b7c0b394e7393133c8ff16a6d0eb3
+config_hash: 1ae003838971335aac550f3ad5872f54

api.md

@@ -245,3 +245,15 @@ Methods:
 - <code title="post /checkpoints/get-tuple">client.checkpoints.<a href="./src/agentex/resources/checkpoints.py">get_tuple</a>(\*\*<a href="src/agentex/types/checkpoint_get_tuple_params.py">params</a>) -> <a href="./src/agentex/types/checkpoint_get_tuple_response.py">Optional[CheckpointGetTupleResponse]</a></code>
 - <code title="post /checkpoints/put">client.checkpoints.<a href="./src/agentex/resources/checkpoints.py">put</a>(\*\*<a href="src/agentex/types/checkpoint_put_params.py">params</a>) -> <a href="./src/agentex/types/checkpoint_put_response.py">CheckpointPutResponse</a></code>
 - <code title="post /checkpoints/put-writes">client.checkpoints.<a href="./src/agentex/resources/checkpoints.py">put_writes</a>(\*\*<a href="src/agentex/types/checkpoint_put_writes_params.py">params</a>) -> None</code>
+
+# Webhooks
+
+Types:
+
+```python
+from agentex.types import WebhookCreateWebhookTriggerResponse
+```
+
+Methods:
+
+- <code title="post /agent_api_keys/webhook-trigger">client.webhooks.<a href="./src/agentex/resources/webhooks.py">create_webhook_trigger</a>(\*\*<a href="src/agentex/types/webhook_create_webhook_trigger_params.py">params</a>) -> <a href="./src/agentex/types/webhook_create_webhook_trigger_response.py">WebhookCreateWebhookTriggerResponse</a></code>

src/agentex/_client.py

@@ -35,12 +35,24 @@
 )
 
 if TYPE_CHECKING:
-    from .resources import spans, tasks, agents, events, states, tracker, messages, checkpoints, deployment_history
+    from .resources import (
+        spans,
+        tasks,
+        agents,
+        events,
+        states,
+        tracker,
+        messages,
+        webhooks,
+        checkpoints,
+        deployment_history,
+    )
     from .resources.spans import SpansResource, AsyncSpansResource
     from .resources.tasks import TasksResource, AsyncTasksResource
     from .resources.events import EventsResource, AsyncEventsResource
     from .resources.states import StatesResource, AsyncStatesResource
     from .resources.tracker import TrackerResource, AsyncTrackerResource
+    from .resources.webhooks import WebhooksResource, AsyncWebhooksResource
     from .resources.checkpoints import CheckpointsResource, AsyncCheckpointsResource
     from .resources.agents.agents import AgentsResource, AsyncAgentsResource
     from .resources.messages.messages import MessagesResource, AsyncMessagesResource
@@ -202,6 +214,12 @@ def checkpoints(self) -> CheckpointsResource:
 
         return CheckpointsResource(self)
 
+    @cached_property
+    def webhooks(self) -> WebhooksResource:
+        from .resources.webhooks import WebhooksResource
+
+        return WebhooksResource(self)
+
     @cached_property
     def with_raw_response(self) -> AgentexWithRawResponse:
         return AgentexWithRawResponse(self)
@@ -457,6 +475,12 @@ def checkpoints(self) -> AsyncCheckpointsResource:
 
         return AsyncCheckpointsResource(self)
 
+    @cached_property
+    def webhooks(self) -> AsyncWebhooksResource:
+        from .resources.webhooks import AsyncWebhooksResource
+
+        return AsyncWebhooksResource(self)
+
     @cached_property
     def with_raw_response(self) -> AsyncAgentexWithRawResponse:
         return AsyncAgentexWithRawResponse(self)
@@ -634,6 +658,12 @@ def checkpoints(self) -> checkpoints.CheckpointsResourceWithRawResponse:
 
         return CheckpointsResourceWithRawResponse(self._client.checkpoints)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithRawResponse:
+        from .resources.webhooks import WebhooksResourceWithRawResponse
+
+        return WebhooksResourceWithRawResponse(self._client.webhooks)
+
 
 class AsyncAgentexWithRawResponse:
     _client: AsyncAgentex
@@ -695,6 +725,12 @@ def checkpoints(self) -> checkpoints.AsyncCheckpointsResourceWithRawResponse:
 
         return AsyncCheckpointsResourceWithRawResponse(self._client.checkpoints)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithRawResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithRawResponse
+
+        return AsyncWebhooksResourceWithRawResponse(self._client.webhooks)
+
 
 class AgentexWithStreamedResponse:
     _client: Agentex
@@ -756,6 +792,12 @@ def checkpoints(self) -> checkpoints.CheckpointsResourceWithStreamingResponse:
 
         return CheckpointsResourceWithStreamingResponse(self._client.checkpoints)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import WebhooksResourceWithStreamingResponse
+
+        return WebhooksResourceWithStreamingResponse(self._client.webhooks)
+
 
 class AsyncAgentexWithStreamedResponse:
     _client: AsyncAgentex
@@ -817,6 +859,12 @@ def checkpoints(self) -> checkpoints.AsyncCheckpointsResourceWithStreamingRespon
 
         return AsyncCheckpointsResourceWithStreamingResponse(self._client.checkpoints)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithStreamingResponse
+
+        return AsyncWebhooksResourceWithStreamingResponse(self._client.webhooks)
+
 
 Client = Agentex
 

src/agentex/resources/__init__.py

@@ -56,6 +56,14 @@
     MessagesResourceWithStreamingResponse,
     AsyncMessagesResourceWithStreamingResponse,
 )
+from .webhooks import (
+    WebhooksResource,
+    AsyncWebhooksResource,
+    WebhooksResourceWithRawResponse,
+    AsyncWebhooksResourceWithRawResponse,
+    WebhooksResourceWithStreamingResponse,
+    AsyncWebhooksResourceWithStreamingResponse,
+)
 from .checkpoints import (
     CheckpointsResource,
     AsyncCheckpointsResource,
@@ -128,4 +136,10 @@
     "AsyncCheckpointsResourceWithRawResponse",
     "CheckpointsResourceWithStreamingResponse",
     "AsyncCheckpointsResourceWithStreamingResponse",
+    "WebhooksResource",
+    "AsyncWebhooksResource",
+    "WebhooksResourceWithRawResponse",
+    "AsyncWebhooksResourceWithRawResponse",
+    "WebhooksResourceWithStreamingResponse",
+    "AsyncWebhooksResourceWithStreamingResponse",
 ]

src/agentex/resources/tasks.py

@@ -554,6 +554,7 @@ def update_by_id(
         self,
         task_id: str,
         *,
+        merge_params: Optional[Dict[str, object]] | Omit = omit,
         task_metadata: Optional[Dict[str, object]] | 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.
@@ -578,7 +579,13 @@ def update_by_id(
             raise ValueError(f"Expected a non-empty value for `task_id` but received {task_id!r}")
         return self._put(
             path_template("/tasks/{task_id}", task_id=task_id),
-            body=maybe_transform({"task_metadata": task_metadata}, task_update_by_id_params.TaskUpdateByIDParams),
+            body=maybe_transform(
+                {
+                    "merge_params": merge_params,
+                    "task_metadata": task_metadata,
+                },
+                task_update_by_id_params.TaskUpdateByIDParams,
+            ),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
@@ -589,6 +596,7 @@ def update_by_name(
         self,
         task_name: str,
         *,
+        merge_params: Optional[Dict[str, object]] | Omit = omit,
         task_metadata: Optional[Dict[str, object]] | 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.
@@ -613,7 +621,13 @@ def update_by_name(
             raise ValueError(f"Expected a non-empty value for `task_name` but received {task_name!r}")
         return self._put(
             path_template("/tasks/name/{task_name}", task_name=task_name),
-            body=maybe_transform({"task_metadata": task_metadata}, task_update_by_name_params.TaskUpdateByNameParams),
+            body=maybe_transform(
+                {
+                    "merge_params": merge_params,
+                    "task_metadata": task_metadata,
+                },
+                task_update_by_name_params.TaskUpdateByNameParams,
+            ),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
@@ -1136,6 +1150,7 @@ async def update_by_id(
         self,
         task_id: str,
         *,
+        merge_params: Optional[Dict[str, object]] | Omit = omit,
         task_metadata: Optional[Dict[str, object]] | 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.
@@ -1161,7 +1176,11 @@ async def update_by_id(
         return await self._put(
             path_template("/tasks/{task_id}", task_id=task_id),
             body=await async_maybe_transform(
-                {"task_metadata": task_metadata}, task_update_by_id_params.TaskUpdateByIDParams
+                {
+                    "merge_params": merge_params,
+                    "task_metadata": task_metadata,
+                },
+                task_update_by_id_params.TaskUpdateByIDParams,
             ),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
@@ -1173,6 +1192,7 @@ async def update_by_name(
         self,
         task_name: str,
         *,
+        merge_params: Optional[Dict[str, object]] | Omit = omit,
         task_metadata: Optional[Dict[str, object]] | 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.
@@ -1198,7 +1218,11 @@ async def update_by_name(
         return await self._put(
             path_template("/tasks/name/{task_name}", task_name=task_name),
             body=await async_maybe_transform(
-                {"task_metadata": task_metadata}, task_update_by_name_params.TaskUpdateByNameParams
+                {
+                    "merge_params": merge_params,
+                    "task_metadata": task_metadata,
+                },
+                task_update_by_name_params.TaskUpdateByNameParams,
             ),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout