~i1rddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZmZddlmZdd lmZmZdd lmZmZdd lmZmZdd lmZdd l m!Z!m"Z"ddl#m$Z$m%Z%ddl&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddgZ/GddeZ0GddeZ1GddZ2GddZ3GddZ4GddZ5y)) 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:eZdZed dZed dZddded ddZddded ddZe e e ddded ddZ ddded dd Z ddded dd Z ddded dd Z y)r"ct|Sa 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 )BatchesWithRawResponseselfs {/var/www/acinvestment.org/public_html/aci/backend/venv/lib/python3.12/site-packages/anthropic/resources/messages/batches.pywith_raw_responsezBatches.with_raw_responses&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,N extra_headers extra_query extra_bodytimeoutc |jdtd|itjt ||||t S)N 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/batchesrequestsr1bodyoptionscast_to)_postrrBatchCreateParamsrrr)r9r2r3r4r5s r*createzBatches.create/sLBzz " *h!79L9^9^_(+Q[el!   r,c |std||jtd|t||||tS)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. 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}message_batch_idr1r<r= ValueError_getrrrr)rGr2r3r4r5s r*retrievezBatches.retrieveYsV> ^_o^rst tyy CVf g(+Q[el!   r,after_id before_idlimitr2r3r4r5c|jdttt||||t |||dt j tSaList 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 r8)rOrPrQ)r2r3r4r5query)pager<model) _get_api_listrrrrrBatchListParamsr)rOrPrQr2r3r4r5s r*listz Batches.listsbP!! ",'(+'%%$,%.!& &55  #"  r,c |std||jtd|t||||tS) 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 rDrErFr1rHrJ_deleterrr rLs r*deletezBatches.deletesV> ^_o^rst t|| CVf g(+Q[el(   r,c |std||jtd|t||||tS) 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 rD./v1/messages/batches/{message_batch_id}/cancelrFr1rHrJr>rrrrLs r*cancelzBatches.cancelsWJ ^_o^rst tzz J]m n(+Q[el!   r,c &|std||j|}|jstd|jddi|xsi}|j t |j|t||||ttdS) . 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 rDrFBNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryr1Tr<r=stream) rJrM results_urlrprocessing_statusrKrrrr!r)rGr2r3r4r5batchs r*resultszBatches.resultss@ ^_o^rst t /? @   TUZUlUlTmn "#7QMN O(+Q[el!!?@   r,)returnr')rqr/ r9z%Iterable[batch_create_params.Request]r2Headers | Noner3 Query | Noner4 Body | Noner5'float | httpx.Timeout | None | NotGivenrqr rGstrr2rsr3rtr4rur5rvrqr)rO str | OmitrPryrQ int | Omitr2rsr3rtr4rur5rvrqzSyncPage[MessageBatch] rGrxr2rsr3rtr4rur5rvrqr ) rGrxr2rsr3rtr4rur5rvrqz,JSONLDecoder[MessageBatchIndividualResponse]__name__ __module__ __qualname__rr+r0r rArMr rZr_rdrpr,r*r"r"s,,22)-$("&;D( 8( & ( "(  ( 9(  ( `)-$("&;D' ' & ' "'  ' 9'  ' X $ $ )-$("&;D: :  :  : &: ":  : 9:  : D)-$("&;D' ' & ' "'  ' 9'  ' ^)-$("&;D- - & - "-  - 9-  - j)-$("&;D1 1 & 1 "1  1 91  61 r,c:eZdZed dZed dZddded ddZddded ddZe e e ddded ddZ ddded dd Z ddded dd Z ddded dd Z y)r#ct|Sr&)AsyncBatchesWithRawResponser(s r*r+zAsyncBatches.with_raw_responseKs+400r,ct|Sr.)!AsyncBatchesWithStreamingResponser(s r*r0z$AsyncBatches.with_streaming_responseUs166r,Nr1c K|jdtd|itjd{t ||||t d{S7$7w)r7r8r9Nr1r:)r>rrr?rrr@s r*rAzAsyncBatches.create^saBZZ ",j(-CEXEjEjkk(+Q[el!     k s!,AA AAAAc K|std||jtd|t||||td{S7w)rCrDrErFr1rHNrIrLs r*rMzAsyncBatches.retrievesd> ^_o^rst tYY CVf g(+Q[el!     AA A A rNc|jdttt||||t |||dt j tSrS)rWrrrrrrXrYs r*rZzAsyncBatches.listsbP!! "<((+'%%$,%.!& &55  #"  r,c K|std||jtd|t||||td{S7w)r\rDrErFr1rHNr]rLs r*r_zAsyncBatches.deletesd> ^_o^rst t\\ CVf g(+Q[el( "    rc K|std||jtd|t||||td{S7w)rarDrbrFr1rHNrcrLs r*rdzAsyncBatches.cancelseJ ^_o^rst tZZ J]m n(+Q[el!      rc VK|std||j|d{}|jstd|jddi|xsi}|j t |j|t||||ttd d{S7|7w) rfrDrFNrgrhrir1Trj) rJrMrlrrmrKrrrr!rns r*rpzAsyncBatches.resultsEs@ ^_o^rst tmm5EmFF   TUZUlUlTmn "#7QMN O(+Q[el&&DE    G s"&B)B%A7B) B'!B)'B))rqr)rqrrrrw)rOryrPryrQrzr2rsr3rtr4rur5rvrqz5AsyncPaginator[MessageBatch, AsyncPage[MessageBatch]]r{) rGrxr2rsr3rtr4rur5rvrqz1AsyncJSONLDecoder[MessageBatchIndividualResponse]r|rr,r*r#r#Js1177)-$("&;D( 8( & ( "(  ( 9(  ( `)-$("&;D' ' & ' "'  ' 9'  ' X $ $ )-$("&;D: :  :  : &: ":  : 9:  ?: D)-$("&;D' ' & ' "'  ' 9'  ' ^)-$("&;D- - & - "-  - 9-  - j)-$("&;D1 1 & 1 "1  1 91  ;1 r,ceZdZddZy)r'cz||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_yN)_batchesrto_raw_response_wrapperrArMrZr_rdr)batchess r*__init__zBatchesWithRawResponse.__init__zs &>> NN  )@@     %<< LL  '>> NN  '>> NN  r,Nrr"rqNoner}r~rrrr,r*r'r'y r,r'ceZdZddZy)rcz||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_yr)rrasync_to_raw_response_wrapperrArMrZr_rdrs r*rz$AsyncBatchesWithRawResponse.__init__s &DD NN  )FF     %BB LL  'DD NN  'DD NN  r,Nrr#rqrrrr,r*rrrr,rceZdZddZy)r/c||_t|j|_t|j|_t|j|_t|j |_t|j |_yr)rrrArMrZr_rdrs r*rz%BatchesWithStreamingResponse.__init__sr 2 NN  5     1 LL  3 NN  3 NN  r,Nrrrr,r*r/r/rr,r/ceZdZddZy)rc||_t|j|_t|j|_t|j|_t|j |_t|j |_yr)rrrArMrZr_rdrs r*rz*AsyncBatchesWithStreamingResponse.__init__sr 8 NN  ;     7 LL  9 NN  9 NN  r,Nrrrr,r*rrrr,r)6 __future__rtypingrhttpxr_typesrrr r r r r _utilsrrr_compatr _resourcerr _responserr paginationrr _exceptionsr _base_clientrrtypes.messagesrr_decoders.jsonlrrtypes.messages.message_batchr$types.messages.deleted_message_batchr 0types.messages.message_batch_individual_responser!__all__r"r#r'rr/rrr,r*rs# KKKKK&:Y-)@D>8G^ n %l ol ^ l #l ^   *  *  *  r,