feat: fix: broken reference for the queues 'consumer' model

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 2037
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-9ba099b7936091cc984d2a24fc4d32c3ffcb1d71d86412c8c9084d201e16b3ac.yml
 openapi_spec_hash: 45edc9a107cf5a5e3b204b230b0d336d
-config_hash: ff14fec6c5fcb182b433bbc41609608b
+config_hash: e3be580c8a7e39157925fab6ac9dd3ad

api.md

@@ -2805,22 +2805,16 @@ Methods:
 Types:
 
 ```python
-from cloudflare.types.queues import (
-    ConsumerCreateResponse,
-    ConsumerUpdateResponse,
-    ConsumerListResponse,
-    ConsumerDeleteResponse,
-    ConsumerGetResponse,
-)
+from cloudflare.types.queues import Consumer, ConsumerDeleteResponse
 ```
 
 Methods:
 
-- <code title="post /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">create</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/consumer_create_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer_create_response.py">Optional[ConsumerCreateResponse]</a></code>
-- <code title="put /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">update</a>(consumer_id, \*, account_id, queue_id, \*\*<a href="src/cloudflare/types/queues/consumer_update_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer_update_response.py">Optional[ConsumerUpdateResponse]</a></code>
-- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">list</a>(queue_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/consumer_list_response.py">SyncSinglePage[ConsumerListResponse]</a></code>
+- <code title="post /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">create</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/consumer_create_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
+- <code title="put /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">update</a>(consumer_id, \*, account_id, queue_id, \*\*<a href="src/cloudflare/types/queues/consumer_update_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
+- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">list</a>(queue_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/consumer.py">SyncSinglePage[Consumer]</a></code>
 - <code title="delete /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">delete</a>(consumer_id, \*, account_id, queue_id) -> <a href="./src/cloudflare/types/queues/consumer_delete_response.py">ConsumerDeleteResponse</a></code>
-- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">get</a>(consumer_id, \*, account_id, queue_id) -> <a href="./src/cloudflare/types/queues/consumer_get_response.py">Optional[ConsumerGetResponse]</a></code>
+- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">get</a>(consumer_id, \*, account_id, queue_id) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
 
 ## Subscriptions
 

src/cloudflare/resources/queues/consumers.py

@@ -21,11 +21,8 @@
 from ...pagination import SyncSinglePage, AsyncSinglePage
 from ..._base_client import AsyncPaginator, make_request_options
 from ...types.queues import consumer_create_params, consumer_update_params
-from ...types.queues.consumer_get_response import ConsumerGetResponse
-from ...types.queues.consumer_list_response import ConsumerListResponse
-from ...types.queues.consumer_create_response import ConsumerCreateResponse
+from ...types.queues.consumer import Consumer
 from ...types.queues.consumer_delete_response import ConsumerDeleteResponse
-from ...types.queues.consumer_update_response import ConsumerUpdateResponse
 
 __all__ = ["ConsumersResource", "AsyncConsumersResource"]
 
@@ -66,7 +63,7 @@ def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerCreateResponse]:
+    ) -> Optional[Consumer]:
         """
         Creates a new consumer for a Queue
 
@@ -102,7 +99,7 @@ def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerCreateResponse]:
+    ) -> Optional[Consumer]:
         """
         Creates a new consumer for a Queue
 
@@ -139,13 +136,13 @@ def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerCreateResponse]:
+    ) -> Optional[Consumer]:
         if not account_id:
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
         if not queue_id:
             raise ValueError(f"Expected a non-empty value for `queue_id` but received {queue_id!r}")
         return cast(
-            Optional[ConsumerCreateResponse],
+            Optional[Consumer],
             self._post(
                 f"/accounts/{account_id}/queues/{queue_id}/consumers",
                 body=maybe_transform(
@@ -162,10 +159,10 @@ def create(
                     extra_query=extra_query,
                     extra_body=extra_body,
                     timeout=timeout,
-                    post_parser=ResultWrapper[Optional[ConsumerCreateResponse]]._unwrapper,
+                    post_parser=ResultWrapper[Optional[Consumer]]._unwrapper,
                 ),
                 cast_to=cast(
-                    Any, ResultWrapper[ConsumerCreateResponse]
+                    Any, ResultWrapper[Consumer]
                 ),  # Union types cannot be passed in as arguments in the type system
             ),
         )
@@ -187,7 +184,7 @@ def update(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerUpdateResponse]:
+    ) -> Optional[Consumer]:
         """
         Updates the consumer for a queue, or creates one if it does not exist.
 
@@ -226,7 +223,7 @@ def update(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerUpdateResponse]:
+    ) -> Optional[Consumer]:
         """
         Updates the consumer for a queue, or creates one if it does not exist.
 
