feat(webhooks): add configurable retries and manual replay

Stainless-Generated-From: cca1358

Author: stlc-bot

.stats.yml

@@ -1 +1 @@
-configured_endpoints: 41
+configured_endpoints: 45

api.md

@@ -167,6 +167,36 @@ Methods:
 - <code title="get /batch/{batch_id}/results">client.batch.<a href="./src/context/dev/resources/batch.py">get_results</a>(batch_id, \*\*<a href="src/context/dev/types/batch_get_results_params.py">params</a>) -> <a href="./src/context/dev/types/batch_get_results_response.py">BatchGetResultsResponse</a></code>
 - <code title="post /batch/submit">client.batch.<a href="./src/context/dev/resources/batch.py">submit</a>(\*\*<a href="src/context/dev/types/batch_submit_params.py">params</a>) -> <a href="./src/context/dev/types/batch_submit_response.py">BatchSubmitResponse</a></code>
 
+# Webhooks
+
+Types:
+
+```python
+from context.dev.types import RetryConfig
+```
+
+## Deliveries
+
+Types:
+
+```python
+from context.dev.types.webhooks import (
+    Attempt,
+    Delivery,
+    DeliveryRetrieveResponse,
+    DeliveryListResponse,
+    DeliveryListAttemptsResponse,
+    DeliveryRetryResponse,
+)
+```
+
+Methods:
+
+- <code title="get /webhooks/deliveries/{delivery_id}">client.webhooks.deliveries.<a href="./src/context/dev/resources/webhooks/deliveries.py">retrieve</a>(delivery_id, \*\*<a href="src/context/dev/types/webhooks/delivery_retrieve_params.py">params</a>) -> <a href="./src/context/dev/types/webhooks/delivery_retrieve_response.py">DeliveryRetrieveResponse</a></code>
+- <code title="get /webhooks/deliveries">client.webhooks.deliveries.<a href="./src/context/dev/resources/webhooks/deliveries.py">list</a>(\*\*<a href="src/context/dev/types/webhooks/delivery_list_params.py">params</a>) -> <a href="./src/context/dev/types/webhooks/delivery_list_response.py">DeliveryListResponse</a></code>
+- <code title="get /webhooks/deliveries/{delivery_id}/attempts">client.webhooks.deliveries.<a href="./src/context/dev/resources/webhooks/deliveries.py">list_attempts</a>(delivery_id, \*\*<a href="src/context/dev/types/webhooks/delivery_list_attempts_params.py">params</a>) -> <a href="./src/context/dev/types/webhooks/delivery_list_attempts_response.py">DeliveryListAttemptsResponse</a></code>
+- <code title="post /webhooks/deliveries/{delivery_id}/retry">client.webhooks.deliveries.<a href="./src/context/dev/resources/webhooks/deliveries.py">retry</a>(delivery_id, \*\*<a href="src/context/dev/types/webhooks/delivery_retry_params.py">params</a>) -> <a href="./src/context/dev/types/webhooks/delivery_retry_response.py">DeliveryRetryResponse</a></code>
+
 # People
 
 Types:

src/context/dev/_client.py

@@ -35,7 +35,7 @@
 )
 
 if TYPE_CHECKING:
-    from .resources import ai, web, news, batch, brand, parse, people, utility, industry, monitors
+    from .resources import ai, web, news, batch, brand, parse, people, utility, industry, monitors, webhooks
     from .resources.ai import AIResource, AsyncAIResource
     from .resources.web import WebResource, AsyncWebResource
     from .resources.news import NewsResource, AsyncNewsResource
@@ -46,6 +46,7 @@
     from .resources.utility import UtilityResource, AsyncUtilityResource
     from .resources.industry import IndustryResource, AsyncIndustryResource
     from .resources.monitors import MonitorsResource, AsyncMonitorsResource
+    from .resources.webhooks.webhooks import WebhooksResource, AsyncWebhooksResource
 
 __all__ = [
     "Timeout",
@@ -175,6 +176,12 @@ def batch(self) -> BatchResource:
 
         return BatchResource(self)
 
+    @cached_property
+    def webhooks(self) -> WebhooksResource:
+        from .resources.webhooks import WebhooksResource
+
+        return WebhooksResource(self)
+
     @cached_property
     def people(self) -> PeopleResource:
         from .resources.people import PeopleResource
@@ -417,6 +424,12 @@ def batch(self) -> AsyncBatchResource:
 
         return AsyncBatchResource(self)
 
+    @cached_property
+    def webhooks(self) -> AsyncWebhooksResource:
+        from .resources.webhooks import AsyncWebhooksResource
+
+        return AsyncWebhooksResource(self)
+
     @cached_property
     def people(self) -> AsyncPeopleResource:
         from .resources.people import AsyncPeopleResource
@@ -601,6 +614,12 @@ def batch(self) -> batch.BatchResourceWithRawResponse:
 
         return BatchResourceWithRawResponse(self._client.batch)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithRawResponse:
+        from .resources.webhooks import WebhooksResourceWithRawResponse
+
+        return WebhooksResourceWithRawResponse(self._client.webhooks)
+
     @cached_property
     def people(self) -> people.PeopleResourceWithRawResponse:
         from .resources.people import PeopleResourceWithRawResponse
@@ -673,6 +692,12 @@ def batch(self) -> batch.AsyncBatchResourceWithRawResponse:
 
         return AsyncBatchResourceWithRawResponse(self._client.batch)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithRawResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithRawResponse
+
+        return AsyncWebhooksResourceWithRawResponse(self._client.webhooks)
+
     @cached_property
     def people(self) -> people.AsyncPeopleResourceWithRawResponse:
         from .resources.people import AsyncPeopleResourceWithRawResponse
@@ -745,6 +770,12 @@ def batch(self) -> batch.BatchResourceWithStreamingResponse:
 
         return BatchResourceWithStreamingResponse(self._client.batch)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import WebhooksResourceWithStreamingResponse
+
+        return WebhooksResourceWithStreamingResponse(self._client.webhooks)
+
     @cached_property
     def people(self) -> people.PeopleResourceWithStreamingResponse:
         from .resources.people import PeopleResourceWithStreamingResponse
@@ -817,6 +848,12 @@ def batch(self) -> batch.AsyncBatchResourceWithStreamingResponse:
 
         return AsyncBatchResourceWithStreamingResponse(self._client.batch)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithStreamingResponse
+
+        return AsyncWebhooksResourceWithStreamingResponse(self._client.webhooks)
+
     @cached_property
     def people(self) -> people.AsyncPeopleResourceWithStreamingResponse:
         from .resources.people import AsyncPeopleResourceWithStreamingResponse

src/context/dev/resources/__init__.py

@@ -80,6 +80,14 @@
     MonitorsResourceWithStreamingResponse,
     AsyncMonitorsResourceWithStreamingResponse,
 )
