o 6Wjv@shddlmZddlmZddlZddlmZddlmZm 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/ddgZ0GdddeZ1GdddeZ2GdddZ3GdddZ4GdddZ5GdddZ6dS)) 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.ddZed/ddZeddded d0ddZdddedd1ddZ eeedddedd2d$d%Z dddedd3d'd(Z dddedd1d)d*Z dddedd4d,d-Z dS)5r"returnBatchesWithRawResponsecCt|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&selfr+s/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/anthropic/resources/messages/batches.pywith_raw_responsezBatches.with_raw_responseBatchesWithStreamingResponsecCr'z 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)r+r+r,with_streaming_response&zBatches.with_streaming_responseNuser_profile_id extra_headers extra_query extra_bodytimeoutrequests%Iterable[batch_create_params.Request]r4 str | Omitr5Headers | Noner6 Query | Noner7 Body | Noner8'float | httpx.Timeout | None | NotGivenrc CsBitd|i|p i}|jdtd|itjt||||dtdS) 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/batchesr9r5r6r7r8bodyoptionscast_to)r_postrrBatchCreateParamsrrr*r9r4r5r6r7r8r+r+r,create/s'zBatches.createrCmessage_batch_idstrcC6|s td||jtd|dt||||dtdS)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}rLrCrFrG ValueError_getr rrr*rLr5r6r7r8r+r+r,retrieve` zBatches.retrieveafter_id before_idlimitr5r6r7r8r[r\r] int | OmitSyncPage[MessageBatch]c C4|jdttt||||t|||dtjdtdSaList 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 rB)r[r\r])r5r6r7r8query)pagerFmodel) _get_api_listrrrrrBatchListParamsr*r[r\r]r5r6r7r8r+r+r,list$(z Batches.listr cCrN) 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 rPrQrRrCrSrU_deleter rr rWr+r+r,deleterYzBatches.deletecCrN)$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 rP./v1/messages/batches/{message_batch_id}/cancelrRrCrSrUrHr rrrWr+r+r,cancels% zBatches.cancel,JSONLDecoder[MessageBatchIndividualResponse]cCsp|s td||j|d}|jstd|jddi|p i}|jt|j|dt||||dtt ddS) 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 rPrRBNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryrCTrFrGstream) rUrX results_urlrprocessing_statusrVr rrr!r*rLr5r6r7r8batchr+r+r,resultss     zBatches.results)r%r&)r%r/r9r:r4r;r5r<r6r=r7r>r8r?r%r rLrMr5r<r6r=r7r>r8r?r%r)r[r;r\r;r]r^r5r<r6r=r7r>r8r?r%r_ rLrMr5r<r6r=r7r>r8r?r%r ) rLrMr5r<r6r=r7r>r8r?r%rr__name__ __module__ __qualname__rr-r1r r rKrXrhrmrqr}r+r+r+r,r"N   7,B/5c@r$)5r#r%AsyncBatchesWithRawResponsecCr'r()rr)r+r+r,r-Rr.zAsyncBatches.with_raw_response!AsyncBatchesWithStreamingResponsecCr'r0)rr)r+r+r,r1\r2z$AsyncBatches.with_streaming_responseNr3r9r:r4r;r5r<r6r=r7r>r8r?rc sPitd|i|p i}|jdtd|itjIdHt||||dtdIdHS)r@rArBr9NrCrD)rrHrrrIrrrJr+r+r,rKes' zAsyncBatches.createrCrLrMc>|s td||jtd|dt||||dtdIdHS)rOrPrQrRrCrSNrTrWr+r+r,rX  zAsyncBatches.retrieverZr[r\r]r^5AsyncPaginator[MessageBatch, AsyncPage[MessageBatch]]c Cr`ra)rerrrrrrfrgr+r+r,rhrizAsyncBatches.listr cr)rjrPrQrRrCrSNrkrWr+r+r,rmrzAsyncBatches.deletecr)rnrProrRrCrSNrprWr+r+r,rq$s%  zAsyncBatches.cancel1AsyncJSONLDecoder[MessageBatchIndividualResponse]cs~|s td||j|dIdH}|jstd|jddi|p$i}|jt|j|dt||||dtt dd IdHS) rsrPrRNrtrurvrCTrw) rUrXryrrzrVr rrr!r{r+r+r,r}Ss"    zAsyncBatches.results)r%r)r%rr~r)r[r;r\r;r]r^r5r<r6r=r7r>r8r?r%rr) rLrMr5r<r6r=r7r>r8r?r%rrr+r+r+r,r#Qrc@eZdZdddZdS) r&batchesr"r%NonecCP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSN)_batchesrto_raw_response_wrapperrKrXrhrmrqr*rr+r+r,__init__  zBatchesWithRawResponse.__init__Nrr"r%rrrrrr+r+r+r,r&r&c@r) rrr#r%rcCrr)rrasync_to_raw_response_wrapperrKrXrhrmrqrr+r+r,rrz$AsyncBatchesWithRawResponse.__init__Nrr#r%rrr+r+r+r,rrrc@r) r/rr"r%rcCF||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr)rrrKrXrhrmrqrr+r+r,r  z%BatchesWithStreamingResponse.__init__Nrrr+r+r+r,r/rr/c@r) rrr#r%rcCrr)rrrKrXrhrmrqrr+r+r,rrz*AsyncBatchesWithStreamingResponse.__init__Nrrr+r+r+r,rrr)7 __future__rtypingrhttpxr_typesrrrr r r r _utilsr rrr_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/rr+r+r+r,s8   $     88