+
    ~j}                       ^ RI Ht ^ RIHtHt ^ RIHt ^ RIt^RIH	t	 ^RI
HtHtHtHtHtHtHt ^RIHtHtHtHtHt ^RIHt ^R	IHtHt ^R
IHtHt ^RI H!t!H"t" ^RI#H$t$ ^RI%H&t&H't' ^RI(H)t)H*t* ^RI+H,t,H-t- ^RI.H/t/ ^RI0H1t1 ^RI2H3t3 ^RI4H5t5 RR.t6 ! R R]4      t7 ! R R]4      t8 ! R R4      t9 ! R R4      t: ! R R4      t; ! R R4      t<R# )     )annotations)ListIterable)chainN)_legacy_response)BodyOmitQueryHeadersNotGivenomit	not_given)is_givenpath_templatemaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncPage	AsyncPage)AnthropicError)AsyncPaginatormake_request_options)JSONLDecoderAsyncJSONLDecoder)batch_list_paramsbatch_create_params)AnthropicBetaParam)BetaMessageBatch)BetaDeletedMessageBatch)"BetaMessageBatchIndividualResponseBatchesAsyncBatchesc                  &   ] tR t^t]R R l4       t]R R l4       tR]RRRRR	RR
]/R R llt	R]RRRRR	RR
]/R R llt
R]R]R]R]RRRRR	RR
]/R R lltR]RRRRR	RR
]/R R lltR]RRRRR	RR
]/R R lltR]RRRRR	RR
]/R R lltRtR# )r&   c                   V ^8  d   QhRR/# )   returnBatchesWithRawResponse )formats   "~/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anthropic/resources/beta/messages/batches.py__annotate__Batches.__annotate__   s     , ,#9 ,    c                    \        V 4      # z
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.

For more information, see https://www.github.com/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers
)r,   selfs   &r/   with_raw_responseBatches.with_raw_response   s     &d++r2   c                   V ^8  d   QhRR/# )r*   r+   BatchesWithStreamingResponser-   )r.   s   "r/   r0   r1   )   s     2 2)E 2r2   c                    \        V 4      # z
An alternative to `.with_raw_response` that doesn't eagerly read the response body.

