fUddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Zddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlm 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.m/Z/m0Z0d d l1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCd dlDmEZEmFZFmGZGmHZHmIZImJZJd dlKmLZLmMZMd dlNmOZOmPZPmQZQmRZRd dlSmTZTmUZUmVZVmWZWd dlXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_d dl`maZambZbmcZcmdZdd dl+meZemfZfmgZgmhZhd dlimjZjejelZmdend<eddZoeddZpedZqedd Zred!eaeZsed"eceZterdd#lumvZwn dd#lumvZwGd%d&ZyGd'd(eOeeqZzGd)d*ezeqeeqZ{Gd+d,eeqepfZ|Gd-d.ezeqeeqZ}ed/ee$je$jfZed0eeaeecefZGd1d2eeefZGd3d4e$jZer e$jZneZGd5d6eZGd7d8ee$jeaefZGd9d:e$jZer e$jZneZGd;dee$jecefZddddde2e2d? dPd@ZGdAdBeedfZGdCdDZeee dEfZdQdFZeIdGdRdHZGdIdJZeee dKfZdSdLZdSdMZdTdNZ dUdOZy#ex$r e7d$ZwYwxYw)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@cteZdZUdZded<ded<e d dZe d dZeed d d Zy )PageInfozStores the necessary information to build the request to retrieve the next page. Either `url` or `params` must be set. URL | NotGivenurlQuery | NotGivenparamscyNselfr`s R/opt/lhia/ganansol/python/venv/lib/python3.12/site-packages/openai/_base_client.py__init__zPageInfo.__init__{ cyrdre)rgrbs rhrizPageInfo.__init__rjrkr`rbc ||_||_yrdrm)rgr`rbs rhrizPageInfo.__init__s  rkN)r`rreturnNone)rbr$rorp)r`r_rbrarorp)__name__ __module__ __qualname____doc____annotations__rrir!rerkrhr^r^rs        (#, !   rkr^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*$$&""$D00rkcyrdrergs rhr}zBasePage.next_page_infosrkcyrdrers rhr|zBasePage._get_page_itemss rkctjtt|jj j |j Srd)httpx QueryParamsrrrxrbmergerfs 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) r9rx_strip_raw_response_header isinstancerbr'r`r copy_withdictstr ValueError)rginfooptionsrbr`s rh_info_to_optionszBasePage._info_to_optionssT]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455rkNrobool)rozOptional[PageInfo])roz Iterable[_T])r`rrozhttpx.QueryParams)rr^ror<) rqrrrsrtrrxrurzrr}r|rrrerkrhrwrws< %0MH!1"}FH$1 8 T6rkrwcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseSyncPage SyncAPIClient_clientc.||_||_||_yrdrzrrx)rgclientmodelrs rh_set_private_attributesz$BaseSyncPage._set_private_attributes    rkc#hK|jD]}|jD]}|ywrd iter_pagesr|rgpageitems 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_listrz __class__rgrrs rhrzBaseSyncPage.get_next_pagesZ""$k ''-||--dkkX_-``rkN)rrrryrr<rorp)roz Iterator[_T])rgrTrozIterator[SyncPageT])rgrTrorT) rqrrrspydanticrrrurrrrrerkrhrrsR1X113G]3   %    $ arkrc@eZdZ ddZddZddZd dZy) AsyncPaginatorc<||_||_||_||_yrd)rzrrx _page_cls)rgrrpage_clsrs rhrizAsyncPaginator.__init__s    !rkc>|jjSrd) _get_page __await__rs rhrzAsyncPaginator.__await__s~~))++rkcKdfd }|j_jjjjd{S7w)Ncl|jjjj|S)N)rrr)rrzrxr)resprgs rh_parserz)AsyncPaginator._get_page.._parsers2  ( (kk || )  Krk)rrVrorV)rx 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]rryrorp)roz Generator[Any, None, AsyncPageT])rorVrozAsyncIterator[_T])rqrrrsrirrrrerkrhrrsG " "% "# "  "  ", IrkrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseAsyncPagerrc.||_||_||_yrdr)rgrrrs rhrz%BaseAsyncPage._set_private_attributesrrkczK|j23d{}|jD]}| $76ywrdrrs rhrzBaseAsyncPage.__aiter__%sB//+  $,,.    +s;979;9;ctK|} ||jr|jd{}ny07wrdrrs rhrzBaseAsyncPage.iter_pages*s=J!!#!//11 2s ,868cK|j}|s td|j|}|jj |j |j |d{S7wrrrs rhrzBaseAsyncPage.get_next_page3sd""$k ''-\\33DKKdnn^e3ffffsA$A-&A+'A-N)rryrrrr<rorpr)rgrVrozAsyncIterator[AsyncPageT])rgrVrorV) rqrrrsrrrrurrrrrerkrhrrsR2h224G^4   %     grkr _HttpxClientT_DefaultStreamTcNeZdZUded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<dZded<eeddd d4dZd5dZ d6dZ d7dZ d8dZ d9dZ d:dZ d;d Z dd#Zd?d$Z d@d%ZedAd&ZedBd'ZedCd(ZedDd)ZedEd*Z dFd+ZedGd,ZedHd-Zej:dId.ZdJd/ZdKdLd0Z dK dMd1Z dNd2Z!dGd3Z"y)O BaseClientrrr_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) rgversionbase_urlrrrlimits transportproxiesrrs rhrizBaseClient.__init__Os  55c(mD&   #-3)/R+F(#' *.  b  rkcz|jjdr|S|j|jdzS)N/raw_path)rendswithrrfs rhrz"BaseClient._enforce_trailing_slashos3 <<  &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_responsets   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 "##rkc@||S|j|jSrd)get_max_retriesr)rgremaining_retriesrs rh_remaining_retrieszBaseClient._remaining_retriess' %6$A pwG^G^_c_o_oGpprkc@|jxsi}t|j|}|j||t j |}|j }|rB|jjdk7r%||vr!|jxs|j||<|S)Nget) headers_merge_mappingsdefault_headers_validate_headersrr%rmethodloweridempotency_key_idempotency_key)rgrr headers_dictridempotency_headers rh_build_headerszBaseClient._build_headerss .B&t';';^L  |^<-- -!55 '.."6"6"8E"AFX`gFg*1*A*A*\TEZEZE\G& '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)rKrs rh_make_sse_decoderzBaseClient._make_sse_decoders |rkc\tjtjr!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}|j4j6d |t9|j:t<r |j:n |j:|j>|jA|jB|r6|jDjGttHtJtLf|nd||d |S)NzRequest options: %sT) exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body` Content-Typezmultipart/form-databoundaryzGExpected query input to be a dictionary for multipart requests but got z instead.data)rrr r`rbrfilesre)'rS isEnabledForloggingDEBUGdebugr: json_data extra_jsonrr"r8rrtyper default_queryrbrr startswithpopr3r_serialize_multipartformr1ForceMultipartDictr build_requestrrr'r rr`qs stringifyr rr)rgrkwargsr#rrb content_typers rh_build_requestzBaseClient._build_requests   GMM * II+Zt-T U!#%%    )  w'9'9: I&+Iw7I7IJ "%@i@QQq#rss%%g. !3!3W^^D{{>2    # (?(?@U(V- N+y)#abfgpbqarr{|"&!>!>y!Iv.0B0DE*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)r,stringify_itemsrr4append)rgrr~ serializedkeyvalueexistings rhr)z#BaseClient._serialize_multipartforms'' # (  )+  4JC!~~c*H"' 3x &#+U"3 3% 4(rkct|js|St|j}|jtt }t|r||_t tt|S|Srd) r6rrr(rHr!rr r()rgcast_torroverride_cast_tos rh_maybe_override_cast_toz"BaseClient._maybe_override_cast_tos^(Nw' #;;'> J $ %%GOY)9: :rkcF|jjtdk(S)Nstream)rrrGrgrs rh_should_stream_response_bodyz'BaseClient._should_stream_response_body+s""#678CCrkc|ttdS|turtt|S tj|r1t |t r!tt|j||S|jrttt||Sttt||S#tj$r}t|||d}~wwxYw)N)rr)type_r8)rr)rr(objectinspectisclass issubclassr2buildrr=r>rValidationErrorrQ)rgrr;rerrs 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&B4B44CCCctSrdrrs rhr,z BaseClient.qsFs }rkcyrdrers rh custom_authzBaseClient.custom_authJsrkciSrdrers rh auth_headerszBaseClient.auth_headersNs rkcrdd|jd|j|j|jS)Nzapplication/json)Acceptrz User-Agent) user_agentplatform_headersrPrrs rhrzBaseClient.default_headersRsN).// ##%    ""   rkci|jSrd)rrs rhr&zBaseClient.default_query]s     rkcy)zaValidate the given default headers and custom headers. Does nothing by default. Nre)rgrrs rhr zBaseClient._validate_headerscs rkcL|jjd|jS)Nz/Python )rrqrrs rhrSzBaseClient.user_agentns"..))*(4==/BBrkc|jSrd)rrs rhrzBaseClient.base_urlrs ~~rkcz|jt|tr ||_yt||_yrd)rrrrrfs rhrzBaseClient.base_urlvs-55ZS=Qc`WZ[^W_`rkcDt|j|jS)N)platform)rTrrrs rhrTzBaseClient.platform_headerszs  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-msiz 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|S||z }ttt d|zt }ddtzz }||z} | dk\r| SdS)Nr<g@rg?)rrrhminrFpowrDr) rgrrrcr retry_after nb_retries sleep_secondsjitterrs rh_calculate_retry_timeoutz#BaseClient._calculate_retry_timeouts --d.>.>? 445EF  "q;'<"'< (=!#44 /#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)rrrSr"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-)uuiduuid4rs rhr zBaseClient._idempotency_keys(77rk)rrr str | URLrrrrrzfloat | Timeout | NonerrrrrrrMapping[str, str] | NonerMapping[str, object] | Nonerorp)r`rror)rhttpx.ResponserorN)rrrrDrr}roz_exceptions.APIStatusError)r Optional[int]rr<ror)rr<roz httpx.Headers)r`rror)rozSSEDecoder | SSEBytesDecoder)rr<ro httpx.Request)rzMapping[object, object]rodict[str, object])r;type[ResponseT]rr<ror)rrror)rrDr;rrr}ror()ror)rozhttpx.Auth | None)rozdict[str, str])rozdict[str, str | Omit])ror)rr%rr%rorpror)ror)r`z URL | strrorp)roDict[str, str]rd)rcOptional[httpx.Headers]roz float | None)rrrr<rcrror])rr}ror)#rqrrrsrurrErCrirrrrrrrr0r)r=rArKpropertyr,rNrPrr&r rSrsetterrTrhrqrvr rerkrhrrBs MN (( !!11!%%##8<5</*94848  &*   (5%12 @; N N N,$$ $ ! $ $ $q(q%q q  B $B  B H<"DTT! T ! T  T0         CC__aaH /L59 ..%.2 .  ..!F8rkrc eZdZdfd ZxZS)_DefaultHttpxClientc |jdt|jdt|jddt|di|yNrrfollow_redirectsTre setdefaultrCrIsuperrirgr.rs rhriz_DefaultHttpxClient.__init__E)_5($=>,d3 "6"rkr.rrorprqrrrsri __classcell__rs@rhrr ##rkrceZdZddZy)SyncHttpxClientWrappercD |jy#t$rYywxYwrd)closerrs rh__del__zSyncHttpxClientWrapper.__del__s"  JJL   s  Nrorprqrrrsrrerkrhrrsrkrc 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 ~|)tjdtd|tdt}|)tjdtd| td|)tjdtd| tdt |s(|r |j tk7r |j }nt}|1t|tjstd t|t |=||t!t"|||||| | | |xst%|t!t"||||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`[The `transport` argument is deprecated. The `http_client` argument should be passed insteadAThe `http_client` argument is mutually exclusive with `transport`YThe `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 ) rrrrrrrrrrTrrrrrr)warningswarnDeprecationWarningrrIr6rHTTPX_DEFAULT_TIMEOUTrCrrClientrr%rrirr&rr) rgrrrrrrrrrrrrs rhrizSyncAPIClient.__init__s\   MMz+  & !qrr.F  MMm+  & !dee   MMk+  & !bcc {226KK%--)  ":k5<<+Pabfgrbsatu  '*#%)(C  # &<'*!'  rkc.|jjSrdrrrs rhrzSyncAPIClient.is_closedU||%%%rkcRt|dr|jjyy)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrs rhrzSyncAPIClient.closeXs# 4 # LL    $rkc|Srdrers rh __enter__zSyncAPIClient.__enter__bs rkc$|jyrdrrgexc_typeexcexc_tbs rh__exit__zSyncAPIClient.__exit__es rkc|Sz#Hook for mutating the given optionsrergrs rh_prepare_optionszSyncAPIClient._prepare_optionsms 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. Nrer@s rh_prepare_requestzSyncAPIClient._prepare_requesttsrkcyrdrergr;rrr? stream_clss rhrzSyncAPIClient.requestrkFr?cyrdre)rgr;rrr?s rhrzSyncAPIClient.requestrkr?rcyrdrers rhrzSyncAPIClient.request #rkc.|j|||||SN)r;rr?rr_requestrs rhrzSyncAPIClient.requests)}}!/   rkc t|}|j||}|j|}|j||}|j |}|j |i} |j |j | d<tjd|j|j |jj|fd|xs|j|i| } tjd |j|j| j(| j*| j,tjd| j,j/d | j1|jA||| |||jC|jD|z S#tj$r_} tjdd|dkDr|j!|||||d cYd} ~ Stjd t#|| d} ~ wt$$r_} tjd d|dkDr|j!|||||d cYd} ~ Stjd t'|| d} ~ wwxYw#tj2$r} tjdd|dkDre|j5| j6rJ| j6j9|j!|||| j6j,||cYd} ~ S| j6j:s| j6j=tjd|j?| j6dd} ~ wwxYw)NauthzSending HTTP Request: %s %sr?r"Encountered httpx.TimeoutExceptionTexc_inforr?rrcRaising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz x-request-id!Encountered httpx.HTTPStatusErrorrRe-raising status errorr;rrr?r retries_taken)#r9r=rrr0rrNrSr"r r`rsendrArTimeoutException_retry_requestrOrrPr reason_phraserrraise_for_statusHTTPStatusErrorrvrrrreadr_process_responserr) rgr;rrr?r input_optionsretriesrr.rrJs rhrzSyncAPIClient._requests5#7+ ..w@''0))*;WE%%g. g& "    '!--F6N /M# ?(t||((S!B!B7!B!SHH - NN KK   " "      "H$4$4$8$8$HI P  % % '.%%!!11$2B2BCgM &  C%% < II:TI J{**!!)%) + II- .!'2 ; ? II-I ={**!!)%) + II0 1$W53 > ?8$$ P II9DI I{t11#,,? ""$**!LL((!) +<<)) !!# II/ 077 E4 O) Psb,3FI9I612H #I6)"H  I62I1 I6"I11I69M3 A;M.M3 A!M..M3c,|dz }|dk(rtjdntjd||j|||}tjd|j|t j ||j|||||SNrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rr;rr?r)rSr"rqrr`rbsleepr rgrr;rrcr?r remainingrs rhrzSyncAPIClient._retry_requests&) > IIn % II' 3// 7DTU 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)Nrsrawrr;r?rrr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r)rrrrGrr(rRrrErFrGr@r?rrBrResponserparse rgr;rrr?rrorigin response_cls api_responses rhrzSyncAPIClient._process_response:s\    # # ' '(; < F! #!)#"/  G$/ ??6 "z&/'Jfk2"CK=P[\b[c dee ._parser}s&  ( ( )  KrkFr)rrTrorT)rr)rgrrrrs`` ` rhrzSyncAPIClient._request_api_listws'  &||D'%|88rkrr?cyrdrergpathr;rr?s rhrzSyncAPIClient.getrrkrcyrdrergrr;rr?rs rhrzSyncAPIClient.getrrkrrcyrdrers rhrzSyncAPIClient.getrrkrr?rc xtjdd|d|}tt|j ||||SNr)r r`rre)r< constructrr(rrgrr;rr?roptss rhrzSyncAPIClient.gets?#,,OEtOwOIt||GT&U_|`aark)rrrr?cyrdre)rgrr;rrrr?s rhpostzSyncAPIClient.postsrk)rrrcyrdrergrr;rrrr?rs rhrzSyncAPIClient.postsrk)rrrrcyrdrers rhrzSyncAPIClient.posts #rk)rrrr?rc tjdd||t|d|}tt|j ||||SNrr r`r#rrre)r<r rrr(r) rgrr;rrrr?rrs rhrzSyncAPIClient.postsP#,, tt>%;P T[ It||GT&U_|`aarkrrcXtjdd||d|}|j||SNpatchr r`r#rer<r rrgrr;rrrs rhrzSyncAPIClient.patchs3#,,aGQUaY`a||GT**rkrrrc ltjdd||t|d|}|j||SNputrre)r<r rrrgrr;rrrrs rhr"zSyncAPIClient.putsB#,, dd.:O SZ ||GT**rkcXtjdd||d|}|j||SNdeleterrerrs rhr&zSyncAPIClient.deletes3#,,bH$RVbZab||GT**rkrrrr cZtjd|||d|}|j|||SNrrer<r rrgrrrrrr rs rh get_api_listzSyncAPIClient.get_api_list7#,,`FPT`X_`%%eT488rk)rrrrzrrr!float | Timeout | None | NotGivenrzTransport | Nonerrr Limits | Nonerzhttpx.Client | Nonerr{rr|rrrorprrrgrWrorWrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonerorprr<ror<rrrorprd) r;Type[ResponseT]rr<rr~r? Literal[True]rzType[_StreamT]rorZ) r;r4rr<rr~r?Literal[False]ror() r;r4rr<rr~r?rrzType[_StreamT] | NoneroResponseT | _StreamT) r;r4rr<rr~r?rrtype[_StreamT] | Noneror7) r;r4rr<r int | Noner?rrr8ror7)rr<r;r4rrrchttpx.Headers | Noner?rrr8ror7r;r4rr<rr}r?rrz1type[Stream[Any]] | type[AsyncStream[Any]] | Nonerrror()r Type[object]rType[SyncPageT]rr<rorT rrr;r4rr0r?r6ror() rrr;r4rr0r?r5rtype[_StreamT]rorZ) rrr;r4rr0r?rrr8ror7)rrr;r4r Body | Nonerr0rRequestFiles | Noner?r6ror()rrr;r4rr@rr0rrAr?r5rr?rorZ)rrr;r4rr@rr0rrAr?rrr8ror7 rrr;r4rr@rr0ror( rrr;r4rr@rrArr0ror()rrrr<rr=rr@rr0r rrorT)rqrrrsrurrEr!rirrrrrrrrrrrrrrrr"r&r,rrs@rhrrs 4818/5>&*'+ $+/3748S S  S  S 3 S $S %S S )S 1S 2S &*S  S j&!,"%   $      ,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__ rrkrrrs@rhrErErrkrEceZdZddZy)AsyncHttpxClientWrapperc tjj|jy#t$rYywxYwrd)asyncioget_running_loop create_taskacloserrs rhrzAsyncHttpxClientWrapper.__del__4s6   $ $ & 2 24;;= A   s14 AANrrrerkrhrHrH3srkrHc .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 ~|)tjdtd| tdt}|)tjdtd| td|)tjdtd| tdt |s(| r | j tk7r | j }nt}| 1t| tjstd t| t |=|||t!t"||||| | | | xst%|t!t"||||d |_y) NrrrrrrrrzTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got ) rrrrrrrrrrTr)rrrrrIr6rrrCrr AsyncClientrr%rrirr&rHr) rgrrrrrrrrrrrrs rhrizAsyncAPIClient.__init__@s^   MMz+  & !qrr.F  MMm+  & !dee   MMk+  & !bcc {226KK%--)  ":k5CTCT+Ufgklwgxfyz  '*#%)(C  # &='*!'  rkc.|jjSrdrrs rhrzAsyncAPIClient.is_closedrrkcTK|jjd{y7w)rN)rrMrs rhrzAsyncAPIClient.closes ll!!###s (&(cK|Swrdrers rh __aenter__zAsyncAPIClient.__aenter__s  c@K|jd{y7wrdrrs rh __aexit__zAsyncAPIClient.__aexit__s jjls cK|Swrrers rhrzAsyncAPIClient._prepare_optionss rUc Kywrrer@s rhrzAsyncAPIClient._prepare_requests F)r?rc Kywrdre)rgr;rr?rs rhrzAsyncAPIClient.request rZ)rc Kywrdrergr;rr?rrs rhrzAsyncAPIClient.request rZ)rrc Kywrdrer^s rhrzAsyncAPIClient.request %(rZ)r?rrcJK|j|||||d{S7wrrr^s rhrzAsyncAPIClient.requests7]]!/ #    s #!#c :K|j!ttd{|_t|}|j ||}|j |d{}|j ||}|j|}|j|d{i} |j|j| d< |jj|fd|xs|j|i| d{} tj!d |j*|j,| j.| j0 | j3|jE||| |||jG|jH|z d{S7b7*77#tj$rh} tj!dd|dkDr%|j#|||||dd{7cYd} ~ Stj!d t%|| d} ~ wt&$rh} tj!d d|dkDr%|j#|||||dd{7cYd} ~ Stj!d t)|| d} ~ wwxYw#tj4$r} tj!d d|dkDrw|j7| j8r\| j8j;d{7|j#|||| j8j<||d{7cYd} ~ S| j8j>s#| j8jAd{7tj!d|jC| j8dd} ~ wwxYw7w)Nrr?rrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)%rr5 get_platformr9r=rrr0rrNrrrArrrSr"rrOrrPr r`rrrrrvrrMrrareadrrrr) rgr;rr?rrrrrr.rrJs rhrzAsyncAPIClient._requestsm >> !$:8L#9#;;DN #7+ ..w@--g66))*;WE%%g.##G,,, "    '!--F6N# ?.T\\..S!B!B7!B!SHH )7>>7;;H\H\^f^t^t  P  % % '.++!!11$2B2BCgM ,   g<7 - %% < II:TI J{!00!!)%) 1 II- .!'2 ; ? II-I ={!00!!)%) 1 II0 1$W53 > ?,$$ P II9DI I{t11#,,?ll))+++!00!LL((!) 1<<))ll((*** II/ 077 E4 O) P, s$NF:N!F ";NF!N6F6F7F;AN=I? 6NNN NNFI<%6HGH I<!N&"H I<6I7 I  I7I<N"I77I<<N?NAN'K*(3NLN N!N&3NM6NNNc\K|dz }|dk(rtjdntjd||j|||}tjd|j|t j |d{|j|||||d{S7"7wr)rSr"rqrr`anyiorrrs rhrzAsyncAPIClient._retry_requestUs&) > IIn % II' 3// 7DTU 7gNkk'"""]]'! #    # s$BB,B(B,#B*$B,*B,rrc 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)Nrsrrrrr(r)rrrrGrr(rRrrErFrGr@rArrBrrrrrs rhrz AsyncAPIClient._process_responsersi    # # ' '(; < F! #!)#"/  G$/ ??6 "z&/'Jf&67"CDTCUU`ag`h ijj ) rrr;r4rr0r?r5rryror[) rrr;r4rr0r?rrrzror{)rrr;r4rr@rrArr0r?r6ror()rrr;r4rr@rrArr0r?r5rryror[)rrr;r4rr@rrArr0r?rrrzror{rBrC)rrrryrrrr@rr0r rror|)rqrrrsrurrEr!rirrrTrWrrrrrrrrrrrr"r&r,rrs@rhrr<s 9=6=/5>+/'+ $043748S S  S &* S  S 3S )S %S S .S 1S 2S  S j&$,"%   $      "'+/  %   )  ,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_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$rbrr r)rr*rrr'r6)r}r~rrr rrrs rhmake_request_optionsrKs!G *  $Z <  !Hw{{8R8HKH gx ($ "%4!" !,  NrkceZdZddZy)r*cy)NTrers rh__bool__zForceMultipartDict.__bool__qsrkNr)rqrrrsrrerkrhr*r*psrkr*c&eZdZddZeddZy) OtherPlatformc||_yrdnamergrs rhrizOtherPlatform.__init__v  rkc d|jS)NzOther:rrs rh__str__zOtherPlatform.__str__y {##rkNrrrorprrqrrrsrirrrerkrhrru$$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)r[systemr rdistroidr)r platform_name distro_ids rhrdrds"((* ))+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)rrdget_architectureget_python_runtimeget_python_version)rr[s rhrTrTs;%'.h8,.9 0 2313'9';  rkc&eZdZddZeddZy) OtherArchc||_yrdrrs rhrizOtherArch.__init__rrkc d|jS)Nzother:rrs rhrzOtherArch.__str__rrkNrrrrerkrhrrrrkr)x32x64armarm64unknowncJ tjS#t$rYywxYwNr)r[python_implementationrrerkrhrrs(--//   ""cJ tjS#t$rYywxYwr)r[python_versionrrerkrhrrs(&&(( rc tj\}}tjj}|dvry|dk(ry|dk(ry|dk(ry|r t |Sy#t$rYywxYw) Nr)raarch64rrx86_64r32bitr)r[ architecturemachiner rr)python_bitness_rs rhrrs$113""$**,&&%( !! ) s9A 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. )r~rr#)obj1obj2mergedr7r8s rhrrs?  F)/ W:3z%QU?VCJ WW Ws<<)r} Query | Noner~zHeaders | Nonerrrr@r rrz'float | httpx.Timeout | None | NotGivenrzPostParser | NotGivenror0)roPlatform)rrr[zPlatform | Nonerorr)roArch)rMapping[_T_co, Union[_T, Omit]]rrrozDict[_T_co, _T]) __future__rrrbrxr^rJrEr r[r email.utilstypesrrtypingrrrr r r r r rrrrrrrtyping_extensionsrrrrgrrrrrrr_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 getLoggerrqrSrurTrVrWrXrZr[ httpx._configr\r ImportErrorr^rwrrrrrPrrrrDefaultHttpxClientrrrEDefaultAsyncHttpxClientrHrrrr*rrrdrTrrrrrrrerkrhrs" "<;  8(PO+UU IH 0'g''1^1 K': ; \)= >  T]4( :VC[ 1{3/?@ M-Q B-6|WR[-6`+a8B<+a\$WR^,$N#gHRL'"+#gLuU\\5CTCT5T/UV +5kRUFV9V3WX[878[8| #%,,#-/`9Ju||VC[89`9F#u00##//75L9Z 1 1;s3C CDL9b$( $""&7@)2" """ "  "  "5"'""Jc4i $$      'T 4$$ Y GH HI6 X ) X ) X XW< - ' -sL99 M  M