chore(api): update composite API spec

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 2163
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-7675b265d629354e193126ffad8e93efb804186cd581c0d45059547a015b7151.yml
-openapi_spec_hash: 12d024b8abf3333c2326cf51a933ba39
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-84d0d84326a7be69e6cd320f5e0c6b7e7ec559809c66195ec4326020091c47e7.yml
+openapi_spec_hash: 6e6c10f0ac9c9272670f1cb025e8523c
 config_hash: aebbf0fc2e33e6126d43d201bfa58e25

api.md

@@ -2885,9 +2885,9 @@ from cloudflare.types.queues import (
 Methods:
 
 - <code title="post /accounts/{account_id}/queues/{queue_id}/messages/ack">client.queues.messages.<a href="./src/cloudflare/resources/queues/messages.py">ack</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/message_ack_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/message_ack_response.py">Optional[MessageAckResponse]</a></code>
-- <code title="post /accounts/{account_id}/queues/{queue_id}/messages/batch">client.queues.messages.<a href="./src/cloudflare/resources/queues/messages.py">bulk_push</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/message_bulk_push_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/message_bulk_push_response.py">MessageBulkPushResponse</a></code>
+- <code title="post /accounts/{account_id}/queues/{queue_id}/messages/batch">client.queues.messages.<a href="./src/cloudflare/resources/queues/messages.py">bulk_push</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/message_bulk_push_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/message_bulk_push_response.py">Optional[MessageBulkPushResponse]</a></code>
 - <code title="post /accounts/{account_id}/queues/{queue_id}/messages/pull">client.queues.messages.<a href="./src/cloudflare/resources/queues/messages.py">pull</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/message_pull_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/message_pull_response.py">Optional[MessagePullResponse]</a></code>
-- <code title="post /accounts/{account_id}/queues/{queue_id}/messages">client.queues.messages.<a href="./src/cloudflare/resources/queues/messages.py">push</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/message_push_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/message_push_response.py">MessagePushResponse</a></code>
+- <code title="post /accounts/{account_id}/queues/{queue_id}/messages">client.queues.messages.<a href="./src/cloudflare/resources/queues/messages.py">push</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/message_push_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/message_push_response.py">Optional[MessagePushResponse]</a></code>
 
 ## Purge
 

src/cloudflare/resources/queues/messages.py

@@ -116,7 +116,7 @@ def bulk_push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessageBulkPushResponse:
+    ) -> Optional[MessageBulkPushResponse]:
         """
         Push a batch of message to a Queue
 
@@ -151,9 +151,13 @@ def bulk_push(
                 message_bulk_push_params.MessageBulkPushParams,
             ),
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[MessageBulkPushResponse]]._unwrapper,
             ),
-            cast_to=MessageBulkPushResponse,
+            cast_to=cast(Type[Optional[MessageBulkPushResponse]], ResultWrapper[MessageBulkPushResponse]),
         )
 
     def pull(
@@ -231,7 +235,7 @@ def push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessagePushResponse:
+    ) -> Optional[MessagePushResponse]:
         """
         Push a message to a Queue
 
@@ -268,7 +272,7 @@ def push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessagePushResponse:
+    ) -> Optional[MessagePushResponse]:
         """
         Push a message to a Queue
 
@@ -304,7 +308,7 @@ def push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessagePushResponse:
+    ) -> Optional[MessagePushResponse]:
         if account_id is None:
             account_id = self._client._get_account_id_path_param()
         if not account_id:
@@ -322,9 +326,13 @@ def push(
                 message_push_params.MessagePushParams,
             ),
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[MessagePushResponse]]._unwrapper,
             ),
-            cast_to=MessagePushResponse,
+            cast_to=cast(Type[Optional[MessagePushResponse]], ResultWrapper[MessagePushResponse]),
         )
 
 
@@ -416,7 +424,7 @@ async def bulk_push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessageBulkPushResponse:
+    ) -> Optional[MessageBulkPushResponse]:
         """
         Push a batch of message to a Queue
 
@@ -451,9 +459,13 @@ async def bulk_push(
                 message_bulk_push_params.MessageBulkPushParams,
             ),
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[MessageBulkPushResponse]]._unwrapper,
             ),
-            cast_to=MessageBulkPushResponse,
+            cast_to=cast(Type[Optional[MessageBulkPushResponse]], ResultWrapper[MessageBulkPushResponse]),
         )
 
     async def pull(
@@ -531,7 +543,7 @@ async def push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessagePushResponse:
+    ) -> Optional[MessagePushResponse]:
         """
         Push a message to a Queue
 
@@ -568,7 +580,7 @@ async def push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessagePushResponse:
+    ) -> Optional[MessagePushResponse]:
         """
         Push a message to a Queue
 
@@ -604,7 +616,7 @@ async def push(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> MessagePushResponse:
+    ) -> Optional[MessagePushResponse]:
         if account_id is None:
             account_id = self._client._get_account_id_path_param()
         if not account_id:
