`iddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z m Z mZmZmZmZddlmZmZmZmZdd lmZdd lmZmZdd lmZmZdd lm Z m!Z!dd l"m#Z#ddl$m%Z%m&Z&ddl'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4ddgZ5GddeZ6GddeZ7GddZ8GddZ9GddZ:Gdd Z;dS)!) annotations)ListIterable)chainN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)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)BetaDeletedMessageBatch)"BetaMessageBatchIndividualResponseBatches AsyncBatchesc eZdZed&dZed'dZedddedd(dZedddedd)dZ eeeedddedd*d Z edddedd+d"Z edddedd)d#Z edddedd,d%Z dS)-r&returnBatchesWithRawResponsec t|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 )r*selfs }/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/anthropic/resources/beta/messages/batches.pywith_raw_responsezBatches.with_raw_responses&d+++BatchesWithStreamingResponsec t|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 )r2r-s r/with_streaming_responsezBatches.with_streaming_response(s,D111r1Nbetas extra_headers extra_query extra_bodytimeoutrequests%Iterable[batch_create_params.Request]r7List[AnthropicBetaParam] | Omitr8Headers | Noner9 Query | Noner: Body | Noner;'float | httpx.Timeout | None | NotGivenr#c Vitdt|r.dtd|Ddgnti|pi}ddi|pi}|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. 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,c34K|]}t|VdSNstr.0es r/ z!Batches.create..X(5L5Lc!ff5L5L5L5L5L5Lr1message-batches-2024-09-24/v1/messages/batches?beta=truer<r8r9r:r;bodyoptionscast_to) rrjoinrr_postrr!BatchCreateParamsrr#r.r<r7r8r9r:r;s r/createzBatches.create1sH  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a zz , *h!79L9^__(+Q[el%    r1message_batch_idrJc P|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|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. 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 rErFc34K|]}t|VdSrHrIrKs r/rNz#Batches.retrieve..rOr1rP/v1/messages/batches/ ?beta=truerRrUrV ValueErrorrrrWrr_getrr#r.r\r7r8r9r:r;s r/retrievezBatches.retrieveisD  us_osstt t  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a yy @$4 @ @ @(+Q[el%    r1after_id before_idlimitr7r8r9r:r;rj str | Omitrkrl int | OmitSyncPage[BetaMessageBatch]c|itdt|r.dtd|Ddgnti|pi}ddi|pi}|dt tt||||t|||dtj tS) 4List 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 rErFc34K|]}t|VdSrHrIrKs r/rNzBatches.list..rOr1rPrQrjrkrlr8r9r:r;querypagerUmodel) rrrWrr _get_api_listrr#rrr BatchListParams r.rjrkrlr7r8r9r:r;s r/listz Batches.listsV  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a !! ,*+(+'%%$,%.!& &5    ##"   r1r$c P|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|d|dt||||t S)  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 r_rErFc34K|]}t|VdSrHrIrKs r/rNz!Batches.delete..rOr1rPrarbrRrc rerrrWrr_deleterr$rgs r/deletezBatches.deletesD  us_osstt t  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a || @$4 @ @ @(+Q[el,    r1c P|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|d|dt||||t S) rBatches 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 r_rErFc34K|]}t|VdSrHrIrKs r/rNz!Batches.cancel..NrOr1rPra/cancel?beta=truerRrc rerrrWrrrXrr#rgs r/cancelzBatches.cancel!sP  us_osstt t  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a zz G$4 G G G(+Q[el%    r10JSONLDecoder[BetaMessageBatchIndividualResponse]c |std|||}|jstd|jddi|pi}it dt |r.dtd|Dd gnti|pi}dd i|pi}| |jt|||| ttd 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. 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 r_r\BNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryrErFc34K|]}t|VdSrHrIrKs r/rNz"Batches.results..rOr1rPrRTrUrVstream)rerh results_urlrprocessing_statusrrrWrrrfrrr%r.r\r7r8r9r:r;batchs r/resultszBatches.results^sPF  us_osstt t /? @@   nUZUlnn "#7QMr8r?r9r@r:rAr;rBr)r#r\rJr7r>r8r?r9r@r:rAr;rBr)r#)rjrmrkrmrlrnr7r>r8r?r9r@r:rAr;rBr)ror\rJr7r>r8r?r9r@r:rAr;rBr)r$)r\rJr7r>r8r?r9r@r:rAr;rBr)r__name__ __module__ __qualname__rr0r5rrr[rhr|rrrr1r/r&r&s,,,_,222_226)-$("&;D6 6 6 6 6 6 x26)-$("&;D5 5 5 5 5 5 t $ $ 15)-$("&;DH H H H H H \26)-$("&;D5 5 5 5 5 5 v26)-$("&;D; ; ; ; ; ; B26)-$("&;D? ? ? ? ? ? ? ? r1c eZdZed&dZed'dZedddedd(dZedddedd)dZ eeeedddedd*d Z edddedd+d"Z edddedd)d#Z edddedd,d%Z dS)-r'r)AsyncBatchesWithRawResponsec t|Sr,)rr-s r/r0zAsyncBatches.with_raw_responses+4000r1!AsyncBatchesWithStreamingResponsec t|Sr4)rr-s r/r5z$AsyncBatches.with_streaming_responses1666r1Nr6r<r=r7r>r8r?r9r@r:rAr;rBr#c rKitdt|r.dtd|Ddgnti|pi}ddi|pi}|dt d|itjd{Vt||||t d{VS) rDrErFc34K|]}t|VdSrHrIrKs r/rNz&AsyncBatches.create..rOr1rPrQr<NrRrS) rrrWrrrXrr!rYrr#rZs r/r[zAsyncBatches.createsH  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a ZZ ,,j(-CEXEjkkkkkkkk(+Q[el%           r1r\rJc `K|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|d|dt||||t d {VS) r^r_rErFc34K|]}t|VdSrHrIrKs r/rNz(AsyncBatches.retrieve..rOr1rPrarbrRrcNrdrgs r/rhzAsyncBatches.retrievesD  us_osstt t  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a YY @$4 @ @ @(+Q[el%          r1rirjrmrkrlrn=AsyncPaginator[BetaMessageBatch, AsyncPage[BetaMessageBatch]]c|itdt|r.dtd|Ddgnti|pi}ddi|pi}|dt tt||||t|||dtj tS) rqrErFc34K|]}t|VdSrHrIrKs r/rNz$AsyncBatches.list..QrOr1rPrQrsrtrv) rrrWrrryrr#rrr rzr{s r/r|zAsyncBatches.list#sV  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a !! ,+,(+'%%$,%.!& &5    ##"   r1r$c `K|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|d|dt||||t d {VS) r~r_rErFc34K|]}t|VdSrHrIrKs r/rNz&AsyncBatches.delete..rOr1rPrarbrRrcNrrgs r/rzAsyncBatches.deletemsD  us_osstt t  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a \\ @$4 @ @ @(+Q[el, "         r1c `K|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|d|dt||||t d {VS) rr_rErFc34K|]}t|VdSrHrIrKs r/rNz&AsyncBatches.cancel..rOr1rPrarrRrcNrrgs r/rzAsyncBatches.cancelsP  us_osstt t  $'#chhu5L5Le5L5L5LOkNl/m/m&n&n&n"  "  *+GaML_]_a ZZ G$4 G G G(+Q[el%           r15AsyncJSONLDecoder[BetaMessageBatchIndividualResponse]c K|std|||d{V}|jstd|jddi|pi}it dt |r.dtd |Dd gnti|pi}dd i|pi}| |jt|||| ttd d{VS)rr_rNrrrrErFc34K|]}t|VdSrHrIrKs r/rNz'AsyncBatches.results..rOr1rPrRTr)rerhrrrrrrWrrrfrrr%rs r/rzAsyncBatches.resultssF  us_osstt tmm5EmFFFFFFFF   nUZUlnn "#7QMr8r?r9r@r:rAr;rBr)rr)r\rJr7r>r8r?r9r@r:rAr;rBr)rrrr1r/r'r's111_1777_726)-$("&;D6 6 6 6 6 6 x26)-$("&;D5 5 5 5 5 5 t $ $ 15)-$("&;DH H H H H H \26)-$("&;D5 5 5 5 5 5 v26)-$("&;D; ; ; ; ; ; B26)-$("&;D? ? ? ? ? ? ? ? r1ceZdZddZdS)r*batchesr&r)Nonec@||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSrH)_batchesrto_raw_response_wrapperr[rhr|rrr.rs r/__init__zBatchesWithRawResponse.__init__$s &> N   )@     %< L   '> N   '> N   r1Nrr&r)rrrrrrr1r/r*r*#(      r1r*ceZdZddZdS)rrr'r)rc@||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSrH)rrasync_to_raw_response_wrapperr[rhr|rrrs r/rz$AsyncBatchesWithRawResponse.__init__9s &D N   )F     %B L   'D N   'D N   r1Nrr'r)rrrr1r/rr8rr1rceZdZddZdS)r2rr&r)rc||_t|j|_t|j|_t|j|_t|j|_t|j|_dSrH)rrr[rhr|rrrs r/rz%BatchesWithStreamingResponse.__init__Ns 2 N   5     1 L   3 N   3 N   r1Nrrrr1r/r2r2Mrr1r2ceZdZddZdS)rrr'r)rc||_t|j|_t|j|_t|j|_t|j|_t|j|_dSrH)rrr[rhr|rrrs r/rz*AsyncBatchesWithStreamingResponse.__init__cs 8 N   ;     7 L   9 N   9 N   r1Nrrrr1r/rrbrr1r)< __future__rtypingrr itertoolsrhttpxr_typesr r r r r rr_utilsrrrr_compatr _resourcerr _responserr paginationrr _exceptionsr _base_clientrr_decoders.jsonlrrtypes.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*rr2rrr1r/rs#"""""!!!!!!!! !!!!!!LLLLLLLLLLLLLLLLLLXXXXXXXXXXXX'''''';;;;;;;;ZZZZZZZZ........******AAAAAAAA????????JJJJJJJJ======GGGGGGVVVVVVmmmmmm n %@ @ @ @ @ o@ @ @ F @ @ @ @ @ #@ @ @ F         *        *        *          r1