gvUddlmZddlZddlZddlZddlZddlZddlZddlZddl 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 dlEmFZFmGZGmHZHmIZImJZJmKZKmLZLd dlMmNZNmOZOd dlPmQZQmRZRmSZSmTZTd dlUmVZVmWZWmXZXmYZYd dlZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZad dlbmcZcmdZdmeZemfZfd dl,mgZgmhZhmiZimjZjd dlkmlZle jenZodepd<eojeFeddZreddZsedZtedd Zued!eceZved"eeeZwerdd#lxmyZzn dd#lxmyZzGd%d&Z|Gd'd(eQeetZ}Gd)d*e}eteetZ~Gd+d,eetesfZGd-d.e}eteetZed/ee%je%jfZed0eeceeeefZGd1d2eeefZGd3d4e%jZere%jZneZGd5d6eZGd7d8ee%jecefZGd9d:e%jZere%jZneZGd;dee%jeeefZddddde3e3d? dPd@ZGdAdBeedfZGdCdDZeee!dEfZdQdFZeKdGdRdHZGdIdJZeee!dKfZdSdLZdSdMZdTdNZ dUdOZy#e{$r e8d$ZzYwxYw)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)SensitiveHeadersFilteris_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 | NotGivenparamscyNselfras H/var/www/openai/venv/lib/python3.12/site-packages/openai/_base_client.py__init__zPageInfo.__init__} cyrerf)rhrcs rirjzPageInfo.__init__rkrlrarcc ||_||_yrern)rhrarcs rirjzPageInfo.__init__s  rlc|jr&|jjd|jdS|jjd|jdS)Nz(url=)z(params=)ra __class____name__rcrhs ri__repr__zPageInfo.__repr__sM 88nn--.eDHH:Q? ?..))*(4;;-qAArlN)rarreturnNone)rcr$rvrw)rar`rcrbrvrwrvstr) rs __module__ __qualname____doc____annotations__rrjr!rrurfrlrir_r_ts        (#, !   BBrlr_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)rhitemss ri has_next_pagezBasePage.has_next_pages*$$&""$D00rlcyrerfrts rirzBasePage.next_page_infosCrlcyrerfrts rirzBasePage._get_page_itemss rlctjtt|jj j |j Sre)httpx QueryParamsrrrrcmergergs ri_params_from_urlzBasePage._params_from_urls3  c4==+?+?!@AGG SSrlct|j}|jt|jt s!i|j|j|_|St|j t sc|j|j }|j j|}t|j|_t||_|Std)N)rczUnexpected PageInfo state) r:r_strip_raw_response_header isinstancercr'rar copy_withdictry ValueError)rhinfooptionsrcras ri_info_to_optionszBasePage._info_to_optionssT]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455rlNrvbool)rvzOptional[PageInfo])rvz Iterable[_T])rarrvzhttpx.QueryParams)rr_rvr=) rsrzr{r|rrr}rrrrrrrfrlrirrs< %0MH!1"}FH$1 8 T6rlrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseSyncPage SyncAPIClient_clientc.||_||_||_yrerrr)rhclientmodelrs ri_set_private_attributesz$BaseSyncPage._set_private_attributes    rlc#hK|jD]}|jD]}|ywre iter_pagesrrhpageitems ri__iter__zBaseSyncPage.__iter__s/OO%D,,. /&s02c#^K|} ||jr|j}ny'wrer get_next_pagerhrs rirzBaseSyncPage.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_listrrrrhrrs rirzBaseSyncPage.get_next_pagesZ""$k ''-||--dkkX_-``rlN)rrrrrr=rvrw)rvz Iterator[_T])rhrUrvzIterator[SyncPageT])rhrUrvrU) rsrzr{pydanticrrr}rrrrrfrlrirrsR1X113G]3   %    $ arlrc@eZdZ ddZddZddZd dZy) AsyncPaginatorc<||_||_||_||_yre)rrr _page_cls)rhrrpage_clsrs rirjzAsyncPaginator.__init__s    !rlc>|jjSre) _get_page __await__rts rirzAsyncPaginator.__await__s~~))++rlcKdfd }|j_jjjjd{S7w)Ncl|jjjj|S)N)rrr)rrrr)resprhs ri_parserz)AsyncPaginator._get_page.._parser s2  ( (kk || )  Krl)rrWrvrW)r post_parserrrequestr)rhrs` rirzAsyncPaginator._get_page s? %, !\\))$..$--HHHHsA AAAchKtt|d{}|23d{}|77 6ywre)rrWrs ri __aiter__zAsyncPaginator.__aiter__s7 J  $J  $s$2, 20.0202N) rAsyncAPIClientrr=rType[AsyncPageT]rrrvrw)rvz Generator[Any, None, AsyncPageT])rvrWrvzAsyncIterator[_T])rsrzr{rjrrrrfrlrirrsG " "% "# "  "  ", IrlrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseAsyncPagerrc.||_||_||_yrer)rhrrrs rirz%BaseAsyncPage._set_private_attributes#rrlczK|j23d{}|jD]}| $76ywrerrs rirzBaseAsyncPage.__aiter__-s8//+ $,,. / +s;979;9;ctK|} ||jr|jd{}ny07wrerrs rirzBaseAsyncPage.iter_pages2s=J!!#!//11 2s ,868cK|j}|s td|j|}|jj |j |j |d{S7wrrrs rirzBaseAsyncPage.get_next_page;sd""$k ''-\\33DKKdnn^e3ffffsA$A-&A+'A-N)rrrrrr=rvrwr)rhrWrvzAsyncIterator[AsyncPageT])rhrWrvrW) rsrzr{rrrr}rrrrrfrlrirr sR2h224G^4   %     grlr _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 BaseClientrrry_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 `openai.DEFAULT_MAX_RETRIES`)r_enforce_trailing_slashrrrrrrr_custom_headers _custom_queryrr _platform TypeError) rhversionbase_urlrrrlimits transportproxiesrrs rirjzBaseClient.__init__Ws  55c(mD&   #-3)/R+F(#' *.  b  rlcz|jjdr|S|j|jdzS)N/raw_path)rendswithrrgs rirz"BaseClient._enforce_trailing_slashws3 <<  &J}}cllT&9}::rlcJ|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)rhrrerr_msgerr_texts ri _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"ctre)NotImplementedError)rhrrrs rirzBaseClient._make_status_errors "##rlr retries_takencr|jxsi}t|j|}|j||t j |}|j }|rB|jjdk7r%||vr!|jxs|j||<dd|Dvrt||d<|S)Ngetzx-stainless-retry-countc3<K|]}|jywre)lower).0headers ri z,BaseClient._build_headers..s,Y.V\\^.s) headers_merge_mappingsdefault_headers_validate_headersrr%rmethodr idempotency_key_idempotency_keyry)rhrrr headers_dictridempotency_headers ri_build_headerszBaseClient._build_headerss .B&t';';^L  |^<-- -!55 '.."6"6"8E"AFX`gFg*1*A*A*\TEZEZE\G& ' %,Y.,Y Y14]1CG- .rlct|}|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)rhra merge_urlmerge_raw_paths ri _prepare_urlzBaseClient._prepare_urlsZ H  $ $!]]33i6H6H6O6OPT6UUN==**N*C CrlctSre)rLrts ri_make_sse_decoderzBaseClient._make_sse_decoders |rlctjtjr!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)rrrrarcrfilesrf))rT isEnabledForloggingDEBUGdebugr; json_data extra_jsonrr"r9rrtyper default_queryrcrr) startswithpopr4r_serialize_multipartformr1ForceMultipartDictrrahostreplacer build_requestrrr'rqs stringifyr ryr) rhrrkwargsr.rrc content_typer) prepared_urls ri_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    rlc|jj|d}i}|D]B\}}|j|}|s|||<t|r|j |<||g||<D|S)Nbrackets) array_format)r9stringify_itemsrr5append)rhr$r serializedkeyvalueexistings rir4z#BaseClient._serialize_multipartform s'' # (  )+ JC!~~c*H"' 3x &#+U"3 3% (rlct|js|St|j}|jtt }t|r||_t tt|S|Sre) r7rrr3rIr!rr r()rhcast_torroverride_cast_tos ri_maybe_override_cast_toz"BaseClient._maybe_override_cast_to's^(Nw' #;;'> J $ %%GOY)9: :rlcF|jjtdk(S)Nstream)rrrHrhrs ri_should_stream_response_bodyz'BaseClient._should_stream_response_body8s""#678CCrlc|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?rValidationErrorrR)rhr$rIrerrs ri_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&B4B44CCCctSrerrts rir9z BaseClient.qsSs }rlcyrerfrts ri custom_authzBaseClient.custom_authWsrlciSrerfrts ri auth_headerszBaseClient.auth_headers[s rlcrdd|jd|j|j|jS)Nzapplication/json)Acceptr"z User-Agent) user_agentplatform_headersr^rrts rirzBaseClient.default_headers_sN).// ##%    ""   rlci|jSre)rrts rir1zBaseClient.default_queryjs     rlcy)zaValidate the given default headers and custom headers. Does nothing by default. Nrf)rhrrs rirzBaseClient._validate_headersps rlcL|jjd|jS)Nz/Python )rrrsrrts rirazBaseClient.user_agent{s"..))*(4==/BBrlc|jSre)rrts rirzBaseClient.base_urls ~~rlcz|jt|tr ||_yt||_yre)rrrrrgs rirzBaseClient.base_urls-55ZS=Qc`WZ[^W_`rlcDt|j|jS)N)platform)rbrrrts rirbzBaseClient.platform_headerss  GGrlc|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)rhresponse_headersretry_ms_header retry_headerretry_date_tuple retry_dates ri_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<rkg@rg?)get_max_retriesrrwminrGpowrEr) rhremaining_retriesrrrr retry_after nb_retries sleep_secondsjitterrs ri_calculate_retry_timeoutz#BaseClient._calculate_retry_timeouts --d.>.>? 445EF  "q;'<"'< (='88$? /#c:2FFX TFH_$&(!Q,w-A-rlcP|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)rrrTr-r)rhrshould_retry_headers ri _should_retryzBaseClient._should_retrys&..223CD & ( IIL M ' ) IIQ R   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M .!rlc0dtjS)Nzstainless-python-retry-)uuiduuid4rts rirzBaseClient._idempotency_keys(77rl)rryr str | URLrrrrrzfloat | Timeout | NonerrrrrrrMapping[str, str] | NonerMapping[str, object] | Nonervrw)rarrvr)rhttpx.ResponservrO)rryrrRrrrvz_exceptions.APIStatusError)rr=rrrvz httpx.Headers)raryrvr)rvzSSEDecoder | SSEBytesDecoder)rr=rrrv httpx.Request)r$zMapping[object, object]rvdict[str, object])rItype[ResponseT]rr=rvr)rrrvr)r$rRrIrrrrvr()rvr)rvzhttpx.Auth | None)rvzdict[str, str])rvzdict[str, str | Omit])rvr)rr%rr%rvrwrx)rvr)raz URL | strrvrw)rvDict[str, str]re)rrOptional[httpx.Headers]rvz float | None)r}rrr=rrrrvrl)rrrvr)"rsrzr{r}rrFrDrjrrrrrrr>r4rKrOrYpropertyr9r\r^rr1rrarsetterrbrwrrrrfrlrirrJs 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!F8rlrc eZdZdfd ZxZS)_DefaultHttpxClientc |jdt|jdt|jddt|di|yNrrfollow_redirectsTrf setdefaultrDrJsuperrjrhr;rrs rirjz_DefaultHttpxClient.__init__E)_5($=>,d3 "6"rlr;rrvrwrsrzr{rj __classcell__rrs@rirr ##rlrceZdZddZy)SyncHttpxClientWrapperc^|jry |jy#t$rYywxYwre)rcloserrts ri__del__zSyncHttpxClientWrapper.__del__s, >>   JJL   s  ,,Nrvrwrsrzr{rrfrlrirrsrlrc 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 ) rrrrrrrrrrTrrrrrf)warningswarnDeprecationWarningrrJr7rHTTPX_DEFAULT_TIMEOUTrDrrClientrr0rrjrr&rr)rhrrrrrrrrrrrr;rrs rirjzSyncAPIClient.__init__s~"$   MMz+  & !qrr.F  "+F;  MMm+  & !dee   'F9  MMk+  & !bcc {226KK%--)  ":k5<<+Pabfgrbsatu  '*#%)(C  # &<' '*! '  '  rlc.|jjSrerrrts rirzSyncAPIClient.is_closedh||%%%rlcRt|dr|jjyy)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrts rirzSyncAPIClient.closeks# 4 # LL    $rlc|Srerfrts ri __enter__zSyncAPIClient.__enter__us rlc$|jyrerrhexc_typeexcexc_tbs ri__exit__zSyncAPIClient.__exit__xs rlc|Sz#Hook for mutating the given optionsrfrhrs ri_prepare_optionszSyncAPIClient._prepare_optionss rlcyaThis 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. NrfrNs ri_prepare_requestzSyncAPIClient._prepare_requestsrlcyrerfrhrIrr}rM stream_clss rirzSyncAPIClient.requestrlFrMcyrerf)rhrIrr}rMs rirzSyncAPIClient.requestrlrMrcyrerfrs rirzSyncAPIClient.request #rlct||j|j|z }nd}|j|||||SNr)rIrrMrrrzr_request)rhrIrr}rMrrs rirzSyncAPIClient.requestsP  (#33D4D4DEHYYMM}}!'   rlc 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 %srMr"Encountered httpx.TimeoutExceptionTexc_inforrrMrrrRaising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz x-request-id!Encountered httpx.HTTPStatusErrorrrrrMrRe-raising status errorrIrrrMrr)"r:rKrrzrr>rr\rTr-rrarsendrOrTimeoutException_retry_requestrPrrQr reason_phraserrraise_for_statusHTTPStatusErrorrrrrreadr_process_response) rhrIrrrMr input_optionsr}rr;rrXs rirzSyncAPIClient._requests0#7+ ..w@''0#33D4D4DE U%%g]%K g& "    '!--F6N /M# ?(t||((S!B!B7!B!SHH - NN KK   " "      "H$4$4$8$8$HI 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)rrIrrMr) rzrrTr-rrrarqsleepr rhrrIrrrrMrr}rs rirzSyncAPIClient._retry_request3s$33D4D4DE U  ! IIn % II'): ;//0A7L\] 7gN 7}}'!+!   rlrrc |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)NrrawrrIrMrrr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r)rrrrHrr(rSrrSrTrUrAr@rrCrResponserparse rhrIrrrMrrorigin response_cls api_responses rirzSyncAPIClient._process_responseRs\    # # ' '(; < F! #!)#"/  G$/ ??6 "z&/'Jfk2"CK=P[\b[c dee ._parsers&  ( ( )  KrlFr)rrUrvrU)rr)rhrrrrs`` ` rirzSyncAPIClient._request_api_lists'  &||D'%|88rlrrMcyrerfrhpathrIrrMs rirzSyncAPIClient.getrrlrcyrerfrhrrIrrMrs rirzSyncAPIClient.getrrlrrcyrerfrs rirzSyncAPIClient.getrrlrrMrc xtjdd|d|}tt|j ||||SNr)rrarrf)r= constructrr(rrhrrIrrMroptss rirzSyncAPIClient.gets?#,,OEtOwOIt||GT&U_|`aarl)rrr)rMcyrerf)rhrrIrrr)rMs ripostzSyncAPIClient.postsrl)rrr)cyrerfrhrrIrrr)rMrs rirzSyncAPIClient.postsrl)rrr)rcyrerfrs rirzSyncAPIClient.posts #rl)rrr)rMrc tjdd||t|d|}tt|j ||||SNrrrar.r)rrf)r=rrrr(r) rhrrIrrr)rMrrs rirzSyncAPIClient.postsP#,, tt>%;P T[ It||GT&U_|`aarlrrcXtjdd||d|}|j||SNpatchrrar.rfr=rrrhrrIrrrs rir'zSyncAPIClient.patchs3#,,aGQUaY`a||GT**rlrr)rc ltjdd||t|d|}|j||SNputr#rf)r=rrrrhrrIrr)rrs rir.zSyncAPIClient.putsB#,, dd.:O SZ ||GT**rlcXtjdd||d|}|j||SNdeleter(rfr)r*s rir2zSyncAPIClient.deletes3#,,bH$RVbZab||GT**rlrrrrcZtjd|||d|}|j|||SNr(rfr=rrrhrrrrrrrs ri get_api_listzSyncAPIClient.get_api_list)7#,,`FPT`X_`%%eT488rl)rryrrrrr!float | Timeout | None | NotGivenrzTransport | Nonerrr Limits | Nonerzhttpx.Client | NonerrrrrrrvrwrrrhrXrvrXrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonervrwrr=rvr=rrrvrwre) rIType[ResponseT]rr=r} Optional[int]rM Literal[True]rzType[_StreamT]rvr[) rIr@rr=r}rArMLiteral[False]rvr() rIr@rr=r}rArMrrzType[_StreamT] | NonervResponseT | _StreamT) rIr@rr=r}rArMrrtype[_StreamT] | NonervrD) rIr@rr=rrrMrrrErvrD)rr=rIr@rrrrhttpx.Headers | NonerMrrrErvrDrIr@rr=rrrMrrz1type[Stream[Any]] | type[AsyncStream[Any]] | Nonerrrvr()r Type[object]rType[SyncPageT]rr=rvrU rryrIr@rr0rMrCrvr() rryrIr@rr0rMrBrtype[_StreamT]rvr[) rryrIr@rr0rMrrrErvrD)rryrIr@r Body | Nonerr0r)RequestFiles | NonerMrCrvr()rryrIr@rrLrr0r)rMrMrBrrKrvr[)rryrIr@rrLrr0r)rMrMrrrErvrD rryrIr@rrLrr0rvr( rryrIr@rrLr)rMrr0rvr()rryrrHrrIrrLrr0rryrvrU)rsrzr{r}rrFr!rjrrrrrrrrrrrrrrr'r.r2r8rrs@rirr 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  9rlrc eZdZdfd ZxZS)_DefaultAsyncHttpxClientc |jdt|jdt|jddt|di|yrrrs rirjz!_DefaultAsyncHttpxClient.__init__8rrlrrrs@rirQrQ7rrlrQceZdZddZy)AsyncHttpxClientWrapperc|jry tjj|j y#t $rYywxYwre)rasyncioget_running_loop create_taskacloserrts rirzAsyncHttpxClientWrapper.__del__Ls@ >>    $ $ & 2 24;;= A   s1A A  A NrrrfrlrirTrTKsrlrTc .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 ) rrrrrrrrrrTrrf)rrrrrJr7rrrDrr AsyncClientrr0rrjrr&rTr)rhrrrrrrrrrrrr;rrs rirjzAsyncAPIClient.__init__[s"$   MMz+  & !qrr.F  "+F;  MMm+  & !dee   'F9  MMk+  & !bcc {226KK%--)  ":k5CTCT+Ufgklwgxfyz  '*#%)(C  # &=' '*! '  '  rlc.|jjSrerrts rirzAsyncAPIClient.is_closedrrlcTK|jjd{y7w)rN)rrYrts rirzAsyncAPIClient.closes ll!!###s (&(cK|Swrerfrts ri __aenter__zAsyncAPIClient.__aenter__s  c@K|jd{y7wrerrs ri __aexit__zAsyncAPIClient.__aexit__s jjls cK|Swrrfrs rirzAsyncAPIClient._prepare_optionss rac KywrrfrNs rirzAsyncAPIClient._prepare_requests F)rMr}c Kywrerf)rhrIrrMr}s rirzAsyncAPIClient.request rf)r}c KywrerfrhrIrrMrr}s rirzAsyncAPIClient.request rf)rr}c Kywrerfrjs rirzAsyncAPIClient.request %(rf)rMrr}cK||j|j|z }nd}|j|||||d{S7wrr)rhrIrrMrr}rs rirzAsyncAPIClient.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)NrrrMrrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)$rr6 get_platformr:rKrrzrr>rr\rrrOrrrTr-rrPrrQrrarrrrrrrYrrareadrr) rhrIrrMrrrr}rr;rrXs rirzAsyncAPIClient._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) rzrrTr-rrraanyiorrrs rirzAsyncAPIClient._retry_requestws$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)rrrrHrr(rSrrSrTrUrArBrrCrrrrrs rirz AsyncAPIClient._process_responsesi    # # ' '(; < F! #!)#"/  G$/ ??6 "z&/'Jf&67"CDTCUU`ag`h ijj r?) rIr@rr=rMrCr}rArvr() rIr@rr=rMrBrtype[_AsyncStreamT]r}rArvr\) rIr@rr=rMrrtype[_AsyncStreamT] | Noner}rArvResponseT | _AsyncStreamT) rIr@rr=rMrrrrrrvr)rr=rIr@rrrrrFrMrrrrvrrG)rrrrrr=rvAsyncPaginator[_T, AsyncPageT]rJ) rryrIr@rr0rMrBrrrvr\) rryrIr@rr0rMrrrrvr)rryrIr@rrLr)rMrr0rMrCrvr()rryrIr@rrLr)rMrr0rMrBrrrvr\)rryrIr@rrLr)rMrr0rMrrrrvrrNrO)rryrrrrrrLrr0rryrvr)rsrzr{r}rrFr!rjrrr`rcrrrrrrrrrrr'r.r2r8rrs@rirrWs 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 ( 9rlr)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.rr/rcrrr)rr*rrr'r7)rrrrrrrrs rimake_request_optionsrms!G *  $Z <  !Hw{{8R8HKH gx ($ "%4!" !,  NrlceZdZddZy)r5cy)NTrfrts ri__bool__zForceMultipartDict.__bool__srlNr)rsrzr{rrfrlrir5r5srlr5c&eZdZddZeddZy) OtherPlatformc||_yrenamerhrs rirjzOtherPlatform.__init__  rlc d|jS)NzOther:rrts ri__str__zOtherPlatform.__str__ {##rlNrryrvrwrxrsrzr{rjrrrfrlrirr$$rlr)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)risystemr rdistroidr)r platform_name distro_ids rirprps"((* ))+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)ryrpget_architectureget_python_runtimeget_python_version)rris rirbrbs;%'.h8,.9 0 2313'9';  rlc&eZdZddZeddZy) OtherArchc||_yrerrs rirjzOtherArch.__init__rrlc d|jS)Nzother:rrts rirzOtherArch.__str__rrlNrrxrrfrlrirrrrlr)x32x64armarm64unknowncJ tjS#t$rYywxYwNr)ripython_implementationrrfrlrirrs(--//   ""cJ tjS#t$rYywxYwr)ripython_versionrrfrlrirrs(&&(( rc tjj}|dvry|dk(ry|dk(rytj dkry|r t |Sy#t$rYywxYw) Nr)raarch64rrx86_64rlr)rimachiner rsysrr)rs rirrsz""$**,&&%( {{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 rirrsC  F)/ W:3z%QU?VCJ WW Ws<<)r Query | NonerzHeaders | NonerrrrLrrrz'float | httpx.Timeout | None | NotGivenrzPostParser | NotGivenrvr0)rvPlatform)rryrizPlatform | Nonervrrx)rvArch)rMapping[_T_co, Union[_T, Omit]]rrrvzDict[_T_co, _T]) __future__rrrrqrrmrVrSr+rir email.utilstypesrrtypingrrrr r r r r rrrrrrrtyping_extensionsrrrrsrrrrrrr_qsr_filesrr _typesr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2_utilsr3r4r5r6r7r8r9_compatr:r;_modelsr<r=r>r? _responser@rArBrC _constantsrDrErFrGrHrIrJ _streamingrKrLrMrNrOrPrQrR_legacy_responserS getLoggerrsrTr} addFilterrUrWrXrYr[r\ httpx._configr]r ImportErrorr_rrrrrr\rrrrDefaultHttpxClientrrrQDefaultAsyncHttpxClientrTrrryr5rrrprbrrrrrrrfrlrirs " "<;  8(hgg+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##//7 5 S9Z 1 1;s3C CDS9p$( $""&7@)2" """ "  "  "5"'""Jc4i $$      'T 4$$ Y GH HI4 X ) X ) X XU= - ' -sM M.-M.