@@ -622,9 +634,13 @@ async def push(
                 message_push_params.MessagePushParams,
             ),
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[MessagePushResponse]]._unwrapper,
             ),
-            cast_to=MessagePushResponse,
+            cast_to=cast(Type[Optional[MessagePushResponse]], ResultWrapper[MessagePushResponse]),
         )
 
 

src/cloudflare/types/queues/message_bulk_push_response.py

@@ -1,18 +1,39 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
-from typing import List, Optional
-from typing_extensions import Literal
+from typing import Optional
 
 from ..._models import BaseModel
-from ..shared.response_info import ResponseInfo
 
-__all__ = ["MessageBulkPushResponse"]
+__all__ = ["MessageBulkPushResponse", "Metadata", "MetadataMetrics"]
 
 
-class MessageBulkPushResponse(BaseModel):
-    errors: Optional[List[ResponseInfo]] = None
+class MetadataMetrics(BaseModel):
+    """Best-effort metrics for the queue.
+
+    Values may be approximate due to the distributed nature of queues.
+    """
+
+    backlog_bytes: float
+    """The size in bytes of unacknowledged messages in the queue."""
+
+    backlog_count: float
+    """The number of unacknowledged messages in the queue."""
+
+    oldest_message_timestamp_ms: float
+    """Unix timestamp in milliseconds of the oldest unacknowledged message in the
+    queue.
 
-    messages: Optional[List[str]] = None
+    Returns 0 if unknown.
+    """
 
-    success: Optional[Literal[True]] = None
-    """Indicates if the API call was successful or not."""
+
+class Metadata(BaseModel):
+    metrics: Optional[MetadataMetrics] = None
+    """Best-effort metrics for the queue.
+
+    Values may be approximate due to the distributed nature of queues.
+    """
+
+
+class MessageBulkPushResponse(BaseModel):
+    metadata: Optional[Metadata] = None

src/cloudflare/types/queues/message_pull_response.py

@@ -4,7 +4,7 @@
 
 from ..._models import BaseModel
 
-__all__ = ["MessagePullResponse", "Message"]
+__all__ = ["MessagePullResponse", "Message", "Metadata", "MetadataMetrics"]
 
 
 class Message(BaseModel):
@@ -25,8 +25,38 @@ class Message(BaseModel):
     timestamp_ms: Optional[float] = None
 
 
+class MetadataMetrics(BaseModel):
+    """Best-effort metrics for the queue.
+
+    Values may be approximate due to the distributed nature of queues.
+    """
+
+    backlog_bytes: float
+    """The size in bytes of unacknowledged messages in the queue."""
+
+    backlog_count: float
+    """The number of unacknowledged messages in the queue."""
+
+    oldest_message_timestamp_ms: float
+    """Unix timestamp in milliseconds of the oldest unacknowledged message in the
+    queue.
+
+    Returns 0 if unknown.
+    """
+
+
+class Metadata(BaseModel):
+    metrics: Optional[MetadataMetrics] = None
+    """Best-effort metrics for the queue.
+
+    Values may be approximate due to the distributed nature of queues.
+    """
+
+
 class MessagePullResponse(BaseModel):
     message_backlog_count: Optional[float] = None
-    """The number of unacknowledged messages in the queue"""
+    """The number of unacknowledged messages in the queue."""
 
     messages: Optional[List[Message]] = None
+
+    metadata: Optional[Metadata] = None

src/cloudflare/types/queues/message_push_response.py

@@ -1,18 +1,39 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
-from typing import List, Optional
-from typing_extensions import Literal
+from typing import Optional
 
 from ..._models import BaseModel
-from ..shared.response_info import ResponseInfo
 
-__all__ = ["MessagePushResponse"]
+__all__ = ["MessagePushResponse", "Metadata", "MetadataMetrics"]
 
 
-class MessagePushResponse(BaseModel):
-    errors: Optional[List[ResponseInfo]] = None
+class MetadataMetrics(BaseModel):
+    """Best-effort metrics for the queue.
+
+    Values may be approximate due to the distributed nature of queues.
+    """
+
+    backlog_bytes: float
+    """The size in bytes of unacknowledged messages in the queue."""
+
+    backlog_count: float
+    """The number of unacknowledged messages in the queue."""
+
+    oldest_message_timestamp_ms: float
+    """Unix timestamp in milliseconds of the oldest unacknowledged message in the
+    queue.
 
-    messages: Optional[List[str]] = None
+    Returns 0 if unknown.
+    """
 
-    success: Optional[Literal[True]] = None
-    """Indicates if the API call was successful or not."""
+
+class Metadata(BaseModel):
+    metrics: Optional[MetadataMetrics] = None
+    """Best-effort metrics for the queue.
+
+    Values may be approximate due to the distributed nature of queues.
+    """
+
+
+class MessagePushResponse(BaseModel):
+    metadata: Optional[Metadata] = None