For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response
)r:   r5   s   &r/   with_streaming_responseBatches.with_streaming_response(   s     ,D11r2   betasextra_headersNextra_query
extra_bodytimeoutc               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# r*   requestsz%Iterable[batch_create_params.Request]r?   List[AnthropicBetaParam] | Omitr@   Headers | NonerA   Query | NonerB   Body | NonerC   'float | httpx.Timeout | None | NotGivenr+   r#   r-   )r.   s   "r/   r0   r1   1   R     6
 6
 86
 /	6
 &6
 "6
  6
 96
 
6
r2   c               D   / \        R\        V4      '       d$   RP                  \        R V 4       R.4      4      M\        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  R\        RV/\        P                  4      \        W4WVR7      \        R7      # )	(  
Send a batch of Message creation requests.

The Message Batches API can be used to process multiple Messages API requests at
once. Once a Message Batch is created, it begins processing immediately. Batches
can take up to 24 hours to complete.

Learn more about the Message Batches API in our
[user guide](https://docs.claude.com/en/docs/build-with-claude/batch-processing)

Args:
  requests: List of requests for prompt completion. Each is an individual request to create
      a Message.

  betas: Optional header to specify the beta version(s) you want to use.

  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
anthropic-beta,c              3  8   "   T F  p\        V4      x  K  	  R # 5iNstr.0es   & r/   	<genexpr>!Batches.create.<locals>.<genexpr>X        5Lec!ffe   message-batches-2024-09-24/v1/messages/batches?beta=truerF   r@   rA   rB   rC   bodyoptionscast_to)r   r   joinr   r   _postr   r!   BatchCreateParamsr   r#   r6   rF   r?   r@   rA   rB   rC   s   &$$$$$$r/   createBatches.create1   s    H	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_azz, *h!79L9^9^_(+Q[ %  
 	
r2   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# r*   message_batch_idrT   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r+   r#   r-   )r.   s   "r/   r0   r1   i   P     5
 5
5
 /	5
 &5
 "5
  5
 95
 
5
r2   c          
     R   V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        W4WVR7      \        R	7      # )
  This endpoint is idempotent and can be used to poll for Message Batch
completion.

To access the results of a Message Batch, make a request to the
`results_url` field in the response.

Learn more about the Message Batches API in our
[user guide](https://docs.claude.com/en/docs/build-with-claude/batch-processing)

Args:
  message_batch_id: ID of the Message Batch.

  betas: Optional header to specify the beta version(s) you want to use.

  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
?Expected a non-empty value for `message_batch_id` but received rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   #Batches.retrieve.<locals>.<genexpr>   rZ   r[   r\   1/v1/messages/batches/{message_batch_id}?beta=truerk   r^   ra   rb   

ValueErrorr   r   rc   r   r   _getr   r   r#   r6   rk   r?   r@   rA   rB   rC   s   &&$$$$$r/   retrieveBatches.retrievei   s    D  ^_o^rstt	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_ayyM`pq(+Q[ %  
 	
r2   after_id	before_idlimitc               <    V ^8  d   QhRRRRRRRRRR	R
RRRRRRR/	# )r*   r{   
str | Omitr|   r}   
int | Omitr?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r+   zSyncPage[BetaMessageBatch]r-   )r.   s   "r/   r0   r1      sq     H
 H
 H
 	H

 H
 /H
 &H
 "H
  H
 9H
 
$H
r2   c               p   / \        R\        V4      '       d$   RP                  \        R V 4       R.4      4      M\        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  R\        \        ,          \        VVVV\        RVRVRV/\        P                  4      R	7      \        R
7      # )  List all Message Batches within a Workspace.

Most recently created batches are
returned first.

Learn more about the Message Batches API in our
[user guide](https://docs.claude.com/en/docs/build-with-claude/batch-processing)

Args:
  after_id: ID of the object to use as a cursor for pagination. When provided, returns the
      page of results immediately after this object.

  before_id: ID of the object to use as a cursor for pagination. When provided, returns the
      page of results immediately before this object.

  limit: Number of items to return per page.

      Defaults to `20`. Ranges from `1` to `1000`.

  betas: Optional header to specify the beta version(s) you want to use.

  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
rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   Batches.list.<locals>.<genexpr>   rZ   r[   r\   r]   r{   r|   r}   r@   rA   rB   rC   querypagera   model)r   r   rc   r   r   _get_api_listr   r#   r   r   r    BatchListParams	r6   r{   r|   r}   r?   r@   rA   rB   rC   s	   &$$$$$$$$r/   listBatches.list   s    V	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_a!!,*+(+'%%"H#Y
 &55 ## " 
 	
r2   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# r*   rk   rT   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r+   r$   r-   )r.   s   "r/   r0   r1      P     5
 5
5
 /	5
 &5
 "5
  5
 95
 
!5
r2   c          
     R   V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        W4WVR7      \        R	7      # )
  
Delete a Message Batch.

Message Batches can only be deleted once they've finished processing. If you'd
like to delete an in-progress batch, you must first cancel it.

Learn more about the Message Batches API in our
[user guide](https://docs.claude.com/en/docs/build-with-claude/batch-processing)

Args:
  message_batch_id: ID of the Message Batch.

  betas: Optional header to specify the beta version(s) you want to use.

  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
ro   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   !Batches.delete.<locals>.<genexpr>  rZ   r[   r\   rr   rs   r^   rt   
rv   r   r   rc   r   r   _deleter   r   r$   rx   s   &&$$$$$r/   deleteBatches.delete   s    D  ^_o^rstt	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_a||M`pq(+Q[ ,  
 	
r2   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# rj   r-   )r.   s   "r/   r0   r1   !  P     =
 =
=
 /	=
 &=
 "=
  =
 9=
 
=
r2   c          
     R   V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        W4WVR7      \        R	7      # )
  Batches may be canceled any time before processing ends.

Once cancellation is
initiated, the batch enters a `canceling` state, at which time the system may
complete any in-progress, non-interruptible requests before finalizing
cancellation.

The number of canceled requests is specified in `request_counts`. To determine
which requests were canceled, check the individual results within the batch.
Note that cancellation may not result in any canceled requests if they were
non-interruptible.

Learn more about the Message Batches API in our
[user guide](https://docs.claude.com/en/docs/build-with-claude/batch-processing)

Args:
  message_batch_id: ID of the Message Batch.

  betas: Optional header to specify the beta version(s) you want to use.

  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
ro   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   !Batches.cancel.<locals>.<genexpr>N  rZ   r[   r\   8/v1/messages/batches/{message_batch_id}/cancel?beta=truers   r^   rt   
rv   r   r   rc   r   r   rd   r   r   r#   rx   s   &&$$$$$r/   cancelBatches.cancel!  s    P  ^_o^rstt	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_azzJ]m )+Q[ %  
 	
r2   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# )r*   rk   rT   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r+   z0JSONLDecoder[BetaMessageBatchIndividualResponse]r-   )r.   s   "r/   r0   r1   `  sP     ?
 ?
?
 /	?
 &?
 "?
  ?
 9?
 
:?
r2   c          
        V'       g   \        RV: 24      hV P                  VR7      pVP                  '       g   \        RVP                   24      hRR/T;'       g    / Cp/ \        R\        V4      '       d$   RP                  \        R V 4       R	.4      4      M\        /4      CT;'       g    / CpRR	/T;'       g    / CpV P                  \        VP                  VR7      \        W4WVR
7      \        \        ,          RR7      # )  
Streams the results of a Message Batch as a `.jsonl` file.

Each line in the file is a JSON object containing the result of a single request
in the Message Batch. Results are not guaranteed to be in the same order as
requests. Use the `custom_id` field to match results to requests.

Learn more about the Message Batches API in our
[user guide](https://docs.claude.com/en/docs/build-with-claude/batch-processing)

Args:
  message_batch_id: ID of the Message Batch.

  betas: Optional header to specify the beta version(s) you want to use.

  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
ro   rs   BNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryrO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   "Batches.results.<locals>.<genexpr>  rZ   r[   r\   r^   Tra   rb   stream)rv   ry   results_urlr   processing_statusr   r   rc   r   r   rw   r   r   r   r%   r6   rk   r?   r@   rA   rB   rC   batchs   &&$$$$$ r/   resultsBatches.results`  s*   F  ^_o^rstt/?@    TUZUlUlTmn  "#7QM<O<ORQ	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_ayy%++>NO(+Q[ !!CD  
 	
r2   r-   __name__
__module____qualname____firstlineno__r   r7   r=   r   r   rg   ry   r   r   r   r   __static_attributes__r-   r2   r/   r&   r&      s   , , 2 26
 26	6
 )-6
 %)6
 #'6
 <E6
p5
 26	5
 )-5
 %)5
 #'5
 <E5
