_j}SSKJr SSKJrJr SSKJr SSKrSSKJ r SSK J r J r J r JrJrJrJr SSKJrJrJrJrJr SS KJr SS KJrJr SS KJrJr SS K J!r!J"r" SS K#J$r$ SSK%J&r&J'r' SSK(J)r)J*r* SSK+J,r,J-r- SSK.J/r/ SSK0J1r1 SSK2J3r3 SSK4J5r5 SS/r6"SS\5r7"SS\5r8"SS5r9"SS5r:"SS5r;"SS 5r!Batches.create..X5Lec!ffemessage-batches-2024-09-24/v1/messages/batches?beta=truerequestsr;r<r=r>bodyoptionscast_to) rrjoinrr_postrr"BatchCreateParamsrr$r/rPr:r;r<r=r>s r0createBatches.create1sH  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a zz , *h!79L9^9^_(+Q[%   r3c 8U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[X4XVS9[S 9$) 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 rArBc38# UHn[U5v M g7frDrErGs r0rJ#Batches.retrieve..rLrMrN1/v1/messages/batches/{message_batch_id}?beta=truemessage_batch_idrQrTrU ValueErrorrrrVrr_getrrr$r/rcr:r;r<r=r>s r0retrieveBatches.retrieveisD ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a yy M`p q(+Q[%   r3after_id before_idlimitr:r;r<r=r>cR0[S[U5(a#SR[SU5S/55O[05EU=(d 0EnSS0U=(d 0EnUR S[ [[UUUU[UUUS.[R5S9[S9$) List 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 rArBc38# UHn[U5v M g7frDrErGs r0rJBatches.list..rLrMrNrOrlrmrnr;r<r=r>querypagerTmodel) rrrVrr _get_api_listrr$rrr!BatchListParams r/rlrmrnr:r;r<r=r>s r0list Batches.listsV  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a !! ,*+(+'%%$,%.!& &55  ##"  r3c 8U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[X4XVS9[S 9$)  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^rArBc38# UHn[U5v M g7frDrErGs r0rJ!Batches.delete..rLrMrNrarbrQrd rfrrrVrr_deleterrr%rhs r0deleteBatches.deletesD ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a || M`p q(+Q[,   r3c 8U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[X4XVS9[S 9$) 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. 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^rArBc38# UHn[U5v M g7frDrErGs r0rJ!Batches.cancel..NrLrMrN8/v1/messages/batches/{message_batch_id}/cancel?beta=truerbrQrd rfrrrVrrrWrrr$rhs r0cancelBatches.cancel!sP ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a zz J]m )+Q[%  r3c U(d[SU<35eURUS9nUR(d[SUR35eSS0U=(d 0En0[ S[ U5(a#SR[SU5S /55O[05EU=(d 0EnSS 0U=(d 0EnUR[URUS9[X4XVS 9[[S S 9$)  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^rbBNo `results_url` for the given batch; Has it finished processing? Acceptapplication/binaryrArBc38# UHn[U5v M g7frDrErGs r0rJ"Batches.results..rLrMrNrQTrTrUstream)rfri results_urlrprocessing_statusrrrVrrrgrrrr&r/rcr:r;r<r=r>batchs r0resultsBatches.results`sF ^_o^rst t /? @   TUZUlUlTmn "#7QMN O(+Q[!!CD   r3)returnr-)rr6rPz%Iterable[batch_create_params.Request]r:List[AnthropicBetaParam] | Omitr;Headers | Noner< Query | Noner= Body | Noner>'float | httpx.Timeout | None | NotGivenrr$rcrFr:rr;rr<rr=rr>rrr$)rl str | Omitrmrrn int | Omitr:rr;rr<rr=rr>rrzSyncPage[BetaMessageBatch]rcrFr:rr;rr<rr=rr>rrr%)rcrFr:rr;rr<rr=rr>rrz0JSONLDecoder[BetaMessageBatchIndividualResponse]__name__ __module__ __qualname____firstlineno__rr1r7rrrZrir|rrr__static_attributes__rr3r0r'r's,,2226)-$("&;D6 86 / 6 &6 "6  6 96  6 x26)-$("&;D5 5 / 5 &5 "5  5 95  5 t $ $ 15)-$("&;DH H  H  H / H &H "H  H 9H  $H \26)-$("&;D5 5 / 5 &5 "5  5 95  !5 v26)-$("&;D= = / = &= "=  = 9=  = F26)-$("&;D? ? / ? &? "?  ? 9?  :? ? r3c \rSrSr\SSj5r\SSj5r\SSS\S.SSjjr \SSS\S.SSjjr \\\\SSS\S.SS jjr \SSS\S.SS jjr \SSS\S.SS jjr \SSS\S.SS jjrS rg)r(ic[U5$r,)AsyncBatchesWithRawResponser.s r0r1AsyncBatches.with_raw_responses+400r3c[U5$r5)!AsyncBatchesWithStreamingResponser.s r0r7$AsyncBatches.with_streaming_responses166r3Nr9c b# 0[S[U5(a#SR[SU5S/55O[05EU=(d 0EnSS0U=(d 0EnUR S[ SU0[R5IShvN [X4XVS9[S 9IShvN $NN7f) r@rArBc38# UHn[U5v M g7frDrErGs r0rJ&AsyncBatches.create..rLrMrNrOrPNrQrR) rrrVrrrWrr"rXrr$rYs r0rZAsyncBatches.createsH  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a ZZ ,,j(-CEXEjEjkk(+Q[%     k s$B B/B+ B/&B-'B/-B/c T# U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[X4XVS9[S 9IS hvN $N7f) r]r^rArBc38# UHn[U5v M g7frDrErGs r0rJ(AsyncBatches.retrieve..rLrMrNrarbrQrdNrerhs r0riAsyncBatches.retrievesD ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a YY M`p q(+Q[%     BB(!B&"B(rkcR0[S[U5(a#SR[SU5S/55O[05EU=(d 0EnSS0U=(d 0EnUR S[ [[UUUU[UUUS.[R5S9[S9$) rprArBc38# UHn[U5v M g7frDrErGs r0rJ$AsyncBatches.list..SrLrMrNrOrsrtrv) rrrVrrryrr$rrr!rzr{s r0r|AsyncBatches.list%sV  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a !! ,+,(+'%%$,%.!& &55  ##"  r3c T# U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[X4XVS9[S 9IS hvN $N7f) rr^rArBc38# UHn[U5v M g7frDrErGs r0rJ&AsyncBatches.delete..rLrMrNrarbrQrdNrrhs r0rAsyncBatches.deleteosD ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a \\ M`p q(+Q[, "    rc T# U(d[SU<35e0[S[U5(a#SR[ SU5S/55O[ 05EU=(d 0EnSS0U=(d 0EnUR [SUS9[X4XVS9[S 9IS hvN $N7f) rr^rArBc38# UHn[U5v M g7frDrErGs r0rJ&AsyncBatches.cancel..rLrMrNrrbrQrdNrrhs r0rAsyncBatches.cancelsP ^_o^rst t  $'*hhu5Le5LOkNl/m&n"  "  *+GaML_]_a ZZ J]m )+Q[%     rc # U(d[SU<35eURUS9IShvN nUR(d[SUR35eSS0U=(d 0En0[ S[ U5(a#SR[S U5S /55O[05EU=(d 0EnSS 0U=(d 0EnUR[URUS9[X4XVS 9[[S S 9IShvN $NN7f)rr^rbNrrrrArBc38# UHn[U5v M g7frDrErGs r0rJ'AsyncBatches.results..rLrMrNrQTr)rfrirrrrrrVrrrgrrr r&rs r0rAsyncBatches.resultss4F ^_o^rst tmm5EmFF   TUZUlUlTmn "#7QMN O(+Q[&&HI    %G$ s")D DCD D D  D r)rr)rrrr)rlrrmrrnrr:rr;rr<rr=rr>rrz=AsyncPaginator[BetaMessageBatch, AsyncPage[BetaMessageBatch]]r)rcrFr:rr;rr<rr=rr>rrz5AsyncJSONLDecoder[BetaMessageBatchIndividualResponse]rrr3r0r(r(s117726)-$("&;D6 86 / 6 &6 "6  6 96  6 x26)-$("&;D5 5 / 5 &5 "5  5 95  5 t $ $ 15)-$("&;DH H  H  H / H &H "H  H 9H  GH \26)-$("&;D5 5 / 5 &5 "5  5 95  !5 v26)-$("&;D= = / = &= "=  = 9=  = F26)-$("&;D? ? / ? &? "?  ? 9?  ?? ? r3c\rSrSrSSjrSrg)r-i'cXl[R"UR5Ul[R"UR5Ul[R"UR 5Ul[R"UR 5Ul[R"UR5Ul[R"UR5UlgrD) _batchesrto_raw_response_wrapperrZrir|rrrr/batchess r0__init__BatchesWithRawResponse.__init__(s &>> NN  )@@     %<< LL  '>> NN  '>> NN  (?? OO  r3rrrZrr|rriNrr'rNonerrrrrrrr3r0r-r-' r3r-c\rSrSrSSjrSrg)ri?cXl[R"UR5Ul[R"UR5Ul[R"UR 5Ul[R"UR 5Ul[R"UR5Ul[R"UR5UlgrD) rrasync_to_raw_response_wrapperrZrir|rrrrs r0r$AsyncBatchesWithRawResponse.__init__@s &DD NN  )FF     %BB LL  'DD NN  'DD NN  (EE OO  r3rNrr(rrrrr3r0rr?rr3rc\rSrSrSSjrSrg)r6iWcHXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5UlgrD)rrrZrir|rrrrs r0r%BatchesWithStreamingResponse.__init__Xs 2 NN  5     1 LL  3 NN  3 NN  4 OO  r3rNrrrr3r0r6r6Wrr3r6c\rSrSrSSjrSrg)riocHXl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5UlgrD)rrrZrir|rrrrs r0r*AsyncBatchesWithStreamingResponse.__init__ps 8 NN  ;     7 LL  9 NN  9 NN  : OO  r3rNrrrr3r0rrorr3r)= __future__rtypingrr itertoolsrhttpxr_typesr r r r r rr_utilsrrrrr_compatr _resourcerr _responserr paginationrr _exceptionsr _base_clientrr_decoders.jsonlrr types.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-rr6rrr3r0rs#! !LLLgg';Z.*A?J=GVm n %B oB J B #B J   0  0  0  r3