g.tddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z m Z mZmZddlmZmZmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd l m!Z!ddl"m#Z#m$Z$ddl%m&Z&m'Z'ddl(m)Z)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0ddgZ1GddeZ2GddeZ3GddZ4GddZ5GddZ6GddZ7y) ) annotations)ListIterable)chainN)_legacy_response) NOT_GIVENBodyQueryHeadersNotGiven)is_givenmaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncPage AsyncPage)AnthropicError)AsyncPaginatormake_request_options) JSONLDecoderAsyncJSONLDecoder)batch_list_paramsbatch_create_params)AnthropicBetaParam)BetaMessageBatch)"BetaMessageBatchIndividualResponseBatches AsyncBatchesc .eZdZed dZed dZeddded d dZeddded ddZeeeeddded ddZ eddded dd Z eddded dd Z y)r#ct|Sa This property can be used as a prefix for any HTTP method call to return the 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 )BatchesWithRawResponseselfs ^/var/www/openai/venv/lib/python3.12/site-packages/anthropic/resources/beta/messages/batches.pywith_raw_responsezBatches.with_raw_response"s&d++ct|Sz 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 )BatchesWithStreamingResponser)s r+with_streaming_responsezBatches.with_streaming_response,s,D11r-Nbetas extra_headers extra_query extra_bodytimeoutc $itdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt d|itjt||||tS)  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. 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,c32K|]}t|ywNstr.0es r+ z!Batches.create..Y5Lec!femessage-batches-2024-09-24/v1/messages/batches?beta=truerequestsr4r5r6r7bodyoptionscast_to) rrjoinrr _postrrBatchCreateParamsrr!r*rHr3r4r5r6r7s r+createzBatches.create5sB  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a zz , *h!79L9^9^_(+Q[el%   r-c |std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j d|dt||||t S) 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. 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 r:r;c32K|]}t|ywr=r>r@s r+rCz#Batches.retrieve..rDrErF/v1/messages/batches/ ?beta=truerIrLrM ValueErrorrrrNrr _getrr!r*message_batch_idr3r4r5r6r7s r+retrievezBatches.retrievejs> ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a yy#$4#5Z @(+Q[el%   r-after_id before_idlimitr3r4r5r6r7c@itdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt tt||||t|||dtjtS) List all Message Batches within a Workspace. Most recently created batches are returned first. 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 r:r;c32K|]}t|ywr=r>r@s r+rCzBatches.list..rDrErFrGrarbrcr4r5r6r7querypagerLmodel) rrrNrr _get_api_listrr!rrrBatchListParams r*rarbrcr3r4r5r6r7s r+listz Batches.listsP  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a !! ,*+(+'%%$,%.!& &55  ##"  r-c |std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j d|dt||||t S) 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. 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 rUr:r;c32K|]}t|ywr=r>r@s r+rCz!Batches.cancel..rDrErFrW/cancel?beta=truerIrY r[rrrNrr rOrr!r]s r+cancelzBatches.cancelsJ ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a zz#$4#55F G(+Q[el%   r-c |std||j|}|jstd|jddi|xsi}it dt |r#djtd|Dd gnti|xsi}dd i|xsi}|j|jt|||| d tt S)  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. 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 rUr^BNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryr:r;c32K|]}t|ywr=r>r@s r+rCz"Batches.results..LrDrErFrITrLstreamrM)r[r_ results_urlrprocessing_statusrrrNrr r\rrr"r*r^r3r4r5r6r7batchs r+resultszBatches.resultss@ ^_o^rst t /? @   TUZUlUlTmn "#7QM)-$("&;DE !E " E  E 3 E &E "E  E 9E  $E V6?)-$("&;D8 8 3 8 &8 "8  8 98  8 |6?)-$("&;D< < 3 < &< "<  < 9<  :< r-c .eZdZed dZed dZeddded d dZeddded ddZeeeeddded ddZ eddded dd Z eddded dd Z y)r$ct|Sr')AsyncBatchesWithRawResponser)s r+r,zAsyncBatches.with_raw_response_s+400r-ct|Sr/)!AsyncBatchesWithStreamingResponser)s r+r1z$AsyncBatches.with_streaming_responseis166r-Nr2c TKitdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt d|itjd{t||||t d{S7$7w) r9r:r;c32K|]}t|ywr=r>r@s r+rCz&AsyncBatches.create..rDrErFrGrHNrIrJ) rrrNrr rOrrrPrr!rQs r+rRzAsyncBatches.creatersB  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a ZZ ,,j(-CEXEjEjkk(+Q[el%     k s$A=B(?B$ B(B& B(&B(c 2K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j d|dt||||t d {S7w) rTrUr:r;c32K|]}t|ywr=r>r@s r+rCz(AsyncBatches.retrieve..rDrErFrWrXrIrYNrZr]s r+r_zAsyncBatches.retrieves> ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a YY#$4#5Z @(+Q[el%     BBBBr`c@itdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt tt||||t|||dtjtS) rer:r;c32K|]}t|ywr=r>r@s r+rCz$AsyncBatches.list..rDrErFrGrgrhrj) rrrNrr rmrr!rrrrnros r+rpzAsyncBatches.listsP  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a !! ,+,(+'%%$,%.!& &55  ##"  r-c 2K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j d|dt||||t d {S7w) rrrUr:r;c32K|]}t|ywr=r>r@s r+rCz&AsyncBatches.cancel..LrDrErFrWrtrIrYNrur]s r+rvzAsyncBatches.cancel"sJ ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a ZZ#$4#55F G(+Q[el%      rc K|std||j|d{}|jstd|jddi|xsi}it dt |r#djtd |Dd gnti|xsi}dd i|xsi}|j|jt|||| d tt d{S77w)rxrUryNrzr{r|r:r;c32K|]}t|ywr=r>r@s r+rCz'AsyncBatches.results..rDrErFrITr~)r[r_rrrrrrNrr r\rrr"rs r+rzAsyncBatches.results\s1@ ^_o^rst tmm5EmFF   TUZUlUlTmn "#7QM)-$("&;DE !E " E  E 3 E &E "E  E 9E  GE V6?)-$("&;D8 8 3 8 &8 "8  8 98  8 |6?)-$("&;D< < 3 < &< "<  < 9<  ?< r-ceZdZddZy)r(c2||_tj|j|_tj|j|_tj|j |_tj|j |_yr=)_batchesrto_raw_response_wrapperrRr_rprvr*batchess r+__init__zBatchesWithRawResponse.__init__su &>> NN  )@@     %<< LL  '>> NN  r-Nrr#rNonerrrrrr-r+r(r( r-r(ceZdZddZy)rc2||_tj|j|_tj|j|_tj|j |_tj|j |_yr=)rrasync_to_raw_response_wrapperrRr_rprvrs r+rz$AsyncBatchesWithRawResponse.__init__su &DD NN  )FF     %BB LL  'DD NN  r-Nrr$rrrrr-r+rrrr-rceZdZddZy)r0c||_t|j|_t|j|_t|j|_t|j |_yr=)rrrRr_rprvrs r+rz%BatchesWithStreamingResponse.__init__s] 2 NN  5     1 LL  3 NN  r-Nrrrr-r+r0r0rr-r0ceZdZddZy)rc||_t|j|_t|j|_t|j|_t|j |_yr=)rrrRr_rprvrs r+rz*AsyncBatchesWithStreamingResponse.__init__s] 8 NN  ;     7 LL  9 NN  r-Nrrrr-r+rrrr-r)8 __future__rtypingrr itertoolsrhttpxr_typesr r r r r _utilsrrrr_compatr _resourcerr _responserr paginationrr _exceptionsr _base_clientrr_decoders.jsonlrrtypes.beta.messagesrrtypes.anthropic_beta_paramr &types.beta.messages.beta_message_batchr!:types.beta.messages.beta_message_batch_individual_responser"__all__r#r$r(rr0rrr-r+rs#! !@@ (;Z.*A?J=Gm n %z oz z z #z z   $  $  $  r-