nH
  $H
 !%	H

 !H
 26H
 )-H
 %)H
 #'H
 <EH
T5
 26	5
 )-5
 %)5
 #'5
 <E5
n=
 26	=
 )-=
 %)=
 #'=
 <E=
~?
 26	?
 )-?
 %)?
 #'?
 <E?
 ?
r2   c                  &   ] tR tRt]R R l4       t]R R l4       tR]RRR	RR
RR]/R R llt	R]RRR	RR
RR]/R R llt
R]R]R]R]RRR	RR
RR]/R R lltR]RRR	RR
RR]/R R lltR]RRR	RR
RR]/R R lltR]RRR	RR
RR]/R R lltRtR# )r'   i  c                   V ^8  d   QhRR/# )r*   r+   AsyncBatchesWithRawResponser-   )r.   s   "r/   r0   AsyncBatches.__annotate__  s     1 1#> 1r2   c                    \        V 4      # r4   )r   r5   s   &r/   r7   AsyncBatches.with_raw_response  s     +400r2   c                   V ^8  d   QhRR/# )r*   r+   !AsyncBatchesWithStreamingResponser-   )r.   s   "r/   r0   r     s     7 7)J 7r2   c                    \        V 4      # r<   )r   r5   s   &r/   r=   $AsyncBatches.with_streaming_response  s     166r2   r?   r@   NrA   rB   rC   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# rE   r-   )r.   s   "r/   r0   r     rL   r2   c               t  "   / \        R\        V4      '       d$   RP                  \        R V 4       R.4      4      M\        /4      CT;'       g    / CpRR/T;'       g    / CpT P                  R\        RV/\        P                  4      G Rj  xL
 \        W4WVR7      \        R	7      G Rj  xL
 #  L" L5i)
