g 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,mfZfmgZgmhZhmiZie jekZldemd<eddZneddZoedZpeddZqed ebeZred!edeZserdd"ltmuZvn dd"ltmuZvGd$d%ZxGd&d'ePeepZyGd(d)eyepeepZzGd*d+eepeofZ{Gd,d-eyepeepZ|ed.ee%je%jfZed/eebeedefZGd0d1eeefZGd2d3e%jZer e%jZneZGd4d5eZGd6d7ee%jebefZGd8d9e%jZer e%jZneZGd:d;eZGd<d=ee%jedefZddddde3e3d> dOd?ZGd@dAeedfZGdBdCZeee!dDfZdPdEZeJdFdQdGZGdHdIZeee!dJfZdRdKZdRdLZdSdMZ dTdNZy#ew$r e8d#ZvYwxYw)U) 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)APIStatusErrorAPITimeoutErrorAPIConnectionErrorAPIResponseValidationErrorzlogging.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 F/var/www/openai/venv/lib/python3.12/site-packages/groq/_base_client.py__init__zPageInfo.__init__{ cyrcrd)rfras rgrhzPageInfo.__init__rirjr_rac ||_||_yrcrl)rfr_ras rgrhzPageInfo.__init__s  rjc|jr&|jjd|jdS|jjd|jdS)Nz(url=)z(params=)r_ __class____name__rarfs rg__repr__zPageInfo.__repr__sM 88nn--.eDHH:Q? ?..))*(4;;-qAArjN)r_rreturnNone)rar$rtru)r_r^rar`rtrurtstr) rq __module__ __qualname____doc____annotations__rrhr!rrsrdrjrgr]r]rs        (#, !   BBrjr]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)rfitemss rg has_next_pagezBasePage.has_next_pages*$$&""$D00rjcyrcrdrrs rgrzBasePage.next_page_infosCrjcyrcrdrrs rgrzBasePage._get_page_itemss rjctjtt|jj j |j Src)httpx QueryParamsrrr~ramergeres rg_params_from_urlzBasePage._params_from_urls3  c4==+?+?!@AGG SSrjct|j}|jt|jt s!i|j|j|_|St|j t sc|j|j }|j j|}t|j|_t||_|Std)N)razUnexpected PageInfo state) r9r~_strip_raw_response_header isinstancerar'r_r copy_withdictrw ValueError)rfinfooptionsrar_s rg_info_to_optionszBasePage._info_to_optionssT]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455rjNrtbool)rtzOptional[PageInfo])rtz Iterable[_T])r_rrtzhttpx.QueryParams)rr]rtr<) rqrxryrzrr~r{rrrrrrrdrjrgr}r}s< %0MH!1"}FH$1 8 T6rjr}cjeZdZUejZded< ddZd dZd dZ d dZ y) BaseSyncPage SyncAPIClient_clientc.||_||_||_yrcrrr~)rfclientmodelrs rg_set_private_attributesz$BaseSyncPage._set_private_attributes    rjc#hK|jD]}|jD]}|ywrc iter_pagesrrfpageitems rg__iter__zBaseSyncPage.__iter__s/OO%D,,. /&s02c#^K|} ||jr|j}ny'wrcr get_next_pagerfrs rgrzBaseSyncPage.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_listrrprfrrs rgrzBaseSyncPage.get_next_pagesZ""$k ''-||--dkkX_-``rjN)rrrrrr<rtru)rtz Iterator[_T])rfrSrtzIterator[SyncPageT])rfrSrtrS) rqrxrypydanticrrr{rrrrrdrjrgrrsR1X113G]3   %    $ arjrc@eZdZ ddZddZddZd dZy) AsyncPaginatorc<||_||_||_||_yrc)rrr~ _page_cls)rfrrpage_clsrs rgrhzAsyncPaginator.__init__s    !rjc>|jjSrc) _get_page __await__rrs rgrzAsyncPaginator.__await__s~~))++rjcKdfd }|j_jjjjd{S7w)Ncl|jjjj|S)N)rrr)rrr~r)resprfs rg_parserz)AsyncPaginator._get_page.._parsers2  ( (kk || )  Krj)rrUrtrU)r~ post_parserrrequestr)rfrs` rgrzAsyncPaginator._get_pages? %, !\\))$..$--HHHHsA AAAchKtt|d{}|23d{}|77 6ywrc)rrUrs rg __aiter__zAsyncPaginator.__aiter__s7 J  $J  $s$2, 20.0202N) rAsyncAPIClientrr<rType[AsyncPageT]rrrtru)rtz Generator[Any, None, AsyncPageT])rtrUrtzAsyncIterator[_T])rqrxryrhrrrrdrjrgrrsG " "% "# "  "  ", IrjrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseAsyncPagerrc.||_||_||_yrcr)rfrrrs rgrz%BaseAsyncPage._set_private_attributes!rrjczK|j23d{}|jD]}| $76ywrcrrs rgrzBaseAsyncPage.__aiter__+s8//+ $,,. / +s;979;9;ctK|} ||jr|jd{}ny07wrcrrs rgrzBaseAsyncPage.iter_pages0s=J!!#!//11 2s ,868cK|j}|s td|j|}|jj |j |j |d{S7wrrrs rgrzBaseAsyncPage.get_next_page9sd""$k ''-\\33DKKdnn^e3ffffsA$A-&A+'A-N)rrrrrr<rtrur)rfrUrtzAsyncIterator[AsyncPageT])rfrUrtrU) rqrxryrrrr{rrrrrdrjrgrrsR2h224G^4   %     grjr _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 BaseClientrrrw_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 `groq.DEFAULT_MAX_RETRIES`)r_enforce_trailing_slashrrrrrrr_custom_headers _custom_queryrr _platform TypeError) rfversionbase_urlrrrlimits transportproxiesrrs rgrhzBaseClient.__init__Us  55c(mD&   #-3)/R+F(#' *.  `  rjcz|jjdr|S|j|jdzS)N/raw_path)rendswithrres rgrz"BaseClient._enforce_trailing_slashus3 <<  &J}}cllT&9}::rjcJ|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)rfrrerr_msgerr_texts rg _make_status_error_from_responsez+BaseClient._make_status_error_from_responsezs   h&A&AD$X%9%9$:;G}}**,HD Lzz(+()=)=(>c$H&&wTH&MM L"K X5I5I4J&K Ls'BB"!B"ctrc)NotImplementedError)rfrrrs rgrzBaseClient._make_status_errors "##rjr retries_takencr|jxsi}t|j|}|j||t j |}|j }|rB|jjdk7r%||vr!|jxs|j||<dd|Dvrt||d<|S)Ngetzx-stainless-retry-countc3<K|]}|jywrc)lower).0headers rg z,BaseClient._build_headers..s,Y.V\\^.s) headers_merge_mappingsdefault_headers_validate_headersrr%rmethodridempotency_key_idempotency_keyrw)rfrrr headers_dictr idempotency_headers rg_build_headerszBaseClient._build_headerss .B&t';';^L  |^<-- -!55 '.."6"6"8E"AFX`gFg*1*A*A*\TEZEZE\G& ' %,Y.,Y Y14]1CG- .rjct|}|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)rfr_ merge_urlmerge_raw_paths rg _prepare_urlzBaseClient._prepare_urlsZ H  $ $!]]33i6H6H6O6OPT6UUN==**N*C CrjctSrc)rKrrs rg_make_sse_decoderzBaseClient._make_sse_decoders |rjctjtjr!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_rarfilesrd))rR isEnabledForloggingDEBUGdebugr: json_data extra_jsonrr"r8r rtyper default_queryrarr' startswithpopr3r_serialize_multipartformr1ForceMultipartDictrr_hostreplacer build_requestrrr'rqs stringifyr rwr) rfrrkwargsr,r ra content_typer' prepared_urls rg_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    rjc|jj|d}i}|D]B\}}|j|}|s|||<t|r|j |<||g||<D|S)Nbrackets) array_format)r7stringify_itemsrr4append)rfr"r serializedkeyvalueexistings rgr2z#BaseClient._serialize_multipartforms'' # (  )+ JC!~~c*H"' 3x &#+U"3 3% (rjct|js|St|j}|jtt }t|r||_t tt|S|Src) r6r rr1rHr!rr r()rfcast_torr override_cast_tos rg_maybe_override_cast_toz"BaseClient._maybe_override_cast_to%s^(Nw' #;;'> J $ %%GOY)9: :rjcF|jjtdk(S)Nstream)r rrGrfrs rg_should_stream_response_bodyz'BaseClient._should_stream_response_body6s""#678CCrjc|ttdS|turtt|S tj|r1t |t r!tt|j||S|jrttt||Sttt||S#tj$r}t|||d}~wwxYw)N)rr")type_rD)rr)rr(objectinspectisclass issubclassr2buildrr=r>rValidationErrorrQ)rfr"rGrerrs rg_process_response_dataz!BaseClient._process_response_data9s < 4( ( f  4( ( Tw'Jw@T,UIw}}hT}'RSS//I}7$'OPP >t#LM M'' T,hTJPS S Ts$AB42&B4B44CCCctSrcrrrs rgr7z BaseClient.qsQs }rjcyrcrdrrs rg custom_authzBaseClient.custom_authUsrjciSrcrdrrs rg auth_headerszBaseClient.auth_headersYs rjcrdd|jd|j|j|jS)Nzapplication/json)Acceptr z User-Agent) user_agentplatform_headersr\rrrs rgrzBaseClient.default_headers]sN).// ##%    ""   rjci|jSrc)rrrs rgr/zBaseClient.default_queryhs     rjcy)zaValidate the given default headers and custom headers. Does nothing by default. Nrd)rfr rs rgrzBaseClient._validate_headersns rjcL|jjd|jS)Nz/Python )rprqrrrs rgr_zBaseClient.user_agentys"..))*(4==/BBrjc|jSrc)rrrs rgrzBaseClient.base_url}s ~~rjcz|jt|tr ||_yt||_yrc)rrrrres rgrzBaseClient.base_urls-55ZS=Qc`WZ[^W_`rjcDt|j|jS)N)platform)r`rrrrs rgr`zBaseClient.platform_headerss  GGrjc|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)rfresponse_headersretry_ms_header retry_headerretry_date_tuple retry_dates rg_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<rig@rg?)get_max_retriesrruminrFpowrDr) rfremaining_retriesrrpr retry_after nb_retries sleep_secondsjitterrs rg_calculate_retry_timeoutz#BaseClient._calculate_retry_timeouts --d.>.>? 445EF  "q;'<"'< (='88$? /#c:2FFX TFH_$&(!Q,w-A-rjcP|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 rrRr+r)rfrshould_retry_headers rg _should_retryzBaseClient._should_retrys&..223CD & ( IIL M ' ) IIQ R   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M .!rjc0dtjS)Nzstainless-python-retry-)uuiduuid4rrs rgrzBaseClient._idempotency_keys(77rj)rrwr str | URLrrrrrzfloat | Timeout | NonerrrrrrrMapping[str, str] | NonerMapping[str, object] | Nonertru)r_rrtr)rhttpx.ResponsertrN)rrwrrPrrrtz_exceptions.APIStatusError)rr<rrrtz httpx.Headers)r_rwrtr)rtzSSEDecoder | SSEBytesDecoder)rr<rrrt httpx.Request)r"zMapping[object, object]rtdict[str, object])rGtype[ResponseT]rr<rtr)rrrtr)r"rPrGrrrrtr()rtr)rtzhttpx.Auth | None)rtzdict[str, str])rtzdict[str, str | Omit])rtr)r r%rr%rtrurv)rtr)r_z URL | strrtru)rtDict[str, str]rc)rpOptional[httpx.Headers]rtz float | None)r{rrr<rprrtrj)rrrtr)"rqrxryr{rrErCrhrrrrrrr<r2rIrMrWpropertyr7rZr\rr/rr_rsetterr`rurrrrdrjrgrrHs 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!F8rjrc eZdZdfd ZxZS)_DefaultHttpxClientc |jdt|jdt|jddt|di|yNrrfollow_redirectsTrd setdefaultrCrIsuperrhrfr9rps rgrhz_DefaultHttpxClient.__init__E)_5($=>,d3 "6"rjr9rrtrurqrxryrh __classcell__rps@rgrr ##rjrceZdZddZy)SyncHttpxClientWrapperc^|jry |jy#t$rYywxYwrc)rcloserrrs rg__del__zSyncHttpxClientWrapper.__del__s, >>   JJL   s  ,,Nrtrurqrxryrrdrjrgrrsrjrc 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 ) rrrrrrrrrrTrrrrrd)warningswarnDeprecationWarningrrIr6rHTTPX_DEFAULT_TIMEOUTrCrrClientrr.rrhrr&rr)rfrrrrrrrrrrrr9rps rgrhzSyncAPIClient.__init__s~"$   MMz+  & !qrr.F  "+F;  MMm+  & !dee   'F9  MMk+  & !bcc {226KK%--)  ":k5<<+Pabfgrbsatu  '*#%)(C  # &<' '*! '  '  rjc.|jjSrcrrrrs rgrzSyncAPIClient.is_closedf||%%%rjcRt|dr|jjyy)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrrs rgrzSyncAPIClient.closeis# 4 # LL    $rjc|Srcrdrrs rg __enter__zSyncAPIClient.__enter__ss rjc$|jyrcrrfexc_typeexcexc_tbs rg__exit__zSyncAPIClient.__exit__vs rjc|Sz#Hook for mutating the given optionsrdrfrs rg_prepare_optionszSyncAPIClient._prepare_options~s rjcyaThis 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. NrdrLs rg_prepare_requestzSyncAPIClient._prepare_requestsrjcyrcrdrfrGrr{rK stream_clss rgrzSyncAPIClient.requestrjFrKcyrcrd)rfrGrr{rKs rgrzSyncAPIClient.requestrjrKrcyrcrdrs rgrzSyncAPIClient.request #rjct||j|j|z }nd}|j|||||SNr)rGrrKrrrxr_request)rfrGrr{rKrrs rgrzSyncAPIClient.requestsP  (#33D4D4DEHYYMM}}!'   rjc rt|}|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. | j1|jA||| |||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#tj2$r} tjdd|d kDre|j5| j6rJ| j6j9|j#|||| j6j.||cYd} ~ S| j6j:s| j6j=tjd|j?| j6dd} ~ wwxYw)NrauthzSending HTTP Request: %s %srKr"Encountered httpx.TimeoutExceptionTexc_inforrrKrrpRaising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %s!Encountered httpx.HTTPStatusErrorrrprKrRe-raising status errorrGrrrKrr)!r9rIrrxrr<rrZrRr+rr_rsendrMrTimeoutException_retry_requestrOrrPr reason_phraser raise_for_statusHTTPStatusErrorrrrrreadr_process_response) rfrGrrrKr input_optionsr{rr9rrVs rgrzSyncAPIClient._requests#7+ ..w@''0#33D4D4DE U%%g]%K g& "    '!--F6N /M# ?(t||((S!B!B7!B!SHH - NN KK   " "      P  % % '.%%!' &  A%% < II:TI J 1$**!"/!)%) + II- .!'2 ; ? II-I = 1$**!"/!)%) + II0 1$W53 > ?6$$ P II9DI I 1$););CLL)I ""$**!"/%(\\%9%9!) +<<)) !!# II/ 077 E4 O) Psb:3E!:H<!H942G&H9,"G H92H4 H9"H44H9<L6A;L1 L6A!L11L6cd|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)rrGrrKr) rxrrRr+rrr_rosleepr rfrrGrrprKrr{rs rgrzSyncAPIClient._retry_request0s$33D4D4DE U  ! IIn % II'): ;//0A7L\] 7gN 7}}'!+!   rjrrc :t|xs|}tj|rgt|trWt|t st dt d|td|}tt|||t|||||S|tjk(rtt|St ||td|||||} t|jjjt rtt| S| j#S)N!API Response types must subclass ; Received type[BaseAPIResponse[Any]]rawrrGrKrrrr)rrQrRrSr@r?rrr(rBrResponserrr rrGparse rfrGrrrKrrorigin response_cls api_responses rgrzSyncAPIClient._process_responseOs G$/ ??6 "z&/'Jfk2"CK=P[\b[c dee ._parsers&  ( ( )  KrjFr)rrSrtrS)rr)rfrrrrs`` ` rgrzSyncAPIClient._request_api_list~s'  &||D'%|88rjrrKcyrcrdrfpathrGrrKs rgrzSyncAPIClient.getrrjrcyrcrdrfrrGrrKrs rgrzSyncAPIClient.getrrjrrcyrcrdrs rgrzSyncAPIClient.getrrjrrKrc xtjdd|d|}tt|j ||||SNr)rr_rrd)r< constructrr(rrfrrGrrKroptss rgrzSyncAPIClient.gets?#,,OEtOwOIt||GT&U_|`aarj)rrr'rKcyrcrd)rfrrGrrr'rKs rgpostzSyncAPIClient.postsrj)rrr'cyrcrdrfrrGrrr'rKrs rgrzSyncAPIClient.postsrj)rrr'rcyrcrdrs rgrzSyncAPIClient.posts #rj)rrr'rKrc tjdd||t|d|}tt|j ||||SNrrr_r,r'rrd)r<rrrr(r) rfrrGrrr'rKrrs rgrzSyncAPIClient.postsP#,, tt>%;P T[ It||GT&U_|`aarjrrcXtjdd||d|}|j||SNpatchrr_r,rdr<rrrfrrGrrrs rgr%zSyncAPIClient.patchs3#,,aGQUaY`a||GT**rjrr'rc ltjdd||t|d|}|j||SNputr!rd)r<rrrrfrrGrr'rrs rgr,zSyncAPIClient.putsB#,, dd.:O SZ ||GT**rjcXtjdd||d|}|j||SNdeleter&rdr'r(s rgr0zSyncAPIClient.delete s3#,,bH$RVbZab||GT**rjrrrrcZtjd|||d|}|j|||SNr&rdr<rrrfrrrrrrrs rg get_api_listzSyncAPIClient.get_api_list7#,,`FPT`X_`%%eT488rj)rrwrrrrr!float | Timeout | None | NotGivenrzTransport | Nonerrr Limits | Nonerzhttpx.Client | NonerrrrrrrtrurrrfrVrtrVrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonertrurr<rtr<rrrtrurc) rGType[ResponseT]rr<r{ Optional[int]rK Literal[True]rzType[_StreamT]rtrY) rGr>rr<r{r?rKLiteral[False]rtr() rGr>rr<r{r?rKrrzType[_StreamT] | NonertResponseT | _StreamT) rGr>rr<r{r?rKrrtype[_StreamT] | NonertrB) rGr>rr<rrrKrrrCrtrB)rr<rGr>rrrphttpx.Headers | NonerKrrrCrtrBrGr>rr<rrrKrrz1type[Stream[Any]] | type[AsyncStream[Any]] | Nonerrrtr()r Type[object]rType[SyncPageT]rr<rtrS rrwrGr>rr0rKrArtr() rrwrGr>rr0rKr@rtype[_StreamT]rtrY) rrwrGr>rr0rKrrrCrtrB)rrwrGr>r Body | Nonerr0r'RequestFiles | NonerKrArtr()rrwrGr>rrJrr0r'rKrKr@rrIrtrY)rrwrGr>rrJrr0r'rKrKrrrCrtrB rrwrGr>rrJrr0rtr( rrwrGr>rrJr'rKrr0rtr()rrwrrFrrGrrJrr0rrwrtrS)rqrxryr{rrEr!rhrrrrrrrrrrrrrrr%r,r0r6rrs@rgrr s 4818/5>&*'+ $+/3748U U  U  U 3 U $U %U U )U 1U 2U &*U  U n&!,"%   $      ,0  %)   #  ,0  "'  %)     ,0 # ,0# #%#) #  #*# ##,0  ,0   % )    *   ,h !h % h  h  h *h  h T $ !   /   *   N-$!-$% -$ ! -$  -$F-$-$ -$^999% 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  9rjrc eZdZdfd ZxZS)_DefaultAsyncHttpxClientc |jdt|jdt|jddt|di|yrrrs rgrhz!_DefaultAsyncHttpxClient.__init__'rrjrrrs@rgrOrO&rrjrOceZdZddZy)AsyncHttpxClientWrapperc|jry tjj|j y#t $rYywxYwrc)rasyncioget_running_loop create_taskacloserrrs rgrzAsyncHttpxClientWrapper.__del__;s@ >>    $ $ & 2 24;;= A   s1A A  A NrrrdrjrgrRrR:srjrRc .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 ) rrrrrrrrrrTrrd)rrrrrIr6rrrCrr AsyncClientrr.rrhrr&rRr)rfrrrrrrrrrrrr9rps rgrhzAsyncAPIClient.__init__Js"$   MMz+  & !qrr.F  "+F;  MMm+  & !dee   'F9  MMk+  & !bcc {226KK%--)  ":k5CTCT+Ufgklwgxfyz  '*#%)(C  # &=' '*! '  '  rjc.|jjSrcrrrs rgrzAsyncAPIClient.is_closedrrjcTK|jjd{y7w)rN)rrWrrs rgrzAsyncAPIClient.closes ll!!###s (&(cK|Swrcrdrrs rg __aenter__zAsyncAPIClient.__aenter__s  c@K|jd{y7wrcrrs rg __aexit__zAsyncAPIClient.__aexit__s jjls cK|Swrrdrs rgrzAsyncAPIClient._prepare_optionss r_c KywrrdrLs rgrzAsyncAPIClient._prepare_requests F)rKr{c Kywrcrd)rfrGrrKr{s rgrzAsyncAPIClient.request rd)r{c KywrcrdrfrGrrKrr{s rgrzAsyncAPIClient.request rd)rr{c Kywrcrdrhs rgrzAsyncAPIClient.request %(rd)rKrr{cK||j|j|z }nd}|j|||||d{S7wrr)rfrGrrKrr{rs rgrzAsyncAPIClient.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)NrrrKrrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)$rr5 get_platformr9rIrrxrr<rrZrrrMrrrRr+rrOrrPrr_rrrrrrrWr rareadrr) rfrGrrKrrrr{rr9rrVs rgrzAsyncAPIClient._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) rxrrRr+rrr_anyiorrrs rgrzAsyncAPIClient._retry_requestfs$33D4D4DE U  ! IIn % II'): ;//0A7L\] 7gNkk'"""]]'!+! #    # s$BCC C?CCCrrc NKt|xs|}tj|rct|trSt|t st dt d|td|}td|||t|||||S|tjk(rtt|St ||td|||||} t|jjjt rtt| S| j#d{S7w)Nrrrr(rr)rrQrRrSr@rArrrBrrr(rrr rrGrrs rgrz AsyncAPIClient._process_responsesG$/ ??6 "z&/'Jf&67"CDTCUU`ag`h ijj rr<rKrAr{r?rtr() rGr>rr<rKr@rtype[_AsyncStreamT]r{r?rtrZ) rGr>rr<rKrrtype[_AsyncStreamT] | Noner{r?rtResponseT | _AsyncStreamT) rGr>rr<rKrrrrrrtr)rr<rGr>rrrprDrKrrrrtrrE)rrrrrr<rtAsyncPaginator[_T, AsyncPageT]rH) rrwrGr>rr0rKr@rrrtrZ) rrwrGr>rr0rKrrrrtr)rrwrGr>rrJr'rKrr0rKrArtr()rrwrGr>rrJr'rKrr0rKr@rrrtrZ)rrwrGr>rrJr'rKrr0rKrrrrtrrLrM)rrwrrrrrrJrr0rrwrtr)rqrxryr{rrEr!rhrrr^rarrrrrrrrrrr%r,r0r6rrs@rgrrFs 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-*-* -*^XXX% 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 ( 9rjr)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-rarrr)rr*rrr'r6)rrrrrrrrs rgmake_request_optionsrNs!G *  $Z <  !Hw{{8R8HKH gx ($ "%4!" !,  NrjceZdZddZy)r3cy)NTrdrrs rg__bool__zForceMultipartDict.__bool__tsrjNr)rqrxryrrdrjrgr3r3ssrjr3c&eZdZddZeddZy) OtherPlatformc||_yrcnamerfrs rgrhzOtherPlatform.__init__y  rjc d|jS)NzOther:rrrs rg__str__zOtherPlatform.__str__| {##rjNrrwrtrurvrqrxryrhrrrdrjrgrrx$$rjr)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)rgsystemrrdistroidr)r platform_name distro_ids rgrnrns"((* ))+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)rwrnget_architectureget_python_runtimeget_python_version)rrgs rgr`r`s;%'.h8,.9 0 2313'9';  rjc&eZdZddZeddZy) OtherArchc||_yrcrrs rgrhzOtherArch.__init__rrjc d|jS)Nzother:rrrs rgrzOtherArch.__str__rrjNrrvrrdrjrgrrrrjr)x32x64armarm64unknowncJ tjS#t$rYywxYwNr)rgpython_implementationrrdrjrgrrs(--//   ""cJ tjS#t$rYywxYwr)rgpython_versionrrdrjrgrrs(&&(( rc tjj}|dvry|dk(ry|dk(rytj dkry|r t |Sy#t$rYywxYw) Nr)raarch64rrx86_64rlr)rgmachinerrsysrr)rs rgrrsz""$**,&&%( {{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#)obj1obj2mergedrCrDs rgr r sC  F)/ W:3z%QU?VCJ WW Ws<<)r Query | NonerzHeaders | NonerrrrJrrrz'float | httpx.Timeout | None | NotGivenrzPostParser | NotGivenrtr0)rtPlatform)rrwrgzPlatform | Nonertrrv)rtArch)rMapping[_T_co, Union[_T, Omit]]rrrtzDict[_T_co, _T]) __future__rrrrorrkrTrQr)rgr email.utilstypesrrtypingrrrr r r r r rrrrrrrtyping_extensionsrrrrqrrrrrrr_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 getLoggerrqrRr{rSrUrVrWrYrZ httpx._configr[r ImportErrorr]r}rrrrrZrrrrDefaultHttpxClientrrrODefaultAsyncHttpxClientrRrrrwr3rrrnr`rrrrrr rdrjrgrs" "<;  8(PO+UU IH(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 #%,,#-/X9Ju||VC[89X9v#u00##//7 5 E9Z 1 1;s3C CDE9T$( $""&7@)2" """ "  "  "5"'""Jc4i $$      'T 4$$ Y GH HI4 X ) X ) X X[< - ' -sL77 MM