L ibUddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Zddl mZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!ddl"m#Z#m$Z$m%Z%ddl&Z&ddl'Z'ddl(Z(ddl)Z)ddl'm*Z*m+Z+m,Z,m-Z-ddl)m.Z.d d l/m0Z0d d l1m2Z2d d l3m4Z4m5Z5d d l6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEd dlFmGZGmHZHmIZImJZJmKZKmLZLd dlMmNZNmOZOmPZPd dlQmRZRmSZSmTZTmUZUd dlVmWZWmXZXmYZYmZZZd dl[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbd dlcmdZdmeZemfZfmgZgd dl0mhZhmiZimjZjmkZkd dllmmZmd dlnmoZoe jeqZrdesd<eddZteddZuedZvedd !Zwed"edeZxed#efeZyer dd$lzm{Z{e{Z|n dd$lzm{Z|Gd&d'Z~Gd(d)eReevZGd*d+eeveevZGd,d-eeveufZGd.d/eeveevZed0ee'je'jfZed1eedeefefZGd2d3eeefZGd4d5e'jZere'jZneZGd6d7eZGd8d9ee'jedefZGd:d;e'jZ ddlZGd<d=ejZere'jZ e'jZneZeZGd?d@eZGdAdBee'jefefZdddddeEeEdC dTdDZGdEdFeedfZGdGdHZeee#dIfZdUdJZeKdKdVdLZGdMdNZeee#dOfZdWdPZdWdQZdXdRZ dYdSZy#e}$r e;d%Z|YwxYw#e}$rGd>d=e'jZYwxYw)Z) annotationsN) TracebackType)random) TYPE_CHECKINGAnyDictListTypeTupleUnionGenericMappingTypeVarIterableIteratorOptional Generator AsyncIteratorcastoverload)Literaloverride get_origin)URLProxy HTTPTransportAsyncHTTPTransport) PrivateAttr) _exceptions Querystring)to_httpx_filesasync_to_httpx_files)BodyOmitQueryHeadersTimeoutNotGiven ResponseT AnyMapping PostParser RequestFiles HttpxSendArgsRequestOptionsHttpxRequestFilesModelBuilderProtocol not_given)is_dictis_listasyncifyis_given lru_cache is_mapping) PYDANTIC_V1 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)get_environment_proxies)LegacyAPIResponsezlogging.Loggerlog SyncPageTzBaseSyncPage[Any])bound AsyncPageTzBaseAsyncPage[Any]_T_T_coT) covariant_StreamT _AsyncStreamT)DEFAULT_TIMEOUT_CONFIG@ceZdZUdZded<ded<ded<e ddZe dd Ze dd Zeeed  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 | NotGivenparamsBody | NotGivenjsoncyNselfrds \/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/anthropic/_base_client.py__init__zPageInfo.__init__ cyrjrk)rmrfs rnrozPageInfo.__init__rprqcyrjrk)rmrhs rnrozPageInfo.__init__rprqrdrhrfc.||_||_||_yrjrt)rmrdrhrfs rnrozPageInfo.__init__s  rqc|jr&|jjd|jdS|jr&|jjd|jdS|jjd|jdS)Nz(url=)z(json=z(params=)rd __class____name__rhrfrms rn__repr__zPageInfo.__repr__sv 88nn--.eDHH:Q? ? 99nn--.fTYYKqA A..))*(4;;-qAArqN)rdrreturnNone)rfr'r|r})rhr%r|r})rdrcrhrgrfrer|r}r|str) ry __module__ __qualname____doc____annotations__rror3rr{rkrqrnrbrbws            ( )#,    !   BBrqrbcjeZdZUdZeZded<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)rmitemss rn has_next_pagezBasePage.has_next_pages*$$&""$D00rqcyrjrkrzs rnrzBasePage.next_page_infosrqcyrjrkrzs rnrzBasePage._get_page_itemss rqctjtt|jj j |j Srj)httpx QueryParamsrrrrfmergerls rn_params_from_urlzBasePage._params_from_urls3  c4==+?+?!@AGG SSrqc t|j}|jt|jt s!i|j|j|_|St|j t sc|j|j }|j j|}t|j|_t||_|St|jt st|js td|jsi|j|_|St|js tdi|j|j|_|Std)N)rfz*Pagination is only supported with mappingszUnexpected PageInfo state)r;r_strip_raw_response_header isinstancerfr*rdr copy_withdictrrhr9 TypeError json_data ValueError)rminfooptionsrfrds rn_info_to_optionszBasePage._info_to_optionss0T]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN$))X.dii( LMM$$$1tyyM! N "'"3"34#$PQQ$Fw'8'8$FDII$F!N455rqNr|bool)r|zOptional[PageInfo])r|z Iterable[_T])rdrr|zhttpx.QueryParams)rrbr|r>) ryrrrrrrrrrrrrrkrqrnrrs< %0MH!1"}FH$1 8 T6rqrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseSyncPage SyncAPIClient_clientcbtst|ddi|_||_||_||_yN__pydantic_private__r:getattrrrrr)rmclientmodelrs rn_set_private_attributesz$BaseSyncPage._set_private_attributes3 /Et!L!T(*D %   rqc#hK|jD]}|jD]}|ywrj iter_pagesrrmpageitems rn__iter__zBaseSyncPage.__iter__s9OO% D,,.    s02c#^K|} ||jr|j}ny'wrjr get_next_pagermrs rnrzBaseSyncPage.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_listrrxrmrrs rnrzBaseSyncPage.get_next_page sZ""$k ''-||--dkkX_-``rqN)rrrrrr>r|r})r|z Iterator[_T])rmrWr|zIterator[SyncPageT])rmrWr|rW) ryrrpydanticrrrrrrrrkrqrnrrsR1X113G]3      %    * arqrc@eZdZ ddZddZddZd dZy) AsyncPaginatorc<||_||_||_||_yrj)rrr _page_cls)rmrrpage_clsrs rnrozAsyncPaginator.__init__s    !rqc>|jjSrj) _get_page __await__rzs rnrzAsyncPaginator.__await__%s~~))++rqcKdfd }|j_jjjjd{S7w)Ncl|jjjj|S)N)rrr)rrrr)resprms rn_parserz)AsyncPaginator._get_page.._parser)s2  ( (kk || )  Krq)rrYr|rY)r post_parserrrequestr)rmrs` rnrzAsyncPaginator._get_page(s? %, !\\))$..$--HHHHsA AAAchKtt|d{}|23d{}|77 6ywrj)rrYrs rn __aiter__zAsyncPaginator.__aiter__5s< J   $J  $s$2, 20.0202N) rAsyncAPIClientrr>rType[AsyncPageT]rrr|r})r|z Generator[Any, None, AsyncPageT])r|rYr|zAsyncIterator[_T])ryrrrorrrrkrqrnrrsG " "% "# "  "  ", IrqrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseAsyncPagerrcbtst|ddi|_||_||_||_yrr)rmrrrs rnrz%BaseAsyncPage._set_private_attributesBrrqczK|j23d{}|jD]}| $76ywrjrrs rnrzBaseAsyncPage.__aiter__OsB//+  $,,.    +s;979;9;ctK|} ||jr|jd{}ny07wrjrrs rnrzBaseAsyncPage.iter_pagesTs=J!!#!//11 2s ,868cK|j}|s td|j|}|jj |j |j |d{S7wrrrs rnrzBaseAsyncPage.get_next_page]sd""$k ''-\\33DKKdnn^e3ffffsA$A-&A+'A-N)rrrrrr>r|r}r)rmrYr|zAsyncIterator[AsyncPageT])rmrYr|rY) ryrrrrrrrrrrrkrqrnrr?sR2h224G^4      %     grqr _HttpxClientT_DefaultStreamTc&eZdZUded<ded<ded<ded<d ed <d ed <d ed<dZded<eeddd d0dZd1dZ d2dZ d3dZ ddd4dZ d5dZ d6dZ dd d7dZd8dZd9dZd:dZ d;d Zedd#Zed?d$Zed@d%Z dAd&ZedBd'ZedCd(Zej8dDd)ZdEd*ZdFd+ZdGdHd,Z dG dId-Z dJd.Z!dBd/Z"y)K BaseClientrrr_versionr _base_urlint max_retrieszUnion[float, Timeout, None]timeoutr_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_slashrrrr_custom_headers _custom_queryrr _platformr)rmversionbase_urlrrrrrs rnrozBaseClient.__init__vs  55c(mD& -3)/R+F(#' *.  e  rqcz|jjdr|S|j|jdzS)N/raw_path)rendswithrrls rnrz"BaseClient._enforce_trailing_slashs3 <<  &J}}cllT&9}::rqcJ|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_codetextstriprhloads Exception_make_status_error)rmrrerr_msgerr_texts rn _make_status_error_from_responsez+BaseClient._make_status_error_from_responses   h&A&AD$X%9%9$:;G}}**,HD Lzz(+()=)=(>c$H&&wTH&MM L"K X5I5I4J&K Ls'BB"!B"ctrj)NotImplementedError)rmrrrs rnrzBaseClient._make_status_errors "##rqr retries_takenc|jxsi}tdt|jtrt |jj nt |ji|j|}|j||tj|}|j}|r|jr||vr|j||<|Dcgc]}|j}}d|vrt ||d<d|vr^t|jtr |jn |j} t| tr | j } | t | |d<|Scc}w)Nzx-stainless-timeoutzx-stainless-retry-countzx-stainless-read-timeout)headers_merge_mappingsrrr)rreaddefault_headers_validate_headersrr(ridempotency_keylowerr*) rmrrr headers_dictridempotency_headerheaderlower_custom_headersrs rn_build_headerszBaseClient._build_headerssI .B&%goow7(+7??+?+?'@) &&     |^<-- -!55 '"9"9>PX_>_*1*A*AG& '>LL6 LL $,@ @14]1CG- . %-A A&0(&KdllQXQ`Q`G'7+!,,"69'l23 MsEct|}|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)rmrd merge_urlmerge_raw_paths rn _prepare_urlzBaseClient._prepare_urlsZ H  $ $!]]33i6H6H6O6OPT6UUN==**N*C CrqctSrj)rMrzs rn_make_sse_decoderzBaseClient._make_sse_decoders |rqctjtjr!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?dk7} | r.tA|tBr||d<ntE|r|nd|d<||d<n$|j)dd|j)d d|jFjHd|tA|jJtLr |jJn |jJ|j<| |r6|jNjQttRtTtVf|ndd|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- extensionsgetcontentrhfiles)rrmethodrdrfrk),rV isEnabledForloggingDEBUGdebugr<r extra_jsonrr%r9r rtyper default_queryrfr%r' startswithpopr4r_serialize_multipartformr1ForceMultipartDictrrdhostreplacer(rrbytesr7r build_requestrr*qs stringifyrrr) rmrrkwargsrrrf content_typer' prepared_urlis_body_alloweds rn_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< !....0E9 )U+$-y!.6y.Atv#F7O KK - JJvt $*t||))  $.w$IDLLw>> JP477$$T'#s(*;V%DEUY    rqc|jj|d}i}|D]B\}}|j|}|s|||<t|r|j |<||g||<D|S)Nbrackets) array_format)r8stringify_itemsr%r5append)rmr r serializedkeyvalueexistings rnr2z#BaseClient._serialize_multipartform;s'' # (  )+  4JC!~~c*H"' 3x &#+U"3 3% 4(rqct|js|St|j}|jtt }t|r||_t tt|S|Srj) r7rrr1rJr3rr r+)rmcast_torroverride_cast_tos rn_maybe_override_cast_toz"BaseClient._maybe_override_cast_toYs^(Nw' #;;'> J $ %%GOY)9: :rqcF|jjtdk(S)Nstream)rr%rIrmrs rn_should_stream_response_bodyz'BaseClient._should_stream_response_bodyjs""#678CCrqc|ttdS|turtt|S tj|r1t |t r!tt|j||S|jrttt||Sttt||S#tj$r}t|||d}~wwxYw)N)rr )type_rF)rr)rr+objectinspectisclass issubclassr2buildrr?r@rValidationErrorrS)rmr rIrerrs rn_process_response_dataz!BaseClient._process_response_datams < 4( ( f  4( ( Tw'Jw@T,UIw}}hT}'RSS//I}7$'OPP >t#LM M'' T,hTJPS S Ts$AB42&B4B44CCCctSrjr!rzs rnr8z BaseClient.qss }rqcyrjrkrzs rn custom_authzBaseClient.custom_authsrqciSrjrkrzs rn auth_headerszBaseClient.auth_headerss rqcrdd|jd|j|j|jS)Nzapplication/json)Acceptrz User-Agent) user_agentplatform_headersr^rrzs rnr zBaseClient.default_headerssN).// ##%    ""   rqci|jSrj)rrzs rnr/zBaseClient.default_querys     rqcy)zaValidate the given default headers and custom headers. Does nothing by default. Nrk)rmrrs rnr zBaseClient._validate_headerss rqcL|jjd|jS)Nz/Python )rxryrrzs rnrazBaseClient.user_agents"..))*(4==/BBrqc|jSrj)rrzs rnrzBaseClient.base_urls ~~rqcz|jt|tr ||_yt||_yrj)rrrrrls rnrzBaseClient.base_urls-55ZS=Qc`WZ[^W_`rqcDt|j|jS)N)platform)rbrrrzs rnrbzBaseClient.platform_headerss  GGrqcbd}d}||zdz }||kDs|r||kDr tdt|dS)NiiXizStreaming is required for operations that may take longer than 10 minutes. See https://github.com/anthropics/anthropic-sdk-python#long-requests for more detailsr`)connect)rr))rm max_tokensmax_nonstreaming_tokens maximum_time default_time expected_times rn_calculate_nonstreaming_timeoutz*BaseClient._calculate_nonstreaming_timeoutsV  $z1G; < ',C UlHlj    rqc|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) r%floatrremailutils parsedate_tz mktime_tztime)rmresponse_headersretry_ms_header retry_headerretry_date_tuple retry_dates rn_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<rsg@rg?)get_max_retriesrrminrHpowrFr) rmremaining_retriesrrzr retry_after nb_retries sleep_secondsjitterrs rn_calculate_retry_timeoutz#BaseClient._calculate_retry_timeouts --d.>.>? 445EF  "q;'<"'< (='88$? /#c:2FFX TFH_$&(!Q,w-A-rqcP|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)rr%rVr,r)rmrshould_retry_headers rn _should_retryzBaseClient._should_retrys&..223CD & ( IIL M ' ) IIQ R   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M .!rqc0dtjS)Nzstainless-python-retry-)uuiduuid4rzs rn_idempotency_keyzBaseClient._idempotency_key+s(77rq)rrr str | URLrrrrrzfloat | Timeout | NonerMapping[str, str] | NonerMapping[str, object] | Noner|r})rdrr|r)rhttpx.Responser|rP)rrrrRrrr|z_exceptions.APIStatusError)rr>rrr|z httpx.Headers)rdrr|r)r|zSSEDecoder | SSEBytesDecoder)rr>rrr| httpx.Request)r zMapping[object, object]r|dict[str, object])rItype[ResponseT]rr>r|r)rrr|r)r rRrIrrrr|r+)r|r")r|zhttpx.Auth | None)r|zdict[str, str])r|zdict[str, str | Omit])r|r)rr(rr(r|r}r~)r|r)rdz URL | strr|r})r|Dict[str, str])rlrrmz int | Noner|r)rj)rzOptional[httpx.Headers]r|z float | None)rrrr>rzrr|rt)rrr|r)#ryrrrrrGrErorrrrrrr>r2rKrOrYpropertyr8r\r^r r/r rarsetterrbrqrrrrrkrqrnrrls| MN ((!%%##8<5</*93748  &*   (12 4; N N N,$$ $ ! $ $ $TU D  S $S  S  S j<"DTT! T ! T  T0         CC__aaH   /L59 ..%.2 .  .0!F8rqrc eZdZdfd ZxZS)_DefaultHttpxClientc X|jdt|jdt|jddd|vrtjtj dfg}t tdd}|#|jtj|dfnFtjdk(r3t td d }|jtj|dft td d}|"|jtj|d ft td d}|"|jtj|dftjDcic]\}}||dn t|} }}dD cic] } | |vs| || } } || d<| jD cic]\}} || dn tdd| i| } }} tdi| }| j|j!di| |d<||d<t#|Hdi|ycc}}wcc} wcc} }wNrlimitsfollow_redirectsT transport TCP_KEEPINTVLrdarwin TCP_KEEPALIVE TCP_KEEPCNT TCP_KEEPIDLE)rd)verifycert trust_envhttp1http2rsocket_optionsproxymountsrk) setdefaultrErKsocket SOL_SOCKET SO_KEEPALIVErrC IPPROTO_TCPsysrirTrrrupdater%superrormr:rrrrrrErd proxy_mapargtransport_kwargsr proxy_mountsdefault_transportrxs rnroz_DefaultHttpxClient.__init__0s2)_5($=>,d3 f $HNHYHY[a[n[nptGuFvN#FOTBM(%%v'9'9="&MN) ' F %%v'9'9="&MN!&->K&%%v'9'9;&JK"6>4@L'%%v'9'9<&LMVmVoVuVuVwx(#sckdu~ExIx-h %(knrxkxVC[    2@ - .#,//"3CU]T 0^E0^M]0^^L!. A0@ A     8R 8 9+F8 #4F;  "6"+y  (H H!H!6H&r:rr|r}ryrrro __classcell__rxs@rnrr/ -#-#rqrceZdZddZy)SyncHttpxClientWrapperc^|jry |jy#t$rYywxYwrj)rcloserrzs rn__del__zSyncHttpxClientWrapper.__del__ms, >>   JJL   s  ,,Nr|r}ryrrrrkrqrnrrlsrqrceZdZUded<dZded<eedddd d2fdZd3dZd4d Z d5d Z d6d Z d7d Z d8d Z e d9dZedd d:dZeddd d;dZddd ddZ d?dZeidd d@dZeid dAdZeidd dBdZiddd  dBd!Zediddd" dCd#Zedidd$ dDd%Zediddd& dEd'Zdidddd( dEd)Zdid* dFd+Zddid, dGd-Zdid* dFd.Zdid/d0 dHd1ZxZS)Irz httpx.ClientrNztype[Stream[Any]] | Nonerrr http_clientrrc bt|s(|r |jtk7r |j}nt}|1t |t j stdt|t |)|tt|||||||xst|tt||_y)NzOInvalid `http_client` argument; Expected an instance of `httpx.Client` but got )rrrrrrrrr)r7rHTTPX_DEFAULT_TIMEOUTrErrClientrr.rrorr)rr) rmrrrrrrrrrxs rnrozSyncAPIClient.__init__{s {226KK%--)  ":k5<<+Pabfgrbsatu  '*#%)(C  # &<'*'  rqc.|jjSrjrrrzs rnrzSyncAPIClient.is_closed||%%%rqcRt|dr|jjyy)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrzs rnrzSyncAPIClient.closes# 4 # LL    $rqc|Srjrkrzs rn __enter__zSyncAPIClient.__enter__s rqc$|jyrjrrmexc_typeexcexc_tbs rn__exit__zSyncAPIClient.__exit__s rqc|Sz#Hook for mutating the given optionsrkrmrs rn_prepare_optionszSyncAPIClient._prepare_optionss rqcyaThis 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. NrkrNs rn_prepare_requestzSyncAPIClient._prepare_requestsrqcyrjrkrmrIrrM stream_clss rnrzSyncAPIClient.requestsrqFrMcyrjrkrmrIrrMs rnrzSyncAPIClient.requestsrqrMrcyrjrkrs rnrzSyncAPIClient.requests #rqc |j||}t|}|j2|jj dk7r|j |_d}|j |j}d}t|dzD]m}t|}|j|}||z } |j||} |j| i} |j|j| d<|j|j| d<tjd| j| j d} |j"j$| fd|xs|j'| i| }tjd| j| j |j4|j6|j8tjd|j8j;d |j=n|Jd|jM||||||S#t(j*$r^} tjd d | dkDr|j-|||d Yd} ~ tjdt/| | d} ~ wt0$r^} tjdd | dkDr|j-|||d Yd} ~ @tjdt3| | d} ~ wwxYw#t(j>$r} tjdd | dkDrP|jA| jBr5| jBjE|j-|||| Yd} ~ | jBjFs| jBjItjd|jK| jBdd} ~ wwxYwNr%rrrauthrzSending HTTP Request: %s %srM)rz"Encountered httpx.TimeoutExceptionT)exc_info)rrrrzRaising timeout errorzEncountered ExceptionzRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz request-idz!Encountered httpx.HTTPStatusErrorzRe-raising status errorz0could not resolve response (should never happen))rIrrrMrr)'rKr;r r(rrrrrangerr>rr\rrVr,rdrsendrOrTimeoutException_sleep_for_retryrQrrRr reason_phraserr%raise_for_statusHTTPStatusErrorrrrrr r_process_response rmrIrrMr input_optionsrrrrrr:rXs rnrzSyncAPIClient.requests..w@ #7+  ( ( 0]5I5I5O5O5QUZ5Z,0,A,A,CM )*.#33D4D4DE  ";?3V M /G++G4G +m ; ))')OG  ! !' *$&F+!%!1!1v''3-4-E-E)* II3W^^W[[ QH! C,4<<,,!WT%F%Fw%F%WD II1 $$&&    II&(8(8(<(<\(J K T))+, mV p#W%WW#%%!' &  C)) @ > N$q())&3$/ -!% *  12%g6C? C 1D A$q())&3$/ -!% *  45(9sB C6(( T = M$q(T-?-? -MLL&&())&3$/ -!) * ||--LL%%' 34;;CLLItS' TsP83H'K3K0-1J$"J K01K+ "K++K03OA&O2A!OOc||z }|dk(rtjdntjd||j|||r |jnd}tj d|j |t j|yNrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rVr,rrrrdrysleeprmrrrrrrs rnrzSyncAPIClient._sleep_for_retryhsu(-7  ! IIn % II'): ;//0A7`hHL\L\nrs 7gN 7rqrrc :|jjjtdk(r t t t |||||||St|xs|}tj|rt|tr|r2t|jjjtrWt|tstdtd|t d|}t t |||t|||||S|t j"k(rt t |St||t d|||||} t|jjjtrt t | S| j%S)NrrawrrIrMrrr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r)rrr%rIrr+rUrrSrTrUrBrrArrDrResponseparse rmrIrrrMrrorigin response_cls api_responses rnrzSyncAPIClient._process_responsevs    # # ' '(; < F! #!)#"/  G$/ OOF #6?3tH$4$4$<$<$@$@AT$UVfk2"CK=P[\b[c dee ._parsers&  ( ( )  KrqFr)rrWr|rW)rr)rmrrrrs`` ` rnrzSyncAPIClient._request_api_lists'  &||D'%|88rqrrMcyrjrkrmpathrIrrMs rnr%zSyncAPIClient.getsrqrcyrjrkrmrrIrrMrs rnr%zSyncAPIClient.getsrqrrcyrjrkrs rnr%zSyncAPIClient.gets #rqrrMrc xtjdd|d|}tt|j ||||SNr%)r(rdrrk)r> constructrr+rrmrrIrrMroptss rnr%zSyncAPIClient.gets?#,,OEtOwOIt||GT&U_|`aarq)rrr'rMcyrjrk)rmrrIrrr'rMs rnpostzSyncAPIClient.postsrq)rrr'cyrjrkrmrrIrrr'rMrs rnr%zSyncAPIClient.postsrq)rrr'rcyrjrkr's rnr%zSyncAPIClient.posts #rq)rrr'rMrc tjdd||t|d|}tt|j ||||SNr%r(rdrr'rrk)r>r!r#rr+r) rmrrIrrr'rMrr#s rnr%zSyncAPIClient.post sP#,, tt>%;P T[ It||GT&U_|`aarqrrcXtjdd||d|}|j||SNpatchr(rdrrkr>r!rrmrrIrrr#s rnr/zSyncAPIClient.patch0s3#,,aGQUaY`a||GT**rqrr'rc ltjdd||t|d|}|j||SNputr+rk)r>r!r#rrmrrIrr'rr#s rnr6zSyncAPIClient.put;sB#,, dd.:O SZ ||GT**rqcXtjdd||d|}|j||SNdeleter0rkr1r2s rnr:zSyncAPIClient.deleteIs3#,,bH$RVbZab||GT**rqr%rrr(cZtjd|||d|}|j|||SNr0rkr>r!rrmrrrrrr(r#s rn get_api_listzSyncAPIClient.get_api_listT7#,,`FPT`X_`%%eT488rq)rrrrrrr!float | Timeout | None | NotGivenrzhttpx.Client | Nonerrrrrrr|r}rrrmrZr|rZrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Noner|r}rr>r|r>rrr|r}) rIType[ResponseT]rr>rM Literal[True]rzType[_StreamT]r|r]rIrGrr>rMLiteral[False]r|r+) rIrGrr>rMrrzType[_StreamT] | Noner|ResponseT | _StreamT) rIrGrr>rMrrtype[_StreamT] | Noner|rK rrrrrr>rzhttpx.Response | Noner|r}rIrGrr>rrrMrrz1type[Stream[Any]] | type[AsyncStream[Any]] | Nonerrr|r+)r Type[object]rType[SyncPageT]rr>r|rW rrrIrGrr0rMrJr|r+) rrrIrGrr0rMrHrtype[_StreamT]r|r]) rrrIrGrr0rMrrrLr|rK)rrrIrGr Body | Nonerr0r'RequestFiles | NonerMrJr|r+)rrrIrGrrSrr0r'rTrMrHrrRr|r])rrrIrGrrSrr0r'rTrMrrrLr|rK rrrIrGrrSrr0r|r+ rrrIrGrrSr'rTrr0r|r+)rrrrOrrPrrSrr0r(rr|rW)ryrrrrrGr3rorrrrrrrrrrrr%r%r/r6r:r@rrs@rnrrws 4818/5>+/3748, ,  ,  , 3 , ), 1, 2, &*,  , \&!,"%   $      %   #   "'  %     ,0 # #%#  # * # ##,0 v  v %v  v * v  v p  # 25 @S _t   ,B$!B$% B$ ! B$  B$FB$B$ B$H999% 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  9rqrc eZdZdfd ZxZS)_DefaultAsyncHttpxClientc X|jdt|jdt|jddd|vrtjtj dfg}t tdd}|#|jtj|dfnFtjdk(r3t td d }|jtj|dft td d}|"|jtj|d ft td d}|"|jtj|dftjDcic]\}}||dn t|} }}dD cic] } | |vs| || } } || d<| jD cic]\}} || dn tdd| i| } }} tdi| }| j|j!di| |d<||d<t#|Hdi|ycc}}wcc} wcc} }wr)rrErKrrrrrCrrrirTrrrrr%rrors rnroz!_DefaultAsyncHttpxClient.__init__cs3)_5($=>,d3 f $HNHYHY[a[n[nptGuFvN#FOTBM(%%v'9'9="&MN) ' F %%v'9'9="&MN!&->K&%%v'9'9;&JK"6>4@L'%%v'9'9<&LMVmVoVuVuVwx(#sckdu~ExIx-h %(knrxkxVC[    2@ - .#,//"3CU]T0B0c0cRb0ccL!3 F5E F     8R 8 9+F8 #4F;  "6"+y  rrrrs@rnrXrXbrrqrXc eZdZdfd ZxZS)_DefaultAioHttpClientc |jdt|jdt|jddt|di|y)NrrrTrk)rrErKrro)rmr:rxs rnroz_DefaultAioHttpClient.__init__sE   i 9   h(A B   0$ 7 G  &v &rqrrrs@rnr[r[s  ' 'rqr[ceZdZddZy)r[c td)NzVTo use the aiohttp client you must have installed the package with the `aiohttp` extra)r)rm_kwargss rnroz_DefaultAioHttpClient.__init__swx xrqN)r_rr|r})ryrrrorkrqrnr[r[s yrqceZdZddZy)AsyncHttpxClientWrapperc|jry tjj|j y#t $rYywxYwrj)rasyncioget_running_loop create_taskacloserrzs rnrzAsyncHttpxClientWrapper.__del__s@ >>    $ $ & 2 24;;= A   s1A A  A NrrrkrqrnrarasrqraceZdZUded<dZded<eedddd d2fdZd3dZd4d Z d5d Z d6d Z d7d Z d8d Z edd d9dZe d:dZedd d;dZddd d;dZ ddZeidd d?dZeid d@dZeidd dAd Ziddd! dAd"Zeddidd# dBd$Zeddid% dCd&Zeddidd' dDd(Zddiddd) dDd*Zdid+ dEd,Zddid% dFd-Zdid+ dEd.Zdid/d0 dGd1ZxZS)Hrzhttpx.AsyncClientrNztype[AsyncStream[Any]] | Nonerrc bt|s(|r |jtk7r |j}nt}|1t |t j stdt|t |)||tt||||||xst|tt||_y)NzTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got )rrrrrrrr)r7rrrErr AsyncClientrr.rrorr)rar) rmrrrrrrrrrxs rnrozAsyncAPIClient.__init__s {226KK%--)  ":k5CTCT+Ufgklwgxfyz  '*#%)(C  # &='*'  rqc.|jjSrjrrzs rnrzAsyncAPIClient.is_closedrrqcTK|jjd{y7w)rN)rrfrzs rnrzAsyncAPIClient.closes ll!!###s (&(cK|Swrjrkrzs rn __aenter__zAsyncAPIClient.__aenter__s  c@K|jd{y7wrjrrs rn __aexit__zAsyncAPIClient.__aexit__s jjls cK|Swrrkrs rnrzAsyncAPIClient._prepare_optionss rnc KywrrkrNs rnrzAsyncAPIClient._prepare_requests Frc Kywrjrkrs rnrzAsyncAPIClient.requests rsc Kywrjrkrs rnrzAsyncAPIClient.request#s rs)rc Kywrjrkrs rnrzAsyncAPIClient.request-s %(rsrc K|j!ttd{|_|j||}t |}|j 2|j jdk7r|j|_d}|j|j}d}t|dzD]}t |}|j|d{}||z } |j||} |j| d{i} |j|j| d<|j |j | d<t"j%d| j | j&d} |j(j*| fd|xs|j-| i| d{}t"j%d| j | j&|j:|j<|j>t"j%d|j>jAd |jCn|Jd|jS||||||d{S7C77c7#t.j0$rg} t"j%d d | dkDr$|j3|||d d{7Yd} ~ t"j%dt5| | d} ~ wt6$rg} t"j%dd | dkDr$|j3|||d d{7Yd} ~ }t"j%dt9| | d} ~ wwxYw#t.jD$r} t"j%dd | dkDrb|jG| jHrG| jHjKd{7|j3|||| d{7Yd} ~ 8| jHjLs#| jHjOd{7t"j%d|jQ| jHdd} ~ wwxYw7wr)*rr6 get_platformrKr;r r(rrrrrrr>rr\rrVr,rdrrrOrrrrQrrRrrrr%rrrrrfrareadrrrs rnrzAsyncAPIClient.request7s5 >> !$:8L#9#;;DN..w@ #7+  ( ( 0]5I5I5O5O5QUZ5Z,0,A,A,CM )*.#33D4D4DE  ";?3V M /G 11'::G +m ; ))')OG''0 0 0$&F+!%!1!1v''3-4-E-E)* II3W^^W[[ QH! C!2!2!2"!WT%F%Fw%F%W""D II1 $$&&    II&(8(8(<(<\(J K T))+, mV p#W%WW#++!' ,   S<$; 1 )) @ > N$q(//&3$/ -!% 0  12%g6C? C 1D A$q(//&3$/ -!% 0  45(9sB C6(( T = M$q(T-?-? -M,,--/////&3$/ -!) 0 ||--,,,,... 34;;CLLItS' T0 s $Q%I)B4Q%I,0Q% I/ A)Q%76I4-I2.I42A;Q%.M>&Q%$Q"%Q%,Q%/Q%2I44M4K);J><K)Q%"K)) M54M)L,*M/Q%5"MMQ%Q2AQO Q$O'%Q*Q%03Q#P&$6QQQ%c:K||z }|dk(rtjdntjd||j|||r |jnd}tj d|j |t j|d{y7wr)rVr,rrrrdanyiorrs rnrzAsyncAPIClient._sleep_for_retrys(-7  ! IIn % II'): ;//0A7`hHL\L\nrs 7gNkk'"""sBBBBrrc NK|jjjtdk(r t t t |||||||St|xs|}tj|rt|tr|r2t|jjjtrSt|tstdtd|t d|}t d|||t|||||S|t j"k(rt t |St||t d|||||} t|jjjtrt t | S| j%d{S7w)Nrrr r r r+r)rrr%rIrr+rUrrSrTrUrBrrCrrDrr rrs rnrz AsyncAPIClient._process_responses    # # ' '(; < F! #!)#"/  G$/ OOF #6?3tH$4$4$<$<$@$@AT$UVf&67"CDTCUU`ag`h ijj r!r$r) rmrrIrr'rrMrr#s rnr%zAsyncAPIClient.post`s^#,, ttAUV[A\;\ `g \\'4:\VVV<]Vs!"AA !AA A Ar,ctKtjdd||d|}|j||d{S7wr.r1r2s rnr/zAsyncAPIClient.patchps=#,,aGQUaY`a\\'40000 /868c Ktjdd||t|d{d|}|j||d{S7#7wr5rr7s rnr6zAsyncAPIClient.put{sX#,, dd@TUZ@[:[ _f \\'4000;\0s!"A AA A A  A ctKtjdd||d|}|j||d{S7wr9r1r2s rnr:zAsyncAPIClient.deletes=#,,bH$RVbZab\\'40000rr%r;cZtjd|||d|}|j|||Sr=r>r?s rnr@zAsyncAPIClient.get_api_listrArq)rrrrrrrrrrBrzhttpx.AsyncClient | Nonerrrrr|r}rrrCrDrErFrI) rIrGrr>rMrHrtype[_AsyncStreamT]r|r^) rIrGrr>rMrrtype[_AsyncStreamT] | Noner|ResponseT | _AsyncStreamTrMrN)rrrrrr>r|AsyncPaginator[_T, AsyncPageT]rQ) rrrIrGrr0rMrHrrr|r^) rrrIrGrr0rMrrrr|r)rrrIrGrrSr'rTrr0rMrJr|r+)rrrIrGrrSr'rTrr0rMrHrrr|r^)rrrIrGrrSr'rTrr0rMrrrr|rrUrV)rrrrrrrrSrr0r(rr|r)ryrrrrrGr3rorrrmrprrrrrrrr%r%r/r6r:r@rrs@rnrrs 9=6=/5>043748, ,  , &* ,  , 3, ., 1, 2,  , \&$,"%   $      "'  %     %   (  26 ( (%(  ( / ( #((15 {  { %{  { / {  #{ z # # #25 #@S #_t #  #,B*!B*% B* ! B*  B*FB*B* B*HXXX% 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 ( 9rqr)query extra_headers extra_query extra_bodyr rrci}|||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.rr-rfrr r)rr,r%rr*r7)rrrrr rrrs rnmake_request_optionsrs!G *  $Z <  !Hw{{8R8HKH gx ($ "%4!" !,  NrqceZdZddZy)r3cy)NTrkrzs rn__bool__zForceMultipartDict.__bool__srqNr)ryrrrrkrqrnr3r3srqr3c&eZdZddZeddZy) OtherPlatformc||_yrjnamermrs rnrozOtherPlatform.__init__  rqc d|jS)NzOther:rrzs rn__str__zOtherPlatform.__str__ {##rqNrrr|r}r~ryrrrorrrkrqrnrr$$rqr)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)Nriphoneipadrrrwindowsrandroidrlinuxfreebsdropenbsdrr)risystemrrdistroidr)r platform_name distro_ids rnrxrxs"((* ))+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)rrxget_architectureget_python_runtimeget_python_version)rris rnrbrbs;%'.h8,.9 0 2313'9';  rqc&eZdZddZeddZy) OtherArchc||_yrjrrs rnrozOtherArch.__init__rrqc d|jS)Nzother:rrzs rnrzOtherArch.__str__rrqNrr~rrkrqrnrrrrqr)x32x64armarm64unknowncJ tjS#t$rYywxYwNr)ripython_implementationrrkrqrnrr&s(--//   ""cJ tjS#t$rYywxYwr)ripython_versionrrkrqrnrr-s(&&(( rc tjj}|dvry|dk(ry|dk(rytj dkry|r t |Sy#t$rYywxYw) Nr)raarch64rrx86_64rlr)rimachinerrrrr)rs rnrr4sz""$**,&&%( {{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&)obj1obj2mergedrErFs rnr r Ns?  F)/ W:3z%QU?VCJ WW Ws<<)r Query | NonerzHeaders | NonerrrrSr rrz'float | httpx.Timeout | None | NotGivenrzPostParser | NotGivenr|r0)r|Platform)rrrizPlatform | Noner|rr~)r|Arch)rMapping[_T_co, Union[_T, Omit]]rrr|zDict[_T_co, _T]) __future__rrrhryrrurrcrSr*ri email.utilstypesrrtypingrrrr r r r r rrrrrrrrrtyping_extensionsrrrr{rrrrrrrrr _qsr"_filesr#r$_typesr%r&r'r(r)r*r+r,r-r.r/r0r1r2r3_utilsr4r5r6r7r8r9_compatr:r;r<_modelsr=r>r?r@ _responserArBrCrD _constantsrErFrGrHrIrJrK _streamingrLrMrNrOrPrQrRrS _utils._httpxrT_legacy_responserU getLoggerryrVrrWrYrZr[r]r^ httpx._configr_r ImportErrorrbrrrrrrirrrrDefaultHttpxClientrrrX httpx_aiohttpHttpxAiohttpClientr[DefaultAsyncHttpxClientDefaultAioHttpClientrarrrr3rrrxrbrrrrrr rkrqrnrsb" &<; ?? 8"PO88UU IH 3/'g''1^1 K': ; \)= >  T]4( :VC[ 1{3/?@ 3-Q 0B0Bf:6|WR[:6z.a8B<.ab$WR^,$N&gHRL'"+&gRuU\\5CTCT5T/UV +5kRUFV9V3WX@878@8F.#%,,.#b-/h9Ju||VC[89h9V.#u00.#b'' @ @'#//!,,_60 5 ^9Z 1 1;s3C CD^9F$( $""&7@)2" """ "  "  "5"'""Jc4i $$      'T 4$$ Y GH HI4 X ) X ) X Xy> - ' -F)yy 1 1yys$M<N< N  N N.-N.