o +ip@s`ddlmZddlmZddlZddlmZddlmZm 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.GdddeZ/GdddeZ0GdddZ1GdddZ2GdddZ3GdddZ4dS)) 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 AsyncBatchesc@eZdZed,ddZed-ddZddded d.ddZddded d/ddZe e e dddedd0d"d#Z ddded d1d%d&Z ddded d/d'd(Z ddded d2d*d+Z dS)3r 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)a/var/www/html/psymed-ai/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_responseN extra_headers extra_query extra_bodytimeoutrequests%Iterable[batch_create_params.Request]r2Headers | Noner3 Query | Noner4 Body | Noner5'float | httpx.Timeout | None | NotGivenrc Cs*|jdtd|itjt||||dtdS)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)_postr rBatchCreateParamsrrr(r6r2r3r4r5r)r)r*create/s!zBatches.createmessage_batch_idstrcC4|s td||jd|t||||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://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/r1r@rA ValueError_getrrr(rFr2r3r4r5r)r)r*retrieveYzBatches.retrieveafter_id before_idlimitr2r3r4r5rT str | OmitrUrV 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://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)pager@model) _get_api_listrrrr rBatchListParamsr(rTrUrVr2r3r4r5r)r)r*list$(z Batches.listrcCrH) 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 rJrKr1rLrN_deleterrrPr)r)r*deleterRzBatches.deletecCs6|s td||jd|dt||||dtdS) 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 rJrK/cancelr1rLrNrBrrrPr)r)r*cancels% zBatches.cancel,JSONLDecoder[MessageBatchIndividualResponse]cCsh|s td||j|d}|jstd|jddi|p i}|j|jt||||dttddS) . 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 rJrFBNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryr1Tr@rAstream) rNrQ results_urlrprocessing_statusrOrrrr(rFr2r3r4r5batchr)r)r*resultss    zBatches.results)r#r$)r#r- r6r7r2r8r3r9r4r:r5r;r#r rFrGr2r8r3r9r4r:r5r;r#r)rTrWrUrWrVrXr2r8r3r9r4r:r5r;r#rY rFrGr2r8r3r9r4r:r5r;r#r) rFrGr2r8r3r9r4r:r5r;r#rl__name__ __module__ __qualname__rr+r/r rErQr rbrgrkrxr)r)r)r*r L  0,B/5c@r")3r!r#AsyncBatchesWithRawResponsecCr%r&)rr'r)r)r*r+Kr,zAsyncBatches.with_raw_response!AsyncBatchesWithStreamingResponsecCr%r.)rr'r)r)r*r/Ur0z$AsyncBatches.with_streaming_responseNr1r6r7r2r8r3r9r4r:r5r;rc s8|jdtd|itjIdHt||||dtdIdHS)r<r=r6Nr1r>)rBrrrCrrrDr)r)r*rE^s! zAsyncBatches.createrFrGc<|s td||jd|t||||dtdIdHS)rIrJrKr1rLNrMrPr)r)r*rQ zAsyncBatches.retrieverSrTrWrUrVrX5AsyncPaginator[MessageBatch, AsyncPage[MessageBatch]]c CrZr[)r_rrrr rr`rar)r)r*rbrczAsyncBatches.listrcr)rdrJrKr1rLNrerPr)r)r*rgrzAsyncBatches.deletecs>|s td||jd|dt||||dtdIdHS)rhrJrKrir1rLNrjrPr)r)r*rks%  zAsyncBatches.cancel1AsyncJSONLDecoder[MessageBatchIndividualResponse]csv|s td||j|dIdH}|jstd|jddi|p$i}|j|jt||||dttdd IdHS) rmrJrnNrorprqr1Trr) rNrQrtrrurOrrrrvr)r)r*rxEs"   zAsyncBatches.results)r#r)r#rryrz)rTrWrUrWrVrXr2r8r3r9r4r:r5r;r#rr{) rFrGr2r8r3r9r4r:r5r;r#rr|r)r)r)r*r!Jrc@eZdZdddZdS) r$batchesr r#NonecCP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSN)_batchesrto_raw_response_wrapperrErQrbrgrkr(rr)r)r*__init__z  zBatchesWithRawResponse.__init__Nrr r#rr}r~rrr)r)r)r*r$yr$c@r) rrr!r#rcCrr)rrasync_to_raw_response_wrapperrErQrbrgrkrr)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)rrrErQrbrgrkrr)r)r*r  z%BatchesWithStreamingResponse.__init__Nrrr)r)r)r*r-rr-c@r) rrr!r#rcCrr)rrrErQrbrgrkrr)r)r*rrz*AsyncBatchesWithStreamingResponse.__init__Nrrr)r)r)r*rrr)5 __future__rtypingrhttpxr_typesrrrr r r r _utilsr r_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-rr)r)r)r*s8   $     11