chore(api): update composite API spec

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 1856
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-90808d61c82855d01afed337662c50972dc6ac8b779763650cecef6541c2d5cc.yml
-openapi_spec_hash: 5c9d36950e74e02161a89f5051bccef1
+configured_endpoints: 1857
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-25948e3293c7ca8798d7722f962cf2fc566faa8880489e0746d3a16f1e02e523.yml
+openapi_spec_hash: 97e3f177c34640dd60815a578f1ed7bd
 config_hash: 8b4b3138e3a18ef5db3b0cadffd36a6e

api.md

@@ -2772,6 +2772,7 @@ from cloudflare.types.queues import (
     SubscriptionUpdateResponse,
     SubscriptionListResponse,
     SubscriptionDeleteResponse,
+    SubscriptionGetResponse,
 )
 ```
 
@@ -2781,6 +2782,7 @@ Methods:
 - <code title="patch /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">update</a>(subscription_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/subscription_update_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/subscription_update_response.py">Optional[SubscriptionUpdateResponse]</a></code>
 - <code title="get /accounts/{account_id}/event_subscriptions/subscriptions">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">list</a>(\*, account_id, \*\*<a href="src/cloudflare/types/queues/subscription_list_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/subscription_list_response.py">SyncV4PagePaginationArray[SubscriptionListResponse]</a></code>
 - <code title="delete /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">delete</a>(subscription_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/subscription_delete_response.py">Optional[SubscriptionDeleteResponse]</a></code>
+- <code title="get /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">get</a>(subscription_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/subscription_get_response.py">Optional[SubscriptionGetResponse]</a></code>
 
 # APIGateway
 

src/cloudflare/resources/queues/subscriptions.py

@@ -21,6 +21,7 @@
 from ...pagination import SyncV4PagePaginationArray, AsyncV4PagePaginationArray
 from ..._base_client import AsyncPaginator, make_request_options
 from ...types.queues import subscription_list_params, subscription_create_params, subscription_update_params
+from ...types.queues.subscription_get_response import SubscriptionGetResponse
 from ...types.queues.subscription_list_response import SubscriptionListResponse
 from ...types.queues.subscription_create_response import SubscriptionCreateResponse
 from ...types.queues.subscription_delete_response import SubscriptionDeleteResponse
@@ -282,6 +283,50 @@ def delete(
             cast_to=cast(Type[Optional[SubscriptionDeleteResponse]], ResultWrapper[SubscriptionDeleteResponse]),
         )
 
+    def get(
+        self,
+        subscription_id: str,
+        *,
+        account_id: str,
+        # 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,
+    ) -> Optional[SubscriptionGetResponse]:
+        """
+        Get details about an existing event subscription
+
+        Args:
+          account_id: A Resource identifier.
+
+          subscription_id: A Resource identifier.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not account_id:
+            raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
+        if not subscription_id:
+            raise ValueError(f"Expected a non-empty value for `subscription_id` but received {subscription_id!r}")
+        return self._get(
+            f"/accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}",
+            options=make_request_options(
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[SubscriptionGetResponse]]._unwrapper,
+            ),
+            cast_to=cast(Type[Optional[SubscriptionGetResponse]], ResultWrapper[SubscriptionGetResponse]),
+        )
+
 
 class AsyncSubscriptionsResource(AsyncAPIResource):
     @cached_property
@@ -536,6 +581,50 @@ async def delete(
             cast_to=cast(Type[Optional[SubscriptionDeleteResponse]], ResultWrapper[SubscriptionDeleteResponse]),
         )
 
+    async def get(
+        self,
+        subscription_id: str,
+        *,
+        account_id: str,
+        # 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,
+    ) -> Optional[SubscriptionGetResponse]:
+        """
+        Get details about an existing event subscription
+
+        Args:
+          account_id: A Resource identifier.
+
+          subscription_id: A Resource identifier.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not account_id:
+            raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
+        if not subscription_id:
+            raise ValueError(f"Expected a non-empty value for `subscription_id` but received {subscription_id!r}")
+        return await self._get(
+            f"/accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}",
+            options=make_request_options(
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[SubscriptionGetResponse]]._unwrapper,
+            ),
+            cast_to=cast(Type[Optional[SubscriptionGetResponse]], ResultWrapper[SubscriptionGetResponse]),
+        )
+
 
 class SubscriptionsResourceWithRawResponse:
     def __init__(self, subscriptions: SubscriptionsResource) -> None:
@@ -553,6 +642,9 @@ def __init__(self, subscriptions: SubscriptionsResource) -> None:
         self.delete = to_raw_response_wrapper(
             subscriptions.delete,
         )
+        self.get = to_raw_response_wrapper(
+            subscriptions.get,
+        )
 
 
 class AsyncSubscriptionsResourceWithRawResponse:
@@ -571,6 +663,9 @@ def __init__(self, subscriptions: AsyncSubscriptionsResource) -> None:
         self.delete = async_to_raw_response_wrapper(
             subscriptions.delete,
         )
+        self.get = async_to_raw_response_wrapper(
+            subscriptions.get,
+        )
 
 
 class SubscriptionsResourceWithStreamingResponse:
@@ -589,6 +684,9 @@ def __init__(self, subscriptions: SubscriptionsResource) -> None:
         self.delete = to_streamed_response_wrapper(
             subscriptions.delete,
         )
+        self.get = to_streamed_response_wrapper(
+            subscriptions.get,
+        )
 
 
 class AsyncSubscriptionsResourceWithStreamingResponse:
@@ -607,3 +705,6 @@ def __init__(self, subscriptions: AsyncSubscriptionsResource) -> None:
         self.delete = async_to_streamed_response_wrapper(
             subscriptions.delete,
         )
+        self.get = async_to_streamed_response_wrapper(
+            subscriptions.get,
+        )

src/cloudflare/resources/r2/buckets/event_notifications.py

@@ -52,7 +52,7 @@ def update(
         *,
         account_id: str,
         bucket_name: str,
-        rules: Iterable[event_notification_update_params.Rule] | Omit = omit,
+        rules: Iterable[event_notification_update_params.Rule],
         jurisdiction: Literal["default", "eu", "fedramp"] | 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.
@@ -298,7 +298,7 @@ async def update(
         *,
         account_id: str,
         bucket_name: str,
-        rules: Iterable[event_notification_update_params.Rule] | Omit = omit,
+        rules: Iterable[event_notification_update_params.Rule],
         jurisdiction: Literal["default", "eu", "fedramp"] | 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.

src/cloudflare/resources/zero_trust/access/applications/applications.py

@@ -2436,6 +2436,7 @@ def list(
         page: int | Omit = omit,
         per_page: int | Omit = omit,
         search: str | Omit = omit,
+        target_attributes: 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,
@@ -2465,6 +2466,8 @@ def list(
 
           search: Search for apps by other listed query parameters.
 
+          target_attributes: Target Criteria attributes in key=value format.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -2502,6 +2505,7 @@ def list(
                         "page": page,
                         "per_page": per_page,
                         "search": search,
+                        "target_attributes": target_attributes,
                     },
                     application_list_params.ApplicationListParams,
                 ),
@@ -5041,6 +5045,7 @@ def list(
         page: int | Omit = omit,
         per_page: int | Omit = omit,
         search: str | Omit = omit,
+        target_attributes: 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,
@@ -5070,6 +5075,8 @@ def list(
 
           search: Search for apps by other listed query parameters.
 
+          target_attributes: Target Criteria attributes in key=value format.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -5107,6 +5114,7 @@ def list(
                         "page": page,
                         "per_page": per_page,
                         "search": search,
+                        "target_attributes": target_attributes,
                     },
                     application_list_params.ApplicationListParams,
                 ),

src/cloudflare/types/queues/__init__.py

@@ -21,6 +21,7 @@
 from .consumer_delete_response import ConsumerDeleteResponse as ConsumerDeleteResponse
 from .message_bulk_push_params import MessageBulkPushParams as MessageBulkPushParams
 from .subscription_list_params import SubscriptionListParams as SubscriptionListParams
+from .subscription_get_response import SubscriptionGetResponse as SubscriptionGetResponse
 from .message_bulk_push_response import MessageBulkPushResponse as MessageBulkPushResponse
 from .subscription_create_params import SubscriptionCreateParams as SubscriptionCreateParams
 from .subscription_list_response import SubscriptionListResponse as SubscriptionListResponse

src/cloudflare/types/queues/subscription_get_response.py

@@ -0,0 +1,118 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import List, Union, Optional
+from datetime import datetime
+from typing_extensions import Literal, TypeAlias
+
+from pydantic import Field as FieldInfo
+
+from ..._models import BaseModel
+
+__all__ = [
+    "SubscriptionGetResponse",
+    "Destination",
+    "Source",
+    "SourceMqEventSourceImages",
+    "SourceMqEventSourceKV",
+    "SourceMqEventSourceR2",
+    "SourceMqEventSourceSuperSlurper",
+    "SourceMqEventSourceVectorize",
+    "SourceMqEventSourceWorkersAIModel",
+    "SourceMqEventSourceWorkersBuildsWorker",
+    "SourceMqEventSourceWorkflowsWorkflow",
+]
+
+
+class Destination(BaseModel):
+    queue_id: str
+    """ID of the target queue"""
+
+    type: Literal["queues.queue"]
+    """Type of destination"""
+
+
+class SourceMqEventSourceImages(BaseModel):
+    type: Optional[Literal["images"]] = None
+    """Type of source"""
+
+
+class SourceMqEventSourceKV(BaseModel):
+    type: Optional[Literal["kv"]] = None
+    """Type of source"""
+
+
+class SourceMqEventSourceR2(BaseModel):
+    type: Optional[Literal["r2"]] = None
+    """Type of source"""
+
+
+class SourceMqEventSourceSuperSlurper(BaseModel):
+    type: Optional[Literal["superSlurper"]] = None
+    """Type of source"""
+
+
+class SourceMqEventSourceVectorize(BaseModel):
+    type: Optional[Literal["vectorize"]] = None
+    """Type of source"""
+
+
+class SourceMqEventSourceWorkersAIModel(BaseModel):
+    ai_model_name: Optional[str] = FieldInfo(alias="model_name", default=None)
+    """Name of the Workers AI model"""
+
+    type: Optional[Literal["workersAi.model"]] = None
+    """Type of source"""
+
+
+class SourceMqEventSourceWorkersBuildsWorker(BaseModel):
+    type: Optional[Literal["workersBuilds.worker"]] = None
+    """Type of source"""
+
+    worker_name: Optional[str] = None
+    """Name of the worker"""
+
+
+class SourceMqEventSourceWorkflowsWorkflow(BaseModel):
+    type: Optional[Literal["workflows.workflow"]] = None
+    """Type of source"""
+
+    workflow_name: Optional[str] = None
+    """Name of the workflow"""
+
+
+Source: TypeAlias = Union[
+    SourceMqEventSourceImages,
+    SourceMqEventSourceKV,
+    SourceMqEventSourceR2,
+    SourceMqEventSourceSuperSlurper,
+    SourceMqEventSourceVectorize,
+    SourceMqEventSourceWorkersAIModel,
+    SourceMqEventSourceWorkersBuildsWorker,
+    SourceMqEventSourceWorkflowsWorkflow,
+]
+
+
+class SubscriptionGetResponse(BaseModel):
+    id: str
+    """Unique identifier for the subscription"""
+
+    created_at: datetime
+    """When the subscription was created"""
+
+    destination: Destination
+    """Destination configuration for the subscription"""
+
+    enabled: bool
+    """Whether the subscription is active"""
+
+    events: List[str]
+    """List of event types this subscription handles"""
+
+    modified_at: datetime
+    """When the subscription was last modified"""
+
+    name: str
+    """Name of the subscription"""
+
+    source: Source
+    """Source configuration for the subscription"""

src/cloudflare/types/r2/buckets/event_notification_update_params.py

@@ -17,7 +17,7 @@ class EventNotificationUpdateParams(TypedDict, total=False):
     bucket_name: Required[str]
     """Name of the bucket."""
 
-    rules: Iterable[Rule]
+    rules: Required[Iterable[Rule]]
     """Array of rules to drive notifications."""
 
     jurisdiction: Annotated[Literal["default", "eu", "fedramp"], PropertyInfo(alias="cf-r2-jurisdiction")]

src/cloudflare/types/zero_trust/access/application_list_params.py

@@ -34,3 +34,6 @@ class ApplicationListParams(TypedDict, total=False):
 
     search: str
     """Search for apps by other listed query parameters."""
+
+    target_attributes: str
+    """Target Criteria attributes in key=value format."""