i1rddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZmZddlmZdd lmZmZdd lmZmZdd lmZmZdd lmZdd l m!Z!m"Z"ddl#m$Z$m%Z%ddl&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddgZ/GddeZ0GddeZ1GddZ2GddZ3GddZ4GddZ5dS)) annotations)IterableN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_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 a/root/projects/qq-shell/venv/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]r3Headers | Noner4 Query | Noner5 Body | Noner6'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/batchesr7r2bodyoptionscast_to)_postrrBatchCreateParamsrrr*r7r3r4r5r6s r+createzBatches.create/s[Bzz " *h!79L9^__(+Q[el!    r-message_batch_idstrc |std||td|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/{message_batch_id}rHr2rBrC ValueError_getrrrr*rHr3r4r5r6s r+retrievezBatches.retrieveYst>  us_osstt tyy CVf g g g(+Q[el!    r-after_id before_idlimitr3r4r5r6rV str | OmitrWrX 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?)rVrWrX)r3r4r5r6query)pagerBmodel) _get_api_listrrrrrBatchListParamsr*rVrWrXr3r4r5r6s r+listz Batches.listsxP!! ",'(+'%%$,%.!& &5    #"   r-r c |std||td|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 rLrMrNr2rOrQ_deleterrr rSs r+deletezBatches.deletest>  us_osstt t|| CVf g g g(+Q[el(    r-c |std||td|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://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 rL./v1/messages/batches/{message_batch_id}/cancelrNr2rOrQrDrrrrSs r+cancelzBatches.cancelsuJ  us_osstt tzz J]m n n n(+Q[el!    r-,JSONLDecoder[MessageBatchIndividualResponse]c >|std|||}|jstd|jddi|pi}|t |j|t||||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 rLrNBNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryr2TrBrCstream) rQrT results_urlrprocessing_statusrRrrrr!r*rHr3r4r5r6batchs r+resultszBatches.resultss@  us_osstt t /? @@   nUZUlnn "#7QMN O O O(+Q[el!!?@    r-)r%r&)r%r. r7r8r3r9r4r:r5r;r6r<r%r rHrIr3r9r4r:r5r;r6r<r%r)rVrYrWrYrXrZr3r9r4r:r5r;r6r<r%r[ rHrIr3r9r4r:r5r;r6r<r%r ) rHrIr3r9r4r:r5r;r6r<r%ro__name__ __module__ __qualname__rr,r1r rGrTr rdrirnr{r-r+r"r"sj,,,_,222_2)-$("&;D( ( ( ( ( ( `)-$("&;D' ' ' ' ' ' X $ $ )-$("&;D: : : : : : D)-$("&;D' ' ' ' ' ' ^)-$("&;D- - - - - - j)-$("&;D1 1 1 1 1 1 1 1 r-ceZdZed$dZed%dZdddedd&dZdddedd'dZe e e dddedd(dZ dddedd)d Z dddedd'd!Z dddedd*d#Z dS)+r#r%AsyncBatchesWithRawResponsec t|Sr()rr)s r+r,zAsyncBatches.with_raw_responseKs+4000r-!AsyncBatchesWithStreamingResponsec t|Sr0)rr)s r+r1z$AsyncBatches.with_streaming_responseUs1666r-Nr2r7r8r3r9r4r:r5r;r6r<rc K|dtd|itjd{Vt ||||t d{VS)r>r?r7Nr2r@)rDrrrErrrFs r+rGzAsyncBatches.create^sBZZ ",j(-CEXEjkkkkkkkk(+Q[el!           r-rHrIc K|std||td|t||||td{VS)rKrLrMrNr2rONrPrSs r+rTzAsyncBatches.retrieves>  us_osstt tYY CVf g g g(+Q[el!          r-rUrVrYrWrXrZ5AsyncPaginator[MessageBatch, AsyncPage[MessageBatch]]c|dttt||||t |||dt jtSr])rarrrrrrbrcs r+rdzAsyncBatches.listsxP!! "<((+'%%$,%.!& &5    #"   r-r c K|std||td|t||||td{VS)rfrLrMrNr2rONrgrSs r+rizAsyncBatches.deletes>  us_osstt t\\ CVf g g g(+Q[el( "         r-c K|std||td|t||||td{VS)rkrLrlrNr2rONrmrSs r+rnzAsyncBatches.cancelsJ  us_osstt tZZ J]m n n n(+Q[el!           r-1AsyncJSONLDecoder[MessageBatchIndividualResponse]c ZK|std|||d{V}|jstd|jddi|pi}|t |j|t||||ttd d{VS) rqrLrNNrrrsrtr2Tru) rQrTrwrrxrRrrrr!rys r+r{zAsyncBatches.resultsEs @  us_osstt tmm5EmFFFFFFFF   nUZUlnn "#7QMN O O O(+Q[el&&DE          r-)r%r)r%rr|r})rVrYrWrYrXrZr3r9r4r:r5r;r6r<r%rr~) rHrIr3r9r4r:r5r;r6r<r%rrrr-r+r#r#Jsj111_1777_7)-$("&;D( ( ( ( ( ( `)-$("&;D' ' ' ' ' ' X $ $ )-$("&;D: : : : : : D)-$("&;D' ' ' ' ' ' ^)-$("&;D- - - - - - j)-$("&;D1 1 1 1 1 1 1 1 r-ceZdZddZdS)r&batchesr"r%Nonec@||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSN)_batchesrto_raw_response_wrapperrGrTrdrirnr*rs r+__init__zBatchesWithRawResponse.__init__zs &> 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_wrapperrGrTrdrirnrs 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)rrrGrTrdrirnrs 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)rrrGrTrdrirnrs r+rz*AsyncBatchesWithStreamingResponse.__init__s 8 N   ;     7 L   9 N   9 N   r-Nrrrr-r+rrrr-r)6 __future__rtypingrhttpxr_typesrrr r r r r _utilsrrr_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.rrr-r+rs#""""" KKKKKKKKKKKKKKKKKKKKKKKKKKKK&&&&&&::::::::YYYYYYYY--------))))))@@@@@@@@DDDDDDDD>>>>>>>>888888GGGGGG^^^^^^ n %l l l l l ol l l ^ l l l l l #l l l ^         *        *        *          r-