@@ -296,47 +296,6 @@ def update(
296296 ),
297297 )
298298
299- def list (
300- self ,
301- queue_id : str ,
302- * ,
303- account_id : str ,
304- # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
305- # The extra values given here take precedence over values defined on the client or passed to this method.
306- extra_headers : Headers | None = None ,
307- extra_query : Query | None = None ,
308- extra_body : Body | None = None ,
309- timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
310- ) -> SyncSinglePage [Consumer ]:
311- """
312- Returns the consumers for a Queue
313-
314- Args:
315- account_id: A Resource identifier.
316-
317- queue_id: A Resource identifier.
318-
319- extra_headers: Send extra headers
320-
321- extra_query: Add additional query parameters to the request
322-
323- extra_body: Add additional JSON properties to the request
324-
325- timeout: Override the client-level default timeout for this request, in seconds
326- """
327- if not account_id :
328- raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
329- if not queue_id :
330- raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
331- return self ._get_api_list (
332- f"/accounts/{ account_id } { queue_id } ,
333- page = SyncSinglePage [Consumer ],
334- options = make_request_options (
335- extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
336- ),
337- model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
338- )
339-
340299 def delete (
341300 self ,
342301 consumer_id : str ,
@@ -384,27 +343,24 @@ def delete(
384343
385344 def get (
386345 self ,
387- consumer_id : str ,
346+ queue_id : str ,
388347 * ,
389348 account_id : str ,
390- queue_id : str ,
391349 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
392350 # The extra values given here take precedence over values defined on the client or passed to this method.
393351 extra_headers : Headers | None = None ,
394352 extra_query : Query | None = None ,
395353 extra_body : Body | None = None ,
396354 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
397- ) -> Optional [Consumer ]:
355+ ) -> SyncSinglePage [Consumer ]:
398356 """
399- Fetches the consumer for a queue by consumer id
357+ Returns the consumers for a Queue
400358
401359 Args:
402360 account_id: A Resource identifier.
403361
404362 queue_id: A Resource identifier.
405363
406- consumer_id: A Resource identifier.
407-
408364 extra_headers: Send extra headers
409365
410366 extra_query: Add additional query parameters to the request
@@ -417,23 +373,13 @@ def get(
417373 raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
418374 if not queue_id :
419375 raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
420- if not consumer_id :
421- raise ValueError (f"Expected a non-empty value for `consumer_id` but received { consumer_id !r} )
422- return cast (
423- Optional [Consumer ],
424- self ._get (
425- f"/accounts/{ account_id } { queue_id } { consumer_id } ,
426- options = make_request_options (
427- extra_headers = extra_headers ,
428- extra_query = extra_query ,
429- extra_body = extra_body ,
430- timeout = timeout ,
431- post_parser = ResultWrapper [Optional [Consumer ]]._unwrapper ,
432- ),
433- cast_to = cast (
434- Any , ResultWrapper [Consumer ]
435- ), # Union types cannot be passed in as arguments in the type system
376+ return self ._get_api_list (
377+ f"/accounts/{ account_id } { queue_id } ,
378+ page = SyncSinglePage [Consumer ],
379+ options = make_request_options (
380+ extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
436381 ),
382+ model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
437383 )
438384
439385
@@ -706,47 +652,6 @@ async def update(
706652 ),
707653 )
708654
709- def list (
710- self ,
711- queue_id : str ,
712- * ,
713- account_id : str ,
714- # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
715- # The extra values given here take precedence over values defined on the client or passed to this method.
716- extra_headers : Headers | None = None ,
717- extra_query : Query | None = None ,
718- extra_body : Body | None = None ,
719- timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
720- ) -> AsyncPaginator [Consumer , AsyncSinglePage [Consumer ]]:
721- """
722- Returns the consumers for a Queue
723-
724- Args:
725- account_id: A Resource identifier.
726-
727- queue_id: A Resource identifier.
728-
729- extra_headers: Send extra headers
730-
731- extra_query: Add additional query parameters to the request
732-
733- extra_body: Add additional JSON properties to the request
734-
735- timeout: Override the client-level default timeout for this request, in seconds
736- """
737- if not account_id :
738- raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
739- if not queue_id :
740- raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
741- return self ._get_api_list (
742- f"/accounts/{ account_id } { queue_id } ,
743- page = AsyncSinglePage [Consumer ],
744- options = make_request_options (
745- extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
746- ),
747- model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
748- )
749-
750655 async def delete (
751656 self ,
752657 consumer_id : str ,
@@ -792,29 +697,26 @@ async def delete(
792697 cast_to = ConsumerDeleteResponse ,
793698 )
794699
795- async def get (
700+ def get (
796701 self ,
797- consumer_id : str ,
702+ queue_id : str ,
798703 * ,
799704 account_id : str ,
800- queue_id : str ,
801705 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
802706 # The extra values given here take precedence over values defined on the client or passed to this method.
803707 extra_headers : Headers | None = None ,
804708 extra_query : Query | None = None ,
805709 extra_body : Body | None = None ,
806710 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
807- ) -> Optional [Consumer ]:
711+ ) -> AsyncPaginator [Consumer , AsyncSinglePage [ Consumer ] ]:
808712 """
809- Fetches the consumer for a queue by consumer id
713+ Returns the consumers for a Queue
810714
811715 Args:
812716 account_id: A Resource identifier.
813717
814718 queue_id: A Resource identifier.
815719
816- consumer_id: A Resource identifier.
817-
818720 extra_headers: Send extra headers
819721
820722 extra_query: Add additional query parameters to the request
@@ -827,23 +729,13 @@ async def get(
827729 raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
828730 if not queue_id :
829731 raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
830- if not consumer_id :
831- raise ValueError (f"Expected a non-empty value for `consumer_id` but received { consumer_id !r} )
832- return cast (
833- Optional [Consumer ],
834- await self ._get (
835- f"/accounts/{ account_id } { queue_id } { consumer_id } ,
836- options = make_request_options (
837- extra_headers = extra_headers ,
838- extra_query = extra_query ,
839- extra_body = extra_body ,
840- timeout = timeout ,
841- post_parser = ResultWrapper [Optional [Consumer ]]._unwrapper ,
842- ),
843- cast_to = cast (
844- Any , ResultWrapper [Consumer ]
845- ), # Union types cannot be passed in as arguments in the type system
732+ return self ._get_api_list (
733+ f"/accounts/{ account_id } { queue_id } ,
734+ page = AsyncSinglePage [Consumer ],
735+ options = make_request_options (
736+ extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
846737 ),
738+ model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
847739 )
848740
849741
@@ -857,9 +749,6 @@ def __init__(self, consumers: ConsumersResource) -> None:
857749 self .update = to_raw_response_wrapper (
858750 consumers .update ,
859751 )
860- self .list = to_raw_response_wrapper (
861- consumers .list ,
862- )
863752 self .delete = to_raw_response_wrapper (
864753 consumers .delete ,
865754 )
@@ -878,9 +767,6 @@ def __init__(self, consumers: AsyncConsumersResource) -> None:
878767 self .update = async_to_raw_response_wrapper (
879768 consumers .update ,
880769 )
881- self .list = async_to_raw_response_wrapper (
882- consumers .list ,
883- )
884770 self .delete = async_to_raw_response_wrapper (
885771 consumers .delete ,
886772 )
@@ -899,9 +785,6 @@ def __init__(self, consumers: ConsumersResource) -> None:
899785 self .update = to_streamed_response_wrapper (
900786 consumers .update ,
901787 )
902- self .list = to_streamed_response_wrapper (
903- consumers .list ,
904- )
905788 self .delete = to_streamed_response_wrapper (
906789 consumers .delete ,
907790 )
@@ -920,9 +803,6 @@ def __init__(self, consumers: AsyncConsumersResource) -> None:
920803 self .update = async_to_streamed_response_wrapper (
921804 consumers .update ,
922805 )
923- self .list = async_to_streamed_response_wrapper (
924- consumers .list ,
925- )
926806 self .delete = async_to_streamed_response_wrapper (
927807 consumers .delete ,
928808 )
![stainless-app[bot]](https://avatars.githubusercontent.com/in/378072?v=4&size=40){kind=avatar}
0 commit comments