AXjvddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZmZmZddlmZdd lmZmZdd lmZmZdd lmZmZdd lm Z dd l!m"Z"m#Z#ddl$m%Z%m&Z&ddl'm(Z(m)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/ddgZ0GddeZ1GddeZ2GddZ3GddZ4GddZ5GddZ6y)) annotations)IterableN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transformstrip_not_givenasync_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 dZeddZeddded ddZddded ddZ eeeddded dd Z 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 j/var/www/html/content_generation/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-Nuser_profile_id extra_headers extra_query extra_bodytimeoutc itd|i|xsi}|jdtd|itjt ||||t S) 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://platform.claude.com/docs/en/build-with-claude/batch-processing) Args: requests: List of requests for prompt completion. Each is an individual request to create a Message. user_profile_id: The user profile ID to attribute the requests in this batch to. Use when acting on behalf of a party other than your organization. Requires the `user-profiles` beta header. Applies to every request in the batch; an individual request whose `user_profile_id` body field conflicts with this header is errored. 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-user-profile-id/v1/messages/batchesrequestsr4r5r6r7bodyoptionscast_to)r_postrrBatchCreateParamsrr r*r<r3r4r5r6r7s r+createzBatches.create/snNu?,G+YZt_l_rprt zz " *h!79L9^9^_(+Q[el!   r-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://platform.claude.com/docs/en/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_idr=r@rA ValueError_getrrr r*rKr4r5r6r7s r+retrievezBatches.retrieve`sV> ^_o^rst tyy CVf g(+Q[el!   r-after_id before_idlimitr4r5r6r7c|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://platform.claude.com/docs/en/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 r;)rSrTrU)r4r5r6r7query)pager@model) _get_api_listrr rrrBatchListParamsr*rSrTrUr4r5r6r7s 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://platform.claude.com/docs/en/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 rHrIrJr=rLrN_deleterrr!rPs 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://platform.claude.com/docs/en/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 rH./v1/messages/batches/{message_batch_id}/cancelrJr=rLrNrBrrr rPs r+cancelzBatches.cancelsWJ ^_o^rst tzz J]m n(+Q[el!   r-c &|std||j|}|jstd|jddi|xsi}|j t |j|t||||ttdS) 2 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://platform.claude.com/docs/en/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 rHrJBNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryr=Tr@rAstream) rNrQ results_urlrprocessing_statusrOrrrr"r*rKr4r5r6r7batchs r+resultszBatches.resultss@ ^_o^rst t /? @   TUZUlUlTmn "#7QMN O(+Q[el!!?@   r-)returnr()rur0r<z%Iterable[batch_create_params.Request]r3 str | Omitr4Headers | Noner5 Query | Noner6 Body | Noner7'float | httpx.Timeout | None | NotGivenrur rKstrr4rxr5ryr6rzr7r{rur )rSrwrTrwrU int | Omitr4rxr5ryr6rzr7r{ruzSyncPage[MessageBatch] rKr}r4rxr5ryr6rzr7r{rur!) rKr}r4rxr5ryr6rzr7r{ruz,JSONLDecoder[MessageBatchIndividualResponse]__name__ __module__ __qualname__rr,r1r r rErQr^rcrhrtr-r+r#r#s-,,22'+)-$("&;D/ 8/ $ / &/ "/  / 9/  / n)-$("&;D' ' & ' "'  ' 9'  ' X $ $ )-$("&;D: :  :  : &: ":  : 9:  : D)-$("&;D' ' & ' "'  ' 9'  ' ^)-$("&;D- - & - "-  - 9-  - j)-$("&;D1 1 & 1 "1  1 91  61 r-c@eZdZed dZeddZeddded ddZddded ddZ eeeddded dd Z ddded dd Z ddded dd Z ddded dd Z y)r$ct|Sr')AsyncBatchesWithRawResponser)s r+r,zAsyncBatches.with_raw_responseRs+400r-ct|Sr/)!AsyncBatchesWithStreamingResponser)s r+r1z$AsyncBatches.with_streaming_response\s166r-Nr2c Kitd|i|xsi}|jdtd|itjd{t ||||t d{S7$7w)r9r:r;r<Nr=r>)rrBrrrCrr rDs r+rEzAsyncBatches.createesNu?,G+YZt_l_rprt ZZ ",j(-CEXEjEjkk(+Q[el!     k s$AA,A( A,#A*$A,*A,r=c K|std||jtd|t||||td{S7w)rGrHrIrJr=rLNrMrPs r+rQzAsyncBatches.retrievesd> ^_o^rst tYY CVf g(+Q[el!     AA A A rRc|jdttt||||t |||dt j tSrW)r[rr rrrr\r]s r+r^zAsyncBatches.listsbP!! "<((+'%%$,%.!& &55  #"  r-c K|std||jtd|t||||td{S7w)r`rHrIrJr=rLNrarPs r+rczAsyncBatches.deletesd> ^_o^rst t\\ CVf g(+Q[el( "    rc K|std||jtd|t||||td{S7w)rerHrfrJr=rLNrgrPs r+rhzAsyncBatches.cancel$seJ ^_o^rst tZZ J]m n(+Q[el!      rc VK|std||j|d{}|jstd|jddi|xsi}|j t |j|t||||ttd d{S7|7w) rjrHrJNrkrlrmr=Trn) rNrQrprrqrOrrrr"rrs r+rtzAsyncBatches.resultsSs@ ^_o^rst tmm5EmFF   TUZUlUlTmn "#7QMN O(+Q[el&&DE    G s"&B)B%A7B) B'!B)'B))rur)rurrvr|)rSrwrTrwrUr~r4rxr5ryr6rzr7r{ruz5AsyncPaginator[MessageBatch, AsyncPage[MessageBatch]]r) rKr}r4rxr5ryr6rzr7r{ruz1AsyncJSONLDecoder[MessageBatchIndividualResponse]rrr-r+r$r$Qs-1177'+)-$("&;D/ 8/ $ / &/ "/  / 9/  / n)-$("&;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_wrapperrErQr^rcrhr*batchess r+__init__zBatchesWithRawResponse.__init__s &>> NN  )@@     %<< LL  '>> NN  '>> NN  r-Nrr#ruNonerrrrrr-r+r(r( r-r(ceZdZddZy)rcz||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_yr)rrasync_to_raw_response_wrapperrErQr^rcrhrs r+rz$AsyncBatchesWithRawResponse.__init__s &DD NN  )FF     %BB LL  'DD NN  'DD NN  r-Nrr$rurrrr-r+rrrr-rceZdZddZy)r0c||_t|j|_t|j|_t|j|_t|j |_t|j |_yr)rrrErQr^rcrhrs r+rz%BatchesWithStreamingResponse.__init__sr 2 NN  5     1 LL  3 NN  3 NN  r-Nrrrr-r+r0r0rr-r0ceZdZddZy)rc||_t|j|_t|j|_t|j|_t|j |_t|j |_yr)rrrErQr^rcrhrs r+rz*AsyncBatchesWithStreamingResponse.__init__sr 8 NN  ;     7 LL  9 NN  9 NN  r-Nrrrr-r+rrrr-r)7 __future__rtypingrhttpxr_typesrrr r r r r _utilsrrrr_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(rr0rrr-r+rs# KKK\\&:Y-)@D>8G^ n %s os l s #s l   *  *  *  r-