rN   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   &AsyncBatches.create.<locals>.<genexpr>  rZ   r[   r\   r]   rF   Nr^   r_   )r   r   rc   r   r   rd   r   r!   re   r   r#   rf   s   &$$$$$$r/   rg   AsyncBatches.create  s     H	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_aZZ,,j(-CEXEjEjkk(+Q[ %   
 
 	
k
s0   AB8B8"/B8B4
B8/B60B86B8c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# rj   r-   )r.   s   "r/   r0   r     rl   r2   c          
     n  "   V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        W4WVR7      \        R	7      G R
j  xL
 #  L5i)rn   ro   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   (AsyncBatches.retrieve.<locals>.<genexpr>  rZ   r[   r\   rr   rs   r^   rt   Nru   rx   s   &&$$$$$r/   ry   AsyncBatches.retrieve  s     D  ^_o^rstt	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_aYYM`pq(+Q[ %  
 
 	
 
   A&B5)B595B5.B3/B5r{   r|   r}   c               <    V ^8  d   QhRRRRRRRRRR	R
RRRRRRR/	# )r*   r{   r   r|   r}   r   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r+   z=AsyncPaginator[BetaMessageBatch, AsyncPage[BetaMessageBatch]]r-   )r.   s   "r/   r0   r   %  sr     H
 H
 H
 	H

 H
 /H
 &H
 "H
  H
 9H
 
GH
r2   c               p   / \        R\        V4      '       d$   RP                  \        R V 4       R.4      4      M\        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  R\        \        ,          \        VVVV\        RVRVRV/\        P                  4      R	7      \        R
7      # )r   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   $AsyncBatches.list.<locals>.<genexpr>S  rZ   r[   r\   r]   r{   r|   r}   r   r   )r   r   rc   r   r   r   r   r#   r   r   r    r   r   s	   &$$$$$$$$r/   r   AsyncBatches.list%  s    V	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_a!!,+,(+'%%"H#Y
 &55 ## " 
 	
r2   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# r   r-   )r.   s   "r/   r0   r   o  r   r2   c          
     n  "   V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        W4WVR7      \        R	7      G R
j  xL
 #  L5i)r   ro   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   &AsyncBatches.delete.<locals>.<genexpr>  rZ   r[   r\   rr   rs   r^   rt   Nr   rx   s   &&$$$$$r/   r   AsyncBatches.deleteo  s     D  ^_o^rstt	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_a\\M`pq(+Q[ , " 
 
 	
 
r   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# rj   r-   )r.   s   "r/   r0   r     r   r2   c          
     n  "   V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        W4WVR7      \        R	7      G R
j  xL
 #  L5i)r   ro   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   &AsyncBatches.cancel.<locals>.<genexpr>  rZ   r[   r\   r   rs   r^   rt   Nr   rx   s   &&$$$$$r/   r   AsyncBatches.cancel  s     P  ^_o^rstt	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_aZZJ]m )+Q[ %   
 
 	
 
r   c               4    V ^8  d   QhRRRRRRRRR	R
RRRR/# )r*   rk   rT   r?   rG   r@   rH   rA   rI   rB   rJ   rC   rK   r+   z5AsyncJSONLDecoder[BetaMessageBatchIndividualResponse]r-   )r.   s   "r/   r0   r     sP     ?
 ?
?
 /	?
 &?
 "?
  ?
 9?
 
??
r2   c          
     F  "   V'       g   \        RV: 24      hV P                  VR7      G Rj  xL
 pVP                  '       g   \        RVP                   24      hRR/T;'       g    / Cp/ \        R\        V4      '       d$   RP                  \        R	 V 4       R
.4      4      M\        /4      CT;'       g    / CpRR
/T;'       g    / CpV P                  \        VP                  VR7      \        W4WVR7      \        \        ,          RR7      G Rj  xL
 #  L L5i)r   ro   rs   Nr   r   r   rO   rP   c              3  8   "   T F  p\        V4      x  K  	  R # 5irR   rS   rU   s   & r/   rX   'AsyncBatches.results.<locals>.<genexpr>  rZ   r[   r\   r^   Tr   )rv   ry   r   r   r   r   r   rc   r   r   rw   r   r   r   r%   r   s   &&$$$$$ r/   r   AsyncBatches.results  s@    F  ^_o^rsttmm5EmFF    TUZUlUlTmn  "#7QM<O<ORQ	