@@ -266,15 +263,15 @@ def update(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerUpdateResponse]:
+    ) -> Optional[Consumer]:
         if not account_id:
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
         if not queue_id:
             raise ValueError(f"Expected a non-empty value for `queue_id` but received {queue_id!r}")
         if not consumer_id:
             raise ValueError(f"Expected a non-empty value for `consumer_id` but received {consumer_id!r}")
         return cast(
-            Optional[ConsumerUpdateResponse],
+            Optional[Consumer],
             self._put(
                 f"/accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}",
                 body=maybe_transform(
@@ -291,10 +288,10 @@ def update(
                     extra_query=extra_query,
                     extra_body=extra_body,
                     timeout=timeout,
-                    post_parser=ResultWrapper[Optional[ConsumerUpdateResponse]]._unwrapper,
+                    post_parser=ResultWrapper[Optional[Consumer]]._unwrapper,
                 ),
                 cast_to=cast(
-                    Any, ResultWrapper[ConsumerUpdateResponse]
+                    Any, ResultWrapper[Consumer]
                 ),  # Union types cannot be passed in as arguments in the type system
             ),
         )
@@ -310,7 +307,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> SyncSinglePage[ConsumerListResponse]:
+    ) -> SyncSinglePage[Consumer]:
         """
         Returns the consumers for a Queue
 
@@ -333,11 +330,11 @@ def list(
             raise ValueError(f"Expected a non-empty value for `queue_id` but received {queue_id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/queues/{queue_id}/consumers",
-            page=SyncSinglePage[ConsumerListResponse],
+            page=SyncSinglePage[Consumer],
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
-            model=cast(Any, ConsumerListResponse),  # Union types cannot be passed in as arguments in the type system
+            model=cast(Any, Consumer),  # Union types cannot be passed in as arguments in the type system
         )
 
     def delete(
@@ -397,7 +394,7 @@ def get(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerGetResponse]:
+    ) -> Optional[Consumer]:
         """
         Fetches the consumer for a queue by consumer id
 
@@ -423,18 +420,18 @@ def get(
         if not consumer_id:
             raise ValueError(f"Expected a non-empty value for `consumer_id` but received {consumer_id!r}")
         return cast(
-            Optional[ConsumerGetResponse],
+            Optional[Consumer],
             self._get(
                 f"/accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}",
                 options=make_request_options(
                     extra_headers=extra_headers,
                     extra_query=extra_query,
                     extra_body=extra_body,
                     timeout=timeout,
-                    post_parser=ResultWrapper[Optional[ConsumerGetResponse]]._unwrapper,
+                    post_parser=ResultWrapper[Optional[Consumer]]._unwrapper,
                 ),
                 cast_to=cast(
-                    Any, ResultWrapper[ConsumerGetResponse]
+                    Any, ResultWrapper[Consumer]
                 ),  # Union types cannot be passed in as arguments in the type system
             ),
         )
@@ -476,7 +473,7 @@ async def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerCreateResponse]:
+    ) -> Optional[Consumer]:
         """
         Creates a new consumer for a Queue
 
@@ -512,7 +509,7 @@ async def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerCreateResponse]:
+    ) -> Optional[Consumer]:
         """
         Creates a new consumer for a Queue
 
@@ -549,13 +546,13 @@ async def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerCreateResponse]:
+    ) -> Optional[Consumer]:
         if not account_id:
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
         if not queue_id:
             raise ValueError(f"Expected a non-empty value for `queue_id` but received {queue_id!r}")
         return cast(
-            Optional[ConsumerCreateResponse],
+            Optional[Consumer],
             await self._post(
                 f"/accounts/{account_id}/queues/{queue_id}/consumers",
                 body=await async_maybe_transform(
@@ -572,10 +569,10 @@ async def create(
                     extra_query=extra_query,
                     extra_body=extra_body,
                     timeout=timeout,
-                    post_parser=ResultWrapper[Optional[ConsumerCreateResponse]]._unwrapper,
+                    post_parser=ResultWrapper[Optional[Consumer]]._unwrapper,
                 ),
                 cast_to=cast(
-                    Any, ResultWrapper[ConsumerCreateResponse]
+                    Any, ResultWrapper[Consumer]
                 ),  # Union types cannot be passed in as arguments in the type system
             ),
         )
@@ -597,7 +594,7 @@ async def update(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerUpdateResponse]:
+    ) -> Optional[Consumer]:
         """
         Updates the consumer for a queue, or creates one if it does not exist.
 
@@ -636,7 +633,7 @@ async def update(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerUpdateResponse]:
+    ) -> Optional[Consumer]:
         """
         Updates the consumer for a queue, or creates one if it does not exist.
 
