+ ~j1r^RIHt^RIHt^RIt^RIHt^RIHtH t H t H t H t H t Ht^RIHtHtHt^RIHt^RIHtHt^R IHtHt^R IHtHt^R IHt^R I H!t!H"t"^R I#H$t$H%t%^RI&H't'H(t(^RI)H*t*^RI+H,t,^RI-H.t.RR.t/!RR]4t0!RR]4t1!RR4t2!RR4t3!RR4t4!RR4t5R#)) annotations)IterableN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncPage AsyncPage)AnthropicError)AsyncPaginatormake_request_options)batch_list_paramsbatch_create_params) JSONLDecoderAsyncJSONLDecoder) MessageBatch)DeletedMessageBatch)MessageBatchIndividualResponseBatches AsyncBatchesc]tRt^t]RRl4t]RRl4tRRRRRRR ]/R R lltRRRRRRR ]/R R llt R] R] R] RRRRRRR ]/RRllt RRRRRRR ]/RRllt RRRRRRR ]/RRllt RRRRRRR ]/RRlltRtR#)r!cV^8dQhRR/#)returnBatchesWithRawResponse)formats"y/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anthropic/resources/messages/batches.py __annotate__Batches.__annotate__s,,#9,c \V4#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_responseBatches.with_raw_responses&d++r-cV^8dQhRR/#)r%r&BatchesWithStreamingResponser()r)s"r*r+r,'s22)E2r-c \V4#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 )r5r0s&r*with_streaming_responseBatches.with_streaming_response&s,D11r- extra_headersN extra_query extra_bodytimeoutc 0V^8dQhRRRRRRRRR R R R /# r%requestsz%Iterable[batch_create_params.Request]r:Headers | Noner; Query | Noner< Body | Noner='float | httpx.Timeout | None | NotGivenr&rr()r)s"r*r+r,/H( ( 8( & ( "(  ( 9(  ( r-c  ~VPR\RV/\P4\ W#WER7\ R7#) 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. 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 /v1/messages/batchesr@r:r;r<r=bodyoptionscast_to)_postrrBatchCreateParamsrrr1r@r:r;r<r=s&$$$$$r*createBatches.create/sGBzz " *h!79L9^9^_(+Q[!   r-c 0V^8dQhRRRRRRRRR R R R /# r%message_batch_idstrr:rAr;rBr<rCr=rDr&rr()r)s"r*r+r,YF' ' ' & ' "'  ' 9'  ' r-c  V'g\RV: 24hVP\RVR7\W#WER7\R7#)bThis 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. 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 '/v1/messages/batches/{message_batch_id}rUrIrLrM ValueError_getr rrr1rUr:r;r<r=s&&$$$$r*retrieveBatches.retrieveYsQ> ^_o^rst tyy CVf g(+Q[!   r-after_id before_idlimitc8V^8dQhRRRRRRRRRR R R R R RR/#)r%rd str | Omitrerf int | Omitr:rAr;rBr<rCr=rDr&zSyncPage[MessageBatch]r()r)s"r*r+r,s\: : :  :  : &: ":  : 9:  : r-c VPR\\,\VVVV\ RVRVRV/\ P 4R7\R7#abList 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`. 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 rHrdrerf)r:r;r<r=query)pagerLmodel) _get_api_listrrrrrBatchListParamsr1rdrerfr:r;r<r=s&$$$$$$$r*list Batches.listshP!! ",'(+'%%"H#Y &55  #"  r-c 0V^8dQhRRRRRRRRR R R R /# r%rUrVr:rAr;rBr<rCr=rDr&rr()r)s"r*r+r,F' ' ' & ' "'  ' 9'  ' r-c  V'g\RV: 24hVP\RVR7\W#WER7\R7#)R 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. 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 rZr[r\rIr]r__deleter rrras&&$$$$r*deleteBatches.deletesQ> ^_o^rst t|| CVf g(+Q[(   r-c 0V^8dQhRRRRRRRRR R R R /#rTr()r)s"r*r+r,F- - - & - "-  - 9-  - r-c  V'g\RV: 24hVP\RVR7\W#WER7\R7#)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. 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 rZ./v1/messages/batches/{message_batch_id}/cancelr\rIr]r_rNr rrras&&$$$$r*cancelBatches.cancelsRJ ^_o^rst tzz J]m n(+Q[!   r-c 0V^8dQhRRRRRRRRR R R R /#) r%rUrVr:rAr;rBr<rCr=rDr&z,JSONLDecoder[MessageBatchIndividualResponse]r()r)s"r*r+r,sF1 1 1 & 1 "1  1 91  61 r-c  PV'g\RV: 24hVPVR7pVP'g\RVP 24hRR/T;'g/CpVP \ VPVR7\W#WER7\\,RR7#)  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. 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 rZr\BNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryrITrLrMstream) r_rb results_urlrprocessing_statusr`r rrr r1rUr:r;r<r=batchs&&$$$$ r*resultsBatches.resultss@ ^_o^rst t /? @    TUZUlUlTmn "#7QMN O(+Q[!!?@   r-r(__name__ __module__ __qualname____firstlineno__rr2r8r rQrbr rrr{rr__static_attributes__r(r-r*r!r!sd,,22( )- ( %)( #'( 1r-c \V4#r/)rr0s&r*r2AsyncBatches.with_raw_responseKs+400r-cV^8dQhRR/#)r%r&!AsyncBatchesWithStreamingResponser()r)s"r*r+rVs77)J7r-c \V4#r7)rr0s&r*r8$AsyncBatches.with_streaming_responseUs166r-r:Nr;r<r=c 0V^8dQhRRRRRRRRR R R R /#r?r()r)s"r*r+r^rEr-c "TPR\RV/\P4GRjxL \ W#WER7\ R7GRjxL #L"L5i)rGrHr@NrIrJ)rNrrrOrrrPs&$$$$$r*rQAsyncBatches.create^sZBZZ ",j(-CEXEjEjkk(+Q[!     k s!,AA A A AAc 0V^8dQhRRRRRRRRR R R R /#rTr()r)s"r*r+rrWr-c "V'g\RV: 24hVP\RVR7\W#WER7\R7GRjxL #L5i)rYrZr[r\rIr]Nr^ras&&$$$$r*rbAsyncBatches.retrieves^> ^_o^rst tYY CVf g(+Q[!     A A A Ardrerfc8V^8dQhRRRRRRRRRR R R R R RR/#)r%rdrhrerfrir:rAr;rBr<rCr=rDr&z5AsyncPaginator[MessageBatch, AsyncPage[MessageBatch]]r()r)s"r*r+rs\: : :  :  : &: ":  : 9:  ?: r-c VPR\\,\VVVV\ RVRVRV/\ P 4R7\R7#rk)rorrrrrrprqs&$$$$$$$r*rrAsyncBatches.listshP!! "<((+'%%"H#Y &55  #"  r-c 0V^8dQhRRRRRRRRR R R R /#rur()r)s"r*r+rrvr-c "V'g\RV: 24hVP\RVR7\W#WER7\R7GRjxL #L5i)rxrZr[r\rIr]Nryras&&$$$$r*r{AsyncBatches.deletes^> ^_o^rst t\\ CVf g(+Q[( "    rc 0V^8dQhRRRRRRRRR R R R /#rTr()r)s"r*r+rr~r-c "V'g\RV: 24hVP\RVR7\W#WER7\R7GRjxL #L5i)rrZrr\rIr]Nrras&&$$$$r*rAsyncBatches.cancels_J ^_o^rst tZZ J]m n(+Q[!      rc 0V^8dQhRRRRRRRRR R R R /#) r%rUrVr:rAr;rBr<rCr=rDr&z1AsyncJSONLDecoder[MessageBatchIndividualResponse]r()r)s"r*r+rEsF1 1 1 & 1 "1  1 91  ;1 r-c "V'g\RV: 24hVPVR7GRjxL pVP'g\RVP 24hRR/T;'g/CpVP \ VPVR7\W#WER7\\,RR 7GRjxL #LL5i) rrZr\NrrrrITr) r_rbrrrr`r rrr rs&&$$$$ r*rAsyncBatches.resultsEs@ ^_o^rst tmm5EmFF    TUZUlUlTmn "#7QMN O(+Q[&&DE    G s.-B>B:B>#B>*A B>5B<6B><B>r(rr(r-r*r"r"Jsd1177( )- ( %)( #'( > NN  )@@     %<< LL  '>> NN  '>> NN  r-rrrQr{rrrbNrrrrrrr(r-r*r'r'y   r-r'c"]tRtRtRRltRtR#)ric V^8dQhRRRR/#r%rr"r&rr()r)s"r*r+(AsyncBatchesWithRawResponse.__annotate__    r-c Wn\P!VP4Vn\P!VP4Vn\P!VP 4Vn\P!VP 4Vn\P!VP4VnR#r)rrasync_to_raw_response_wrapperrQrbrrr{rrs&&r*r$AsyncBatchesWithRawResponse.__init__s &DD NN  )FF     %BB LL  'DD NN  'DD NN  r-rNrr(r-r*rrrr-rc"]tRtRtRRltRtR#)r5ic V^8dQhRRRR/#rr()r)s"r*r+)BatchesWithStreamingResponse.__annotate__rr-c Wn\VP4Vn\VP4Vn\VP4Vn\VP 4Vn\VP 4VnR#r)rrrQrbrrr{rrs&&r*r%BatchesWithStreamingResponse.__init__sp 2 NN  5     1 LL  3 NN  3 NN  r-rNrr(r-r*r5r5rr-r5c"]tRtRtRRltRtR#)ric V^8dQhRRRR/#rr()r)s"r*r+.AsyncBatchesWithStreamingResponse.__annotate__rr-c Wn\VP4Vn\VP4Vn\VP4Vn\VP 4Vn\VP 4VnR#r)rrrQrbrrr{rrs&&r*r*AsyncBatchesWithStreamingResponse.__init__sp 8 NN  ;     7 LL  9 NN  9 NN  r-rNrr(r-r*rrrr-r)6 __future__rtypingrhttpxr_typesrrrr r r r _utilsr rr_compatr _resourcerr _responserr paginationrr _exceptionsr _base_clientrrtypes.messagesrr_decoders.jsonlrrtypes.messages.message_batchr$types.messages.deleted_message_batchr0types.messages.message_batch_individual_responser __all__r!r"r'rr5rr(r-r*rs# KKKKK&:Y-)@D>8G^ n %l ol ^ l #l ^   *  *  *  r-