`ipddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZddlmZdd lmZmZdd lmZmZdd lmZmZdd lmZdd lm Z m!Z!ddl"m#Z#m$Z$ddl%m&Z&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-ddgZ.GddeZ/GddeZ0GddZ1GddZ2GddZ3GddZ4dS)) annotations)IterableN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)maybe_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 AsyncBatchesceZdZed$dZed%dZdddedd&dZdddedd'dZe e e dddedd(dZ dddedd)d Z dddedd'd!Z dddedd*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 x/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/anthropic/resources/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 )r-r(s r*with_streaming_responsezBatches.with_streaming_response&s,D111r,N extra_headers extra_query extra_bodytimeoutrequests%Iterable[batch_create_params.Request]r2Headers | Noner3 Query | Noner4 Body | Noner5'float | httpx.Timeout | None | NotGivenrc |dtd|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/batchesr6r1bodyoptionscast_to)_postrrBatchCreateParamsrrr)r6r2r3r4r5s r*createzBatches.create/s[Bzz " *h!79L9^__(+Q[el!    r,message_batch_idstrc |std||d|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/r1rArB ValueError_getrrr)rGr2r3r4r5s r*retrievezBatches.retrieveYsn>  us_osstt tyy 6$4 6 6(+Q[el!    r,after_id before_idlimitr2r3r4r5rT str | OmitrUrV int | OmitSyncPage[MessageBatch]c|dttt||||t |||dt jtSaList 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 r>)rTrUrV)r2r3r4r5query)pagerAmodel) _get_api_listrrrrrBatchListParamsr)rTrUrVr2r3r4r5s r*listz Batches.listsxP!! ",'(+'%%$,%.!& &5    #"   r,rc |std||d|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 rKrLr1rMrO_deleterrrQs r*deletezBatches.deletesn>  us_osstt t|| 6$4 6 6(+Q[el(    r,c |std||d|dt||||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 rKrL/cancelr1rMrOrCrrrQs r*cancelzBatches.cancelsrJ  us_osstt tzz =$4 = = =(+Q[el!    r,,JSONLDecoder[MessageBatchIndividualResponse]c  |std|||}|jstd|jddi|pi}||jt ||||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 rKrGBNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryr1TrArBstream) rOrR results_urlrprocessing_statusrPrrr r)rGr2r3r4r5batchs r*resultszBatches.resultss@  us_osstt t /? @@   nUZUlnn "#7QMr6Nr1r?)rCrrrDrrrEs r*rFzAsyncBatches.create^sBZZ ",j(-CEXEjkkkkkkkk(+Q[el!           r,rGrHc K|std||d|t||||td{VS)rJrKrLr1rMNrNrQs r*rRzAsyncBatches.retrieves>  us_osstt tYY 6$4 6 6(+Q[el!          r,rSrTrWrUrVrX5AsyncPaginator[MessageBatch, AsyncPage[MessageBatch]]c|dttt||||t |||dt jtSr[)r_rrrrrr`ras r*rbzAsyncBatches.listsxP!! "<((+'%%$,%.!& &5    #"   r,rc K|std||d|t||||td{VS)rdrKrLr1rMNrerQs r*rgzAsyncBatches.deletes>  us_osstt t\\ 6$4 6 6(+Q[el( "         r,c K|std||d|dt||||td{VS)rirKrLrjr1rMNrkrQs r*rlzAsyncBatches.cancelsJ  us_osstt tZZ =$4 = = =(+Q[el!           r,1AsyncJSONLDecoder[MessageBatchIndividualResponse]c <K|std|||d{V}|jstd|jddi|pi}||jt ||||ttd d{VS) rorKrpNrqrrrsr1Trt) rOrRrvrrwrPrrr rxs r*rzzAsyncBatches.resultsEs@  us_osstt tmm5EmFFFFFFFF   nUZUlnn "#7QM N   )@     %< L   '> N   '> N   r,Nrr!r$rrrrrrr,r*r%r%y(      r,r%ceZdZddZdS)rrr"r$rc@||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSr)rrasync_to_raw_response_wrapperrFrRrbrgrlrs r*rz$AsyncBatchesWithRawResponse.__init__s &D N   )F     %B L   'D N   'D N   r,Nrr"r$rrrr,r*rrrr,rceZdZddZdS)r-rr!r$rc||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr)rrrFrRrbrgrlrs r*rz%BatchesWithStreamingResponse.__init__s 2 N   5     1 L   3 N   3 N   r,Nrrrr,r*r-r-rr,r-ceZdZddZdS)rrr"r$rc||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr)rrrFrRrbrgrlrs r*rz*AsyncBatchesWithStreamingResponse.__init__s 8 N   ;     7 L   9 N   9 N   r,Nrrrr,r*rrrr,r)5 __future__rtypingrhttpxr_typesrrr r r r r _utilsrr_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%rr-rrr,r*rs#""""" KKKKKKKKKKKKKKKKKK<<<<<<<<&&&&&&::::::::YYYYYYYY--------))))))@@@@@@@@DDDDDDDD>>>>>>>>888888GGGGGG^^^^^^ n %l l l l l ol l l ^ l l l l l #l l l ^         *        *        *          r,