+from .webhooks import (
+    WebhooksResource,
+    AsyncWebhooksResource,
+    WebhooksResourceWithRawResponse,
+    AsyncWebhooksResourceWithRawResponse,
+    WebhooksResourceWithStreamingResponse,
+    AsyncWebhooksResourceWithStreamingResponse,
+)
 
 __all__ = [
     "ParseResource",
@@ -130,6 +138,12 @@
     "AsyncBatchResourceWithRawResponse",
     "BatchResourceWithStreamingResponse",
     "AsyncBatchResourceWithStreamingResponse",
+    "WebhooksResource",
+    "AsyncWebhooksResource",
+    "WebhooksResourceWithRawResponse",
+    "AsyncWebhooksResourceWithRawResponse",
+    "WebhooksResourceWithStreamingResponse",
+    "AsyncWebhooksResourceWithStreamingResponse",
     "PeopleResource",
     "AsyncPeopleResource",
     "PeopleResourceWithRawResponse",

src/context/dev/resources/batch.py

@@ -283,6 +283,7 @@ def submit(
         *,
         input: batch_submit_params.Input,
         tags: SequenceNotStr[str] | Omit = omit,
+        webhook: batch_submit_params.Webhook | Omit = omit,
         webhook_url: str | Omit = omit,
         idempotency_key: str | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
@@ -300,7 +301,11 @@ def submit(
 
           tags: Tags stored on the batch. Filter the batch list by them later.
 
-          webhook_url: URL notified when the batch finishes.
+          webhook: Completion webhook settings. Cannot be combined with webhookUrl. Omitting retry
+              preserves legacy delivery; retry: {} opts into durable retries.
+
+          webhook_url: Legacy URL notified when the batch finishes. Preserves one best-effort attempt.
+              Cannot be combined with webhook.
 
           idempotency_key: Any string unique to this submission. Retries with the same key return the
               original batch.
@@ -320,6 +325,7 @@ def submit(
                 {
                     "input": input,
                     "tags": tags,
+                    "webhook": webhook,
                     "webhook_url": webhook_url,
                 },
                 batch_submit_params.BatchSubmitParams,
@@ -586,6 +592,7 @@ async def submit(
         *,
         input: batch_submit_params.Input,
         tags: SequenceNotStr[str] | Omit = omit,
+        webhook: batch_submit_params.Webhook | Omit = omit,
         webhook_url: str | Omit = omit,
         idempotency_key: str | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
@@ -603,7 +610,11 @@ async def submit(
 
           tags: Tags stored on the batch. Filter the batch list by them later.
 
-          webhook_url: URL notified when the batch finishes.
+          webhook: Completion webhook settings. Cannot be combined with webhookUrl. Omitting retry
+              preserves legacy delivery; retry: {} opts into durable retries.
+
+          webhook_url: Legacy URL notified when the batch finishes. Preserves one best-effort attempt.
+              Cannot be combined with webhook.
 
           idempotency_key: Any string unique to this submission. Retries with the same key return the
               original batch.
@@ -623,6 +634,7 @@ async def submit(
                 {
                     "input": input,
                     "tags": tags,
+                    "webhook": webhook,
                     "webhook_url": webhook_url,
                 },
                 batch_submit_params.BatchSubmitParams,

src/context/dev/resources/webhooks/__init__.py

@@ -0,0 +1,33 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from .webhooks import (
+    WebhooksResource,
+    AsyncWebhooksResource,
+    WebhooksResourceWithRawResponse,
+    AsyncWebhooksResourceWithRawResponse,
+    WebhooksResourceWithStreamingResponse,
+    AsyncWebhooksResourceWithStreamingResponse,
+)
+from .deliveries import (
+    DeliveriesResource,
+    AsyncDeliveriesResource,
+    DeliveriesResourceWithRawResponse,
+    AsyncDeliveriesResourceWithRawResponse,
+    DeliveriesResourceWithStreamingResponse,
+    AsyncDeliveriesResourceWithStreamingResponse,
+)
+
+__all__ = [
+    "DeliveriesResource",
+    "AsyncDeliveriesResource",
+    "DeliveriesResourceWithRawResponse",
+    "AsyncDeliveriesResourceWithRawResponse",
+    "DeliveriesResourceWithStreamingResponse",
+    "AsyncDeliveriesResourceWithStreamingResponse",
+    "WebhooksResource",
+    "AsyncWebhooksResource",
+    "WebhooksResourceWithRawResponse",
+    "AsyncWebhooksResourceWithRawResponse",
+    "WebhooksResourceWithStreamingResponse",
+    "AsyncWebhooksResourceWithStreamingResponse",
+]