Dj UddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Zddl mZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddl m!Z!m"Z"m#Z#ddl$Z$ddl%Z%ddl&Z&ddl'Z'ddl%m(Z(m)Z)ddl'm*Z*d d l+m,Z,d d l-m.Z.d d l/m0Z0m1Z1d d l2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDd dlEmFZFmGZGmHZHmIZImJZJmKZKd dlLmMZMmNZNd dlOmPZPmQZQmRZRmSZSd dlTmUZUmVZVmWZWmXZXd dlYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`d dlambZbmcZcmdZdmeZed dl,mfZfmgZgmhZhmiZid dljmkZke jemZndeod<eddZpeddZqedZredd Zsed!ebeZted"edeZuerdd#lvmwZxn dd#lvmwZxGd%d&ZzGd'd(ePeerZ{Gd)d*e{ereerZ|Gd+d,eereqfZ}Gd-d.e{ereerZ~ed/ee%je%jfZed0eebeedefZGd1d2eeefZGd3d4e%jZer e%jZneZGd5d6eZGd7d8ee%jebefZGd9d:e%jZere%jZneZGd;dee%jedefZddddde3e3d? dPd@ZGdAdBeedfZGdCdDZeee!dEfZdQdFZeJdGdRdHZGdIdJZeee!dKfZdSdLZdSdMZdTdNZ dUdOZy#ey$r e8d$ZxYwxYw)V) annotationsN) TracebackType)random) TYPE_CHECKINGAnyDictTypeUnionGenericMappingTypeVarIterableIteratorOptional Generator AsyncIteratorcastoverload)Literaloverride get_origin)URLLimits) PrivateAttr) _exceptions Querystring)to_httpx_filesasync_to_httpx_files) NOT_GIVENBodyOmitQueryHeadersTimeoutNotGiven ResponseT Transport AnyMapping PostParser ProxiesTypes RequestFiles HttpxSendArgsAsyncTransportRequestOptionsHttpxRequestFilesModelBuilderProtocol)is_dictis_listasyncifyis_given lru_cache is_mapping) model_copy model_dump) GenericModelFinalRequestOptions validate_typeconstruct_type) APIResponseBaseAPIResponseAsyncAPIResponseextract_response_type)DEFAULT_TIMEOUTMAX_RETRY_DELAYDEFAULT_MAX_RETRIESINITIAL_RETRY_DELAYRAW_RESPONSE_HEADEROVERRIDE_CAST_TO_HEADERDEFAULT_CONNECTION_LIMITS)Stream SSEDecoder AsyncStreamSSEBytesDecoder)APIStatusErrorAPITimeoutErrorAPIConnectionErrorAPIResponseValidationError)LegacyAPIResponsezlogging.Loggerlog SyncPageTzBaseSyncPage[Any])bound AsyncPageTzBaseAsyncPage[Any]_T_T_coT) covariant_StreamT _AsyncStreamT)DEFAULT_TIMEOUT_CONFIGg@ceZdZUdZded<ded<e d dZe d dZeed dd Zedd Z y )PageInfozStores the necessary information to build the request to retrieve the next page. Either `url` or `params` must be set. URL | NotGivenurlQuery | NotGivenparamscyNselfr`s ZC:\Crop_Prediction\Backend\crop-ai-system\venv\Lib\site-packages\anthropic/_base_client.py__init__zPageInfo.__init__| cyrdre)rgrbs rhrizPageInfo.__init__rjrkr`rbc ||_||_yrdrm)rgr`rbs rhrizPageInfo.__init__s  rkc|jr&|jjd|jdS|jjd|jdS)Nz(url=)z(params=)r` __class____name__rbrgs rh__repr__zPageInfo.__repr__sM 88nn--.eDHH:Q? ?..))*(4;;-qAArkN)r`rreturnNone)rbr$rurv)r`r_rbrarurvrustr) rr __module__ __qualname____doc____annotations__rrir!rrtrerkrhr^r^ss        (#, !   BBrkr^cjeZdZUdZeZded<eZded<d dZd dZ ddZ dd Z dd Z y )BasePagea< Defines the core interface for pagination. Type Args: ModelT: The pydantic model that represents an item in the response. Methods: has_next_page(): Check if there is another page available next_page_info(): Get the necessary information to make a request for the next page r<_optionsType[_T]_modelcL|j}|sy|jduS)NF)_get_page_itemsnext_page_info)rgitemss rh has_next_pagezBasePage.has_next_pages*$$&""$D00rkcyrdrerss rhrzBasePage.next_page_infosrkcyrdrerss rhrzBasePage._get_page_itemss rkctjtt|jj j |j Srd)httpx QueryParamsrrrrbmergerfs rh_params_from_urlzBasePage._params_from_urls3  c4==+?+?!@AGG SSrkct|j}|jt|jt s!i|j|j|_|St|j t sc|j|j }|j j|}t|j|_t||_|Std)N)rbzUnexpected PageInfo state) r9r_strip_raw_response_header isinstancerbr'r`r copy_withdictrx ValueError)rginfooptionsrbr`s rh_info_to_optionszBasePage._info_to_optionssT]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455rkNrubool)ruzOptional[PageInfo])ruz Iterable[_T])r`rruzhttpx.QueryParams)rr^rur<) rrryrzr{rrr|rrrrrrrerkrhr~r~s< %0MH!1"}FH$1 8 T6rkr~cjeZdZUejZded< ddZd dZd dZ d dZ y) BaseSyncPage SyncAPIClient_clientc.||_||_||_yrdrrr)rgclientmodelrs rh_set_private_attributesz$BaseSyncPage._set_private_attributes    rkc#hK|jD]}|jD]}|ywrd iter_pagesrrgpageitems rh__iter__zBaseSyncPage.__iter__s9OO% D,,.    s02c#^K|} ||jr|j}ny'wrdr get_next_pagergrs rhrzBaseSyncPage.iter_pagess5J!!#))+ s+-c|j}|s td|j|}|jj |j |j |SNzYNo next page expected; please check `.has_next_page()` before calling `.get_next_page()`.)rrr RuntimeErrorrr_request_api_listrrqrgrrs rhrzBaseSyncPage.get_next_pagesZ""$k ''-||--dkkX_-``rkN)rrrrrr<rurv)ruz Iterator[_T])rgrTruzIterator[SyncPageT])rgrTrurT) rrryrzpydanticrrr|rrrrrerkrhrrsR1X113G]3   %    $ arkrc@eZdZ ddZddZddZd dZy) AsyncPaginatorc<||_||_||_||_yrd)rrr _page_cls)rgrrpage_clsrs rhrizAsyncPaginator.__init__s    !rkc>|jjSrd) _get_page __await__rss rhrzAsyncPaginator.__await__s~~))++rkcKdfd }|j_jjjjd{S7w)Ncl|jjjj|S)N)rrr)rrrr)resprgs rh_parserz)AsyncPaginator._get_page.._parser s2  ( (kk || )  Krk)rrVrurV)r post_parserrrequestr)rgrs` rhrzAsyncPaginator._get_pages? %, !\\))$..$--HHHHsA AAAchKtt|d{}|23d{}|77 6ywrd)rrVrs rh __aiter__zAsyncPaginator.__aiter__s< J   $J  $s$2, 20.0202N) rAsyncAPIClientrr<rType[AsyncPageT]rrrurv)ruz Generator[Any, None, AsyncPageT])rurVruzAsyncIterator[_T])rrryrzrirrrrerkrhrrsG " "% "# "  "  ", IrkrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseAsyncPagerrc.||_||_||_yrdr)rgrrrs rhrz%BaseAsyncPage._set_private_attributes"rrkczK|j23d{}|jD]}| $76ywrdrrs rhrzBaseAsyncPage.__aiter__,sB//+  $,,.    +s;979;9;ctK|} ||jr|jd{}ny07wrdrrs rhrzBaseAsyncPage.iter_pages1s=J!!#!//11 2s ,868cK|j}|s td|j|}|jj |j |j |d{S7wrrrs rhrzBaseAsyncPage.get_next_page:sd""$k ''-\\33DKKdnn^e3ffffsA$A-&A+'A-N)rrrrrr<rurvr)rgrVruzAsyncIterator[AsyncPageT])rgrVrurV) rrryrzrrrr|rrrrrerkrhrrsR2h224G^4   %     grkr _HttpxClientT_DefaultStreamTcHeZdZUded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<dZded<eeddd d5dZd6dZ d7dZ d8dZ ddd9dZ d:d Z d;d!Z dd dd$Zd?d%Z d@d&ZedAd'ZedBd(ZedCd)ZedDd*ZedEd+Z dFd,ZedGd-ZedHd.Zej8dId/ZdJd0ZdKdLd1Z dK dMd2ZdNd3Z dGd4Z!y)O BaseClientrrrx_versionr _base_urlint max_retrieszUnion[float, Timeout, None]timeout httpx.Limits_limitsProxiesTypes | None_proxies!Transport | AsyncTransport | None _transportr_strict_response_validation str | None_idempotency_headerNztype[_DefaultStreamT] | None_default_stream_cls)rrcustom_headers custom_queryc ||_|jt||_||_||_||_||_||_| xsi|_ | xsi|_ ||_ d|_ d|_ | tdy)Nzmax_retries cannot be None. If you want to disable retries, pass `0`; if you want unlimited retries, pass `math.inf` or a very high number; if you want the default behavior, pass `anthropic.DEFAULT_MAX_RETRIES`)r_enforce_trailing_slashrrrrrrr_custom_headers _custom_queryrr _platform TypeError) rgversionbase_urlrrrlimits transportproxiesrrs rhrizBaseClient.__init__Vs  55c(mD&   #-3)/R+F(#' *.  e  rkcz|jjdr|S|j|jdzS)N/raw_path)rendswithrrfs rhrz"BaseClient._enforce_trailing_slashvs3 <<  &J}}cllT&9}::rkcJ|jr|jsd}d|j}nD|jj }|} t j |}d|jd|}|j|||S#t$r|xsd|j}Y2wxYw)Nz Error code: z - )bodyresponse) is_closedis_stream_consumed status_codetextstripjsonloads Exception_make_status_error)rgrrerr_msgerr_texts rh _make_status_error_from_responsez+BaseClient._make_status_error_from_response{s   h&A&AD$X%9%9$:;G}}**,HD Lzz(+()=)=(>c$H&&wTH&MM L"K X5I5I4J&K Ls'BB"!B"ctrd)NotImplementedError)rgrrrs rhrzBaseClient._make_status_errors "##rkr retries_takencr|jxsi}t|j|}|j||t j |}|j }|rB|jjdk7r%||vr!|jxs|j||<dd|Dvrt||d<|S)Ngetzx-stainless-retry-countc3<K|]}|jywrd)lower).0headers rh z,BaseClient._build_headers..s,YV\\^,Ys) headers_merge_mappingsdefault_headers_validate_headersrr%rmethodr idempotency_key_idempotency_keyrx)rgrrr headers_dictr idempotency_headers rh_build_headerszBaseClient._build_headerss .B&t';';^L  |^<-- -!55 '.."6"6"8E"AFX`gFg*1*A*A*\TEZEZE\G& ' %,Y.,Y Y14]1CG- .rkct|}|jrN|jj|jj dz}|jj |S|S)z Merge a URL argument together with any 'base_url' on the client, to create the URL used for the outgoing request. rr)ris_relative_urlrrlstripr)rgr` merge_urlmerge_raw_paths rh _prepare_urlzBaseClient._prepare_urlsZ H  $ $!]]33i6H6H6O6OPT6UUN==**N*C CrkctSrd)rKrss rh_make_sse_decoderzBaseClient._make_sse_decoders |rkctjtjr!tj dt |di}|j }|jW|tt|j}n:t|rt||j}ntdt|d|j||}t|j|j }|j#d}|j$}|y|j'drhd |vr|j)d|r7t+|st-d t|d |j/||d <|stt0t3}|j5|j6} d | j8vr!d| j8j;d di|d<|j<j>d|tA|jBtDr |jBn |jB|jF| |r6|jHjKttLtNtPf|nd||d|S)NzRequest options: %sT) exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body`r Content-Typezmultipart/form-databoundaryzGExpected query input to be a dictionary for multipart requests but got z instead.data_ sni_hostname- extensions)r rrr`rbrfilesre))rS isEnabledForloggingDEBUGdebugr: json_data extra_jsonrr"r8rrtyper default_queryrbrr( startswithpopr3r_serialize_multipartformr1ForceMultipartDictrr`hostreplacer build_requestrrr'rqs stringifyr rxr) rgrrkwargsr-r rb content_typer( prepared_urls rh_build_requestzBaseClient._build_requests%   GMM * II+Zt-T U!#%%    )  w'9'9: I&+Iw7I7IJ "%@i@QQq#rss%%g]%K !3!3W^^D{{>2    # (?(?@U(V- N+y)#abfgpbqarr{|"&!>!>y!Iv.0B0DE((5 ,## #$2L4E4E4M4McSV4W#XF< *t||))  $.w$IDLLw>> JP477$$T'#s(*;V%DEUY    rkc|jj|d}i}|D]B\}}|j|}|s|||<t|r|j |<||g||<D|S)Nbrackets) array_format)r8stringify_itemsrr4append)rgr#r serializedkeyvalueexistings rhr3z#BaseClient._serialize_multipartforms'' # (  )+  4JC!~~c*H"' 3x &#+U"3 3% 4(rkct|js|St|j}|jtt }t|r||_t tt|S|Srd) r6r rr2rHr!rr r()rgcast_torr override_cast_tos rh_maybe_override_cast_toz"BaseClient._maybe_override_cast_to&s^(Nw' #;;'> J $ %%GOY)9: :rkcF|jjtdk(S)Nstream)r rrGrgrs rh_should_stream_response_bodyz'BaseClient._should_stream_response_body7s""#678CCrkc|ttdS|turtt|S tj|r1t |t r!tt|j||S|jrttt||Sttt||S#tj$r}t|||d}~wwxYw)N)rr#)type_rE)rr)rr(objectinspectisclass issubclassr2buildrr=r>rValidationErrorrQ)rgr#rHrerrs rh_process_response_dataz!BaseClient._process_response_data:s < 4( ( f  4( ( Tw'Jw@T,UIw}}hT}'RSS//I}7$'OPP >t#LM M'' T,hTJPS S Ts$AB42&B4B44CCCctSrdrrss rhr8z BaseClient.qsRs }rkcyrdrerss rh custom_authzBaseClient.custom_authVsrkciSrdrerss rh auth_headerszBaseClient.auth_headersZs rkcrdd|jd|j|j|jS)Nzapplication/json)Acceptr!z User-Agent) user_agentplatform_headersr]rrss rhrzBaseClient.default_headers^sN).// ##%    ""   rkci|jSrd)rrss rhr0zBaseClient.default_queryis     rkcy)zaValidate the given default headers and custom headers. Does nothing by default. Nre)rgr rs rhrzBaseClient._validate_headersos rkcL|jjd|jS)Nz/Python )rqrrrrss rhr`zBaseClient.user_agentzs"..))*(4==/BBrkc|jSrd)rrss rhrzBaseClient.base_url~s ~~rkcz|jt|tr ||_yt||_yrd)rrrrrfs rhrzBaseClient.base_urls-55ZS=Qc`WZ[^W_`rkcDt|j|jS)N)platform)rarrrss rhrazBaseClient.platform_headerss  GGrkc|y |jdd}t|dz S#ttf$rYnwxYw|jd} t|S#ttf$rYnwxYwtj j |}|ytj j|}t|tjz S)a@Returns a float of the number of seconds (not milliseconds) to wait after retrying, or None if unspecified. About the Retry-After header: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Retry-After See also https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Retry-After#syntax Nzretry-after-msz retry-after) rfloatrremailutils parsedate_tz mktime_tztime)rgresponse_headersretry_ms_header retry_headerretry_date_tuple retry_dates rh_parse_retry_after_headerz$BaseClient._parse_retry_after_headers  # .223CTJO)D0 0:&   (++M:  & &:&   !;;33LA  #[[**+;< Z$))+-..s%77 AA)(A)c|j|j}|j|}|d|cxkrdkr|St||z d}ttt d|zt }ddtzz }||z} | dk\r| SdS)Nr<rjg@rg?)get_max_retriesrrvminrFpowrDr) rgremaining_retriesrrqr retry_after nb_retries sleep_secondsjitterrs rh_calculate_retry_timeoutz#BaseClient._calculate_retry_timeouts --d.>.>? 445EF  "q;'<"'< (='88$? /#c:2FFX TFH_$&(!Q,w-A-rkcP|jjd}|dk(rtjdy|dk(rtjdy|jdk(r!tjd |jy|jd k(r!tjd |jy|jd k(r!tjd |jy|jd k\r!tjd |jytjd y)Nzx-should-retrytruez4Retrying as header `x-should-retry` is set to `true`Tfalsez9Not retrying as header `x-should-retry` is set to `false`FizRetrying due to status code %iiiiz Not retrying)r rrSr,r)rgrshould_retry_headers rh _should_retryzBaseClient._should_retrys&..223CD & ( IIL M ' ) IIQ R   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M .!rkc0dtjS)Nzstainless-python-retry-)uuiduuid4rss rhrzBaseClient._idempotency_keys(77rk)rrxr str | URLrrrrrzfloat | Timeout | NonerrrrrrrMapping[str, str] | NonerMapping[str, object] | Nonerurv)r`rrur)rhttpx.ResponserurN)rrxrrQrrruz_exceptions.APIStatusError)rr<rrruz httpx.Headers)r`rxrur)ruzSSEDecoder | SSEBytesDecoder)rr<rrru httpx.Request)r#zMapping[object, object]rudict[str, object])rHtype[ResponseT]rr<rur)rrrur)r#rQrHrrrrur()rur)ruzhttpx.Auth | None)ruzdict[str, str])ruzdict[str, str | Omit])rur)r r%rr%rurvrw)rur)r`z URL | strrurv)ruDict[str, str]rd)rqOptional[httpx.Headers]ruz float | None)r|rrr<rqrrurk)rrrur)"rrryrzr|rrErCrirrrrrrr=r3rJrNrXpropertyr8r[r]rr0rr`rsetterrarvrrrrerkrhrrIs MN (( !!11!%%##8<5</*94848  &*   (5%12 @; N N N,$$ $ ! $ $ $TU&  I $I  I  I V<"DTT! T ! T  T0         CC__aaH /L59 ..%.2 .  .0!F8rkrc eZdZdfd ZxZS)_DefaultHttpxClientc |jdt|jdt|jddt|di|yNrrfollow_redirectsTre setdefaultrCrIsuperrirgr:rqs rhriz_DefaultHttpxClient.__init__E)_5($=>,d3 "6"rkr:rrurvrrryrzri __classcell__rqs@rhrr ##rkrceZdZddZy)SyncHttpxClientWrappercD |jy#t$rYywxYwrd)closerrss rh__del__zSyncHttpxClientWrapper.__del__s"  JJL   s  Nrurvrrryrzrrerkrhrrsrkrc 4eZdZUded<dZded<eeddddddd d3fdZd4dZd5d Z d6d Z d7d Z d8d Z d9d Z e d: d;dZe d:dd ddZ d?dZ d@dZdd dAdZ dBdZeidd dCdZeid dDdZeidd dEd Ziddd! dEd"Zediddd# dFd$Zedidd% dGd&Zediddd' dHd(Zdidddd) dHd*Zdid+ dId,Zddid- dJd.Zdid+ dId/Zdid0d1 dKd2ZxZS)Lrz httpx.ClientrNztype[Stream[Any]] | Nonerrrrrr http_clientrrc i} |)tjdtd|tdt}|.|| d<tjdtd| td|.|| d<tjd td| td t |s(|r |j tk7r |j }nt}|1t|tjstd t|t |=||t!t"|||||| | | |xst%d|t!t"||d d| |_y)NhThe `connection_pool_limits` argument is deprecated. The `http_client` argument should be passed insteadcategory stacklevelNThe `http_client` argument is mutually exclusive with `connection_pool_limits`r[The `transport` argument is deprecated. The `http_client` argument should be passed insteadAThe `http_client` argument is mutually exclusive with `transport`rYThe `proxies` argument is deprecated. The `http_client` argument should be passed instead?The `http_client` argument is mutually exclusive with `proxies`zOInvalid `http_client` argument; Expected an instance of `httpx.Client` but got ) rrrrrrrrrrTrrrrre)warningswarnDeprecationWarningrrIr6rHTTPX_DEFAULT_TIMEOUTrCrrClientrr/rrirr&rr)rgrrrrrrrrrrrr:rqs rhrizSyncAPIClient.__init__ s~"$   MMz+  & !qrr.F  "+F;  MMm+  & !dee   'F9  MMk+  & !bcc {226KK%--)  ":k5<<+Pabfgrbsatu  '*#%)(C  # &<' '*! '  '  rkc.|jjSrdrrrss rhrzSyncAPIClient.is_closedd||%%%rkcRt|dr|jjyy)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrss rhrzSyncAPIClient.closegs# 4 # LL    $rkc|Srdrerss rh __enter__zSyncAPIClient.__enter__qs rkc$|jyrdrrgexc_typeexcexc_tbs rh__exit__zSyncAPIClient.__exit__ts rkc|Sz#Hook for mutating the given optionsrergrs rh_prepare_optionszSyncAPIClient._prepare_options|s rkcyaThis method is used as a callback for mutating the `Request` object after it has been constructed. This is useful for cases where you want to add certain headers based off of the request properties, e.g. `url`, `method` etc. NrerMs rh_prepare_requestzSyncAPIClient._prepare_requestsrkcyrdrergrHrr|rL stream_clss rhrzSyncAPIClient.requestrkFrLcyrdre)rgrHrr|rLs rhrzSyncAPIClient.requestrkrLrcyrdrers rhrzSyncAPIClient.request #rkct||j|j|z }nd}|j|||||SNr)rHrrLrrryr_request)rgrHrr|rLrrs rhrzSyncAPIClient.requestsP  (#33D4D4DEHYYMM}}!'   rkc t|}|j||}|j|}|j|j|z }|j ||}|j |i} |j|j| d<tjd|j|j |jj|fd|xs|j|i| } tjd|j|j| j*| j,| j.tjd| j.j1d | j3|jC||| |||S#tj $r_} tjdd|d kDr|j#|||||d cYd} ~ Stjd t%|| d} ~ wt&$r_} tjd d|d kDr|j#|||||d cYd} ~ Stjd t)|| d} ~ wwxYw#tj4$r} tjdd|d kDre|j7| j8rJ| j8j;|j#|||| j8j.||cYd} ~ S| j8j<s| j8j?tjd|jA| j8dd} ~ wwxYw)NrauthzSending HTTP Request: %s %srLr"Encountered httpx.TimeoutExceptionTexc_inforrrLrrqRaising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz request-id!Encountered httpx.HTTPStatusErrorrrqrLrRe-raising status errorrHrrrLrr)"r9rJrryrr=rr[rSr,rr`rsendrNrTimeoutException_retry_requestrOrrPr reason_phraser rraise_for_statusHTTPStatusErrorrrrrreadr_process_response) rgrHrrrLr input_optionsr|rr:rrWs rhrzSyncAPIClient._requests0#7+ ..w@''0#33D4D4DE U%%g]%K g& "    '!--F6N /M# ?(t||((S!B!B7!B!SHH - NN KK   " "      "H$4$4$8$8$FG P  % % '.%%!' &  C%% < II:TI J 1$**!"/!)%) + II- .!'2 ; ? II-I = 1$**!"/!)%) + II0 1$W53 > ?8$$ P II9DI I 1$););CLL)I ""$**!"/%(\\%9%9!) +<<)) !!# II/ 077 E4 O) Psb:3F)I+I(#2G=I("G== I( 2I#;I("I##I(+M%>A;M 9M%?A!M  M%cd|j|j|z }|dk(rtjdntjd||j |||}tj d|j |tj||j|||dz||SNrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rrHrrLr) ryrrSr,rrr`rpsleepr rgrrHrrqrLrr|rs rhrzSyncAPIClient._retry_request/s$33D4D4DE U  ! IIn % II'): ;//0A7L\] 7gN 7}}'!+!   rkrrc |jjjtdk(r t t t |||||||St|xs|}tj|rgt|trWt|tstdtd|t d|}t t |||t|||||S|tj k(rt t |St||t d|||||} t#|jjjtrt t | S| j%S)NrrawrrHrLrrr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r)rr rrGrr(rRrrRrSrTr@r?rrBrResponserparse rgrHrrrLrrorigin response_cls api_responses rhrzSyncAPIClient._process_responseNs\    # # ' '(; < F! #!)#"/  G$/ ??6 "z&/'Jfk2"CK=P[\b[c dee ._parsers&  ( ( )  KrkFr)rrTrurT)rr)rgrrrrs`` ` rhrzSyncAPIClient._request_api_lists'  &||D'%|88rkrrLcyrdrergpathrHrrLs rhrzSyncAPIClient.getrrkrcyrdrergrrHrrLrs rhrzSyncAPIClient.getrrkrrcyrdrers rhrzSyncAPIClient.getrrkrrLrc xtjdd|d|}tt|j ||||SNr)rr`rre)r< constructrr(rrgrrHrrLroptss rhrzSyncAPIClient.gets?#,,OEtOwOIt||GT&U_|`aark)rrr(rLcyrdre)rgrrHrrr(rLs rhpostzSyncAPIClient.postsrk)rrr(cyrdrergrrHrrr(rLrs rhrzSyncAPIClient.postsrk)rrr(rcyrdrers rhrzSyncAPIClient.posts #rk)rrr(rLrc tjdd||t|d|}tt|j ||||SNrrr`r-r(rre)r<rrrr(r) rgrrHrrr(rLrrs rhrzSyncAPIClient.postsP#,, tt>%;P T[ It||GT&U_|`aarkrrcXtjdd||d|}|j||SNpatchrr`r-rer<rrrgrrHrrrs rhr&zSyncAPIClient.patchs3#,,aGQUaY`a||GT**rkrr(rc ltjdd||t|d|}|j||SNputr"re)r<rrrrgrrHrr(rrs rhr-zSyncAPIClient.put sB#,, dd.:O SZ ||GT**rkcXtjdd||d|}|j||SNdeleter'rer(r)s rhr1zSyncAPIClient.deletes3#,,bH$RVbZab||GT**rkrrrrcZtjd|||d|}|j|||SNr'rer<rrrgrrrrrrrs rh get_api_listzSyncAPIClient.get_api_list%7#,,`FPT`X_`%%eT488rk)rrxrrrrr!float | Timeout | None | NotGivenrzTransport | Nonerrr Limits | Nonerzhttpx.Client | NonerrrrrrrurvrrrgrWrurWrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonerurvrr<rur<rrrurvrd) rHType[ResponseT]rr<r| Optional[int]rL Literal[True]rzType[_StreamT]rurZ) rHr?rr<r|r@rLLiteral[False]rur() rHr?rr<r|r@rLrrzType[_StreamT] | NoneruResponseT | _StreamT) rHr?rr<r|r@rLrrtype[_StreamT] | NonerurC) rHr?rr<rrrLrrrDrurC)rr<rHr?rrrqhttpx.Headers | NonerLrrrDrurCrHr?rr<rrrLrrz1type[Stream[Any]] | type[AsyncStream[Any]] | Nonerrrur()r Type[object]rType[SyncPageT]rr<rurT rrxrHr?rr0rLrBrur() rrxrHr?rr0rLrArtype[_StreamT]rurZ) rrxrHr?rr0rLrrrDrurC)rrxrHr?r Body | Nonerr0r(RequestFiles | NonerLrBrur()rrxrHr?rrKrr0r(rLrLrArrJrurZ)rrxrHr?rrKrr0r(rLrLrrrDrurC rrxrHr?rrKrr0rur( rrxrHr?rrKr(rLrr0rur()rrxrrGrrHrrKrr0rrxrurT)rrryrzr|rrEr!rirrrrrrrrrrrrrrr&r-r1r7rrs@rhrr s 4818/5>&*'+ $+/3748U U  U  U 3 U $U %U U )U 1U 2U &*U  U n&!,"%   $      ,0  %)   #  ,0  "'  %)     ,0 # ,0# #%#) #  #*# ##,0  ,0   % )    *   ,i !i % i  i  i *i  i V $ !   /   *   N;$!;$% ;$ ! ;$  ;$F;$;$ ;$z999% 9  9$ #%!& !       #% !     #  #%,0##! #  #  #*# ###%,0 b b! b  b  b* b  b !"$%)!&  !     #      !"$%)  !     #  #     !"$%),0 # #! #  #  ## # #* #  # #"!"$%),0bb! b  b  b#bb*b b*!"$ + +! +  +  +  + !%)"$ + +! +  + # +  +  +&!"$ + +! +  +  +  +"!"$ 9 9 9  9  9  9 9  9rkrc eZdZdfd ZxZS)_DefaultAsyncHttpxClientc |jdt|jdt|jddt|di|yrrrs rhriz!_DefaultAsyncHttpxClient.__init__4rrkrrrs@rhrPrP3rrkrPceZdZddZy)AsyncHttpxClientWrapperc tjj|jy#t$rYywxYwrd)asyncioget_running_loop create_taskacloserrss rhrzAsyncHttpxClientWrapper.__del__Hs6   $ $ & 2 24;;= A   s14 AANrrrerkrhrSrSGsrkrSc .eZdZUded<dZded<eeddddddd d4fdZd5dZd6d Z d7d Z d8d Z d9d Z d:d Z eddd d;dZedd ddZ d?dZdd d@dZ dAdZeidd dBdZeid dCd Zeidd! dDd"Ziddd# dDd$Zeddidd% dEd&Zeddid' dFd(Zeddidd) dGd*Zddiddd+ dGd,Zdid- dHd.Zddid' dId/Zdid- dHd0Zdid1d2 dJd3ZxZS)Krzhttpx.AsyncClientrNztype[AsyncStream[Any]] | Nonerrc i} |)tjdtd| tdt}|.|| d<tjdtd| td|.|| d<tjd td| td t |s(| r | j tk7r | j }nt}| 1t| tjstd t| t |=|||t!t"||||| | | | xst%d|t!t"||d d| |_y)NrrrrrrrrrrzTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got ) rrrrrrrrrrTrre)rrrrrIr6rrrCrr AsyncClientrr/rrirr&rSr)rgrrrrrrrrrrrr:rqs rhrizAsyncAPIClient.__init__Ts"$   MMz+  & !qrr.F  "+F;  MMm+  & !dee   'F9  MMk+  & !bcc {226KK%--)  ":k5CTCT+Ufgklwgxfyz  '*#%)(C  # &=' '*! '  '  rkc.|jjSrdrrss rhrzAsyncAPIClient.is_closedrrkcTK|jjd{y7w)rN)rrXrss rhrzAsyncAPIClient.closes ll!!###s (&(cK|Swrdrerss rh __aenter__zAsyncAPIClient.__aenter__s  c@K|jd{y7wrdrrs rh __aexit__zAsyncAPIClient.__aexit__s jjls cK|Swrrers rhrzAsyncAPIClient._prepare_optionss r`c KywrrerMs rhrzAsyncAPIClient._prepare_requests F)rLr|c Kywrdre)rgrHrrLr|s rhrzAsyncAPIClient.request re)r|c KywrdrergrHrrLrr|s rhrzAsyncAPIClient.request re)rr|c Kywrdreris rhrzAsyncAPIClient.request %(re)rLrr|cK||j|j|z }nd}|j|||||d{S7wrr)rgrHrrLrr|rs rhrzAsyncAPIClient.requests^  (#33D4D4DEHYYMM]]!' #    s=AAAc K|j!ttd{|_t|}|j ||}|j |d{}|j |j|z }|j||}|j|d{i} |j|j| d< |jj|fd|xs|j|i| d{} t j#d |j,|j.| j0| j2 | j5|jG||| |||d{S7T777}#tj$rh} t j#dd|dkDr%|j%|||||d d{7cYd} ~ St j#d t'|| d} ~ wt($rh} t j#d d|dkDr%|j%|||||d d{7cYd} ~ St j#d t+|| d} ~ wwxYw#tj6$r} t j#dd|dkDrw|j9| j:r\| j:j=d{7|j%|||| j:j>||d{7cYd} ~ S| j:j@s#| j:jCd{7t j#d|jE| j:dd} ~ wwxYw7w)NrrrLrrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)$rr5 get_platformr9rJrryrr=rr[rrrNrrrSr,rrOrrPrr`rrrrrrrXr rareadrr) rgrHrrLrrrr|rr:rrWs rhrzAsyncAPIClient._requestsh >> !$:8L#9#;;DN #7+ ..w@--g66#33D4D4DE U%%g]%K##G,,, "    '!--F6N# ?.T\\..S!B!B7!B!SHH )7>>7;;H\H\^f^t^t  P  % % '.++!' ,   g<7 - %% < II:TI J 1$!00!"/!)%) 1 II- .!'2 ; ? II-I = 1$!00!"/!)%) 1 II0 1$W53 > ?,$$ P II9DI I 1$););CLL)Ill))+++!00!"/%(\\%9%9!) 1<<))ll((*** II/ 077 E4 O) P, s$N E::N !E="A N +F,!N 6FFF AN  I1N 5N 6N =N N FI.6G: GG:I.N "G:: I.6I)<H?=I)I.N "I))I..N 1NANK3N LNNN 3N M 6NNN cK|j|j|z }|dk(rtjdntjd||j |||}tj d|j |tj|d{|j|||dz||d{S7%7wr) ryrrSr,rrr`anyiorrrs rhrzAsyncAPIClient._retry_requestps$33D4D4DE U  ! IIn % II'): ;//0A7L\] 7gNkk'"""]]'!+! #    # s$BCC C?CCCrrc K|jjjtdk(r t t t |||||||St|xs|}tj|rct|trSt|tstdtd|t d|}t d|||t|||||S|tj k(rt t |St||t d|||||} t#|jjjtrt t | S| j%d{S7w)Nrrrrrr(r)rr rrGrr(rRrrRrSrTr@rArrBrrrrrs rhrz AsyncAPIClient._process_responsesi    # # ' '(; < F! #!)#"/  G$/ ??6 "z&/'Jf&67"CDTCUU`ag`h ijj ) rHr?rr<rLrBr|r@rur() rHr?rr<rLrArtype[_AsyncStreamT]r|r@rur[) rHr?rr<rLrrtype[_AsyncStreamT] | Noner|r@ruResponseT | _AsyncStreamT) rHr?rr<rLrrrrrrur)rr<rHr?rrrqrErLrrrrurrF)rrrrrr<ruAsyncPaginator[_T, AsyncPageT]rI) rrxrHr?rr0rLrArrrur[) rrxrHr?rr0rLrrrrur)rrxrHr?rrKr(rLrr0rLrBrur()rrxrHr?rrKr(rLrr0rLrArrrur[)rrxrHr?rrKr(rLrr0rLrrrrurrMrN)rrxrrrrrrKrr0rrxrur)rrryrzr|rrEr!rirrr_rbrrrrrrrrrrr&r-r1r7rrs@rhrrPs 9=6=/5>+/'+ $043748U U  U &* U  U 3U )U %U U .U 1U 2U  U n&$,"%   $      "'+/  %   )  ,0 %   ( ) 26+/( (%(  ( / ()( #((15+/   %   /  )  # ,f  f %f  f / f f  #f P $ !   /   /  # J;*!;*% ;* ! ;*  ;*F;*;* ;*zXXX% X ( X #%!& !       #% !     (  #%15((! (  (  (/( #((#%15 W W! W  W  W/ W # W !%)"$!&  !    #        !%)"$  !    #    (     !%)"$15 ( (! (  ( # (  ( (/ ( # ( ("!%)"$15WW! W  W # W WW/W #W*!"$ 1 1! 1  1  1  1 !%)"$ 1 1! 1  1 # 1  1  1&!"$ 1 1! 1  1  1  1"!"$ 9 9 9  9  9  9 9 ( 9rkr)query extra_headers extra_query extra_bodyrrrci}|||d<|tt||d<|||d<|i|jdi||d<t|ts||d<|||d<t |r||d<|S)zECreate a dict of type RequestOptions without keys of NotGiven values.r r.rbrrr)rr*rrr'r6)rrrrrrrrs rhmake_request_optionsrfs!G *  $Z <  !Hw{{8R8HKH gx ($ "%4!" !,  NrkceZdZddZy)r4cy)NTrerss rh__bool__zForceMultipartDict.__bool__srkNr)rrryrzrrerkrhr4r4srkr4c&eZdZddZeddZy) OtherPlatformc||_yrdnamergrs rhrizOtherPlatform.__init__  rkc d|jS)NzOther:rrss rh__str__zOtherPlatform.__str__ {##rkNrrxrurvrwrrryrzrirrrerkrhrr$$rkr)MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknowncF tjj}tjj}d|vsd|vry|dk(ry|dk(ryd |vry |d k(r!t j }|d k(ry |dk(ryy|r t |Sy#t$rYywxYw)Nriphoneipadrdarwinrwindowsrandroidrlinuxfreebsdropenbsdrr)rhsystemr rdistroidr)r platform_name distro_ids rhroros"((* ))+113 = Fm$;   M! IIK  !  !]++ G sAB B B )maxsizecd|t|xs ttttt dS)Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)rxroget_architectureget_python_runtimeget_python_version)rrhs rhraras;%'.h8,.9 0 2313'9';  rkc&eZdZddZeddZy) OtherArchc||_yrdrrs rhrizOtherArch.__init__rrkc d|jS)Nzother:rrss rhrzOtherArch.__str__rrkNrrwrrerkrhrrrrkr)x32x64armarm64unknowncJ tjS#t$rYywxYwNr)rhpython_implementationrrerkrhrrs(--//   ""cJ tjS#t$rYywxYwr)rhpython_versionrrerkrhrrs(&&(( rc tjj}|dvry|dk(ry|dk(rytj dkry|r t |Sy#t$rYywxYw) Nr)raarch64rrx86_64rlr)rhmachiner rsysrr)rs rhrrsz""$**,&&%( {{e!! ) s"A A#"A#ci||}|jDcic]\}}t|tr||c}}Scc}}w)zMerge two mappings of the same type, removing any values that are instances of `Omit`. In cases with duplicate keys the second mapping takes precedence. )rrr#)obj1obj2mergedrDrEs rhrrs?  F)/ W:3z%QU?VCJ WW Ws<<)r Query | NonerzHeaders | NonerrrrKrrrz'float | httpx.Timeout | None | NotGivenrzPostParser | NotGivenrur0)ruPlatform)rrxrhzPlatform | Nonerurrw)ruArch)rMapping[_T_co, Union[_T, Omit]]rrruzDict[_T_co, _T]) __future__rrrrprrlrUrRr*rhr email.utilstypesrrtypingrrrr r r r r rrrrrrrtyping_extensionsrrrrrrrrrrrr_qsr_filesrr _typesr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2_utilsr3r4r5r6r7r8_compatr9r:_modelsr;r<r=r> _responser?r@rArB _constantsrCrDrErFrGrHrI _streamingrJrKrLrMrNrOrPrQ_legacy_responserR getLoggerrrrSr|rTrVrWrXrZr[ httpx._configr\r ImportErrorr^r~rrrrr[rrrrDefaultHttpxClientrrrPDefaultAsyncHttpxClientrSrrrxr4rrrorarrrrrrrerkrhrs" "<;  8(PO+UU IH 0'g''1^1 K': ; \)= >  T]4( :VC[ 1{3/?@ M-Q $B$BN-6|WR[-6`+a8B<+a\$WR^,$N#gHRL'"+#gLuU\\5CTCT5T/UV +5kRUFV9V3WXa878a8H #%,,#-/g9Ju||VC[89g9T#u00##//75S9Z 1 1;s3C CDS9p$( $""&7@)2" """ "  "  "5"'""Jc4i $$      'T 4$$ Y GH HI4 X ) X ) X XI= - ' -sM MM