$ '*hhu5Le5LOkNl/m&n"	
 ""	
 *+GaML_L_]_aYY%++>NO(+Q[ &&HI  
 
 	
% G$
s;   -D!DD!#D!*AD!=D!AD!DD!D!r-   r   r-   r2   r/   r'   r'     s   1 1 7 76
 26	6
 )-6
 %)6
 #'6
 <E6
p5
 26	5
 )-5
 %)5
 #'5
 <E5
nH
  $H
 !%	H

 !H
 26H
 )-H
 %)H
 #'H
 <EH
T5
 26	5
 )-5
 %)5
 #'5
 <E5
n=
 26	=
 )-=
 %)=
 #'=
 <E=
~?
 26	?
 )-?
 %)?
 #'?
 <E?
 ?
r2   c                  "    ] tR tRtR R ltRtR# )r,   i'  c                    V ^8  d   QhRRRR/# r*   batchesr&   r+   Noner-   )r.   s   "r/   r0   #BatchesWithRawResponse.__annotate__(       
 
 
D 
r2   c                	   Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP
                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        R # rR   )	_batchesr   to_raw_response_wrapperrg   ry   r   r   r   r   r6   r   s   &&r/   __init__BatchesWithRawResponse.__init__(  s    &>>NN
 )@@
 %<<LL
	 '>>NN
 '>>NN
 (??OO
r2   r   r   rg   r   r   r   ry   Nr   r   r   r   r   r   r-   r2   r/   r,   r,   '      
 
r2   r,   c                  "    ] tR tRtR R ltRtR# )r   i?  c                    V ^8  d   QhRRRR/# r*   r   r'   r+   r   r-   )r.   s   "r/   r0   (AsyncBatchesWithRawResponse.__annotate__@       
 
 
 
r2   c                	   Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP
                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        R # rR   )	r   r   async_to_raw_response_wrapperrg   ry   r   r   r   r   r   s   &&r/   r   $AsyncBatchesWithRawResponse.__init__@  s    &DDNN
 )FF
 %BBLL
	 'DDNN
 'DDNN
 (EEOO
r2   r   Nr   r-   r2   r/   r   r   ?  r   r2   r   c                  "    ] tR tRtR R ltRtR# )r:   iW  c                    V ^8  d   QhRRRR/# r   r-   )r.   s   "r/   r0   )BatchesWithStreamingResponse.__annotate__X  r   r2   c                	J   Wn         \        VP                  4      V n        \        VP                  4      V n        \        VP                  4      V n        \        VP
                  4      V n        \        VP                  4      V n        \        VP                  4      V n        R # rR   )r   r   rg   ry   r   r   r   r   r   s   &&r/   r   %BatchesWithStreamingResponse.__init__X  s    2NN
 5
 1LL
	 3NN
 3NN
 4OO
r2   r   Nr   r-   r2   r/   r:   r:   W  r   r2   r:   c                  "    ] tR tRtR R ltRtR# )r   io  c                    V ^8  d   QhRRRR/# r   r-   )r.   s   "r/   r0   .AsyncBatchesWithStreamingResponse.__annotate__p  r   r2   c                	J   Wn         \        VP                  4      V n        \        VP                  4      V n        \        VP                  4      V n        \        VP
                  4      V n        \        VP                  4      V n        \        VP                  4      V n        R # rR   )r   r   rg   ry   r   r   r   r   r   s   &&r/   r   *AsyncBatchesWithStreamingResponse.__init__p  s    8NN
 ;
 7LL
	 9NN
 9NN
 :OO
r2   r   Nr   r-   r2   r/   r   r   o  r   r2   r   )=
__future__r   typingr   r   	itertoolsr   httpx r   _typesr   r	   r
   r   r   r   r   _utilsr   r   r   r   r   _compatr   	_resourcer   r   	_responser   r   
paginationr   r   _exceptionsr   _base_clientr   r   _decoders.jsonlr   r   types.beta.messagesr    r!   types.anthropic_beta_paramr"   &types.beta.messages.beta_message_batchr#   .types.beta.messages.beta_deleted_message_batchr$   :types.beta.messages.beta_message_batch_individual_responser%   __all__r&   r'   r,   r   r:   r   r-   r2   r/   <module>r     s    # !   ! L L L g g ' ; Z . * A ? J = G V mn
%B
o B
JB
# B
J
 
0
 
0
 
0
 
r2   