@@ -676,15 +673,15 @@ async def update(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerUpdateResponse]:
+    ) -> Optional[Consumer]:
         if not account_id:
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
         if not queue_id:
             raise ValueError(f"Expected a non-empty value for `queue_id` but received {queue_id!r}")
         if not consumer_id:
             raise ValueError(f"Expected a non-empty value for `consumer_id` but received {consumer_id!r}")
         return cast(
-            Optional[ConsumerUpdateResponse],
+            Optional[Consumer],
             await self._put(
                 f"/accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}",
                 body=await async_maybe_transform(
@@ -701,10 +698,10 @@ async def update(
                     extra_query=extra_query,
                     extra_body=extra_body,
                     timeout=timeout,
-                    post_parser=ResultWrapper[Optional[ConsumerUpdateResponse]]._unwrapper,
+                    post_parser=ResultWrapper[Optional[Consumer]]._unwrapper,
                 ),
                 cast_to=cast(
-                    Any, ResultWrapper[ConsumerUpdateResponse]
+                    Any, ResultWrapper[Consumer]
                 ),  # Union types cannot be passed in as arguments in the type system
             ),
         )
@@ -720,7 +717,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> AsyncPaginator[ConsumerListResponse, AsyncSinglePage[ConsumerListResponse]]:
+    ) -> AsyncPaginator[Consumer, AsyncSinglePage[Consumer]]:
         """
         Returns the consumers for a Queue
 
@@ -743,11 +740,11 @@ def list(
             raise ValueError(f"Expected a non-empty value for `queue_id` but received {queue_id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/queues/{queue_id}/consumers",
-            page=AsyncSinglePage[ConsumerListResponse],
+            page=AsyncSinglePage[Consumer],
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
-            model=cast(Any, ConsumerListResponse),  # Union types cannot be passed in as arguments in the type system
+            model=cast(Any, Consumer),  # Union types cannot be passed in as arguments in the type system
         )
 
     async def delete(
@@ -807,7 +804,7 @@ async def get(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
-    ) -> Optional[ConsumerGetResponse]:
+    ) -> Optional[Consumer]:
         """
         Fetches the consumer for a queue by consumer id
 
@@ -833,18 +830,18 @@ async def get(
         if not consumer_id:
             raise ValueError(f"Expected a non-empty value for `consumer_id` but received {consumer_id!r}")
         return cast(
-            Optional[ConsumerGetResponse],
+            Optional[Consumer],
             await self._get(
                 f"/accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}",
                 options=make_request_options(
                     extra_headers=extra_headers,
                     extra_query=extra_query,
                     extra_body=extra_body,
                     timeout=timeout,
-                    post_parser=ResultWrapper[Optional[ConsumerGetResponse]]._unwrapper,
+                    post_parser=ResultWrapper[Optional[Consumer]]._unwrapper,
                 ),
                 cast_to=cast(
-                    Any, ResultWrapper[ConsumerGetResponse]
+                    Any, ResultWrapper[Consumer]
                 ),  # Union types cannot be passed in as arguments in the type system
             ),
         )

src/cloudflare/types/queues/__init__.py

@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 from .queue import Queue as Queue
+from .consumer import Consumer as Consumer
 from .queue_edit_params import QueueEditParams as QueueEditParams
 from .message_ack_params import MessageAckParams as MessageAckParams
 from .purge_start_params import PurgeStartParams as PurgeStartParams
@@ -11,17 +12,13 @@
 from .queue_create_params import QueueCreateParams as QueueCreateParams
 from .queue_update_params import QueueUpdateParams as QueueUpdateParams
 from .message_ack_response import MessageAckResponse as MessageAckResponse
-from .consumer_get_response import ConsumerGetResponse as ConsumerGetResponse
 from .message_pull_response import MessagePullResponse as MessagePullResponse
 from .message_push_response import MessagePushResponse as MessagePushResponse
 from .purge_status_response import PurgeStatusResponse as PurgeStatusResponse
 from .queue_delete_response import QueueDeleteResponse as QueueDeleteResponse
 from .consumer_create_params import ConsumerCreateParams as ConsumerCreateParams
-from .consumer_list_response import ConsumerListResponse as ConsumerListResponse
 from .consumer_update_params import ConsumerUpdateParams as ConsumerUpdateParams
-from .consumer_create_response import ConsumerCreateResponse as ConsumerCreateResponse
 from .consumer_delete_response import ConsumerDeleteResponse as ConsumerDeleteResponse
-from .consumer_update_response import ConsumerUpdateResponse as ConsumerUpdateResponse
 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

…re/types/queues/consumer_get_response.py src/cloudflare/types/queues/consumer.pysrc/cloudflare/types/queues/consumer_get_response.py renamed to src/cloudflare/types/queues/consumer.py src/cloudflare/types/queues/consumer_get_response.py renamed to src/cloudflare/types/queues/consumer.py

@@ -8,7 +8,7 @@
 from ..._models import BaseModel
 
 __all__ = [
-    "ConsumerGetResponse",
+    "Consumer",
     "MqWorkerConsumerResponse",
     "MqWorkerConsumerResponseSettings",
     "MqHTTPConsumerResponse",
@@ -97,6 +97,6 @@ class MqHTTPConsumerResponse(BaseModel):
     type: Optional[Literal["http_pull"]] = None
 
 
-ConsumerGetResponse: TypeAlias = Annotated[
+Consumer: TypeAlias = Annotated[
     Union[MqWorkerConsumerResponse, MqHTTPConsumerResponse], PropertyInfo(discriminator="type")
 ]