EjvUddlmZddlZddlZddlZddlZddlZddlZddlZddl 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@mAZAmBZBd dlCmDZDmEZEmFZFmGZGmHZHmIZId dlJmKZKmLZLd dlMmNZNmOZOmPZPmQZQd dlRmSZSmTZTmUZUmVZVd dlWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^d dl_m`Z`maZambZbmcZcd dl+mdZdmeZemfZfmgZgd dlhmiZiejekZldemd<eddZneddZoedZpedd Zqed!e`eZred"ebeZserdd#ltmuZvn dd#ltmuZvGd%d&ZxGd'd(eNeepZyGd)d*eyepeepZzGd+d,eepeofZ{Gd-d.eyepeepZ|ed/ee$je$jfZed0ee`eebefZGd1d2eeefZGd3d4e$jZer e$jZneZGd5d6eZGd7d8ee$je`efZGd9d:e$jZer e$jZneZGd;dee$jebefZddddde2e2d? dNd@ZGdAdBZeee dCfZdOdDZeHdEdPdFZGdGdHZeee dIfZdQdJZdQdKZdRdLZ dSdMZy#ew$r e7d$ZvYwxYw)T) 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 HttpxSendArgsAsyncTransportRequestOptionsModelBuilderProtocol)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 V/var/www/html/peoplehubportal/venv/lib/python3.12/site-packages/openai/_base_client.py__init__zPageInfo.__init__z cyrcrd)rfras rgrhzPageInfo.__init__rirjr_rac ||_||_yrcrl)rfr_ras rgrhzPageInfo.__init__s  rjN)r_rreturnNone)rar$rnro)r_r^rar`rnro)__name__ __module__ __qualname____doc____annotations__rrhr!rdrjrgr]r]qs               (#, !   rjr]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*$$&""$D00rjcyrcrdrfs rgr|zBasePage.next_page_info rjcyrcrdrs rgr{zBasePage._get_page_itemsrrjctjtt|jj j |j Src)httpx QueryParamsrrrwramergeres 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) r8rw_strip_raw_response_header isinstancerar'r_r copy_withdictstr ValueError)rfinfooptionsrar_s rg_info_to_optionszBasePage._info_to_optionssT]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455rjNrnbool)rnzOptional[PageInfo])rnz Iterable[_T])r_rrnzhttpx.QueryParams)rr]rnr;) rprqrrrsrrwrtryr~r|r{rrrdrjrgrvrvs< %0MH!1"}FH$1   T6rjrvcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseSyncPage SyncAPIClient_clientc.||_||_||_yrcryrrw)rfclientmodelrs rg_set_private_attributesz$BaseSyncPage._set_private_attributes    rjc#hK|jD]}|jD]}|ywrc iter_pagesr{rfpageitems rg__iter__zBaseSyncPage.__iter__s9OO% 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_listry __class__rfrrs rgrzBaseSyncPage.get_next_pagesZ""$k ''-||--dkkX_-``rjN)rrrrxrr;rnro)rnz Iterator[_T])rfrSrnzIterator[SyncPageT])rfrSrnrS) rprqrrpydanticrrrtrrrrrdrjrgrrsR1X113G]3   %    $ arjrc@eZdZ ddZddZddZd dZy) AsyncPaginatorc<||_||_||_||_yrc)ryrrw _page_cls)rfrrpage_clsrs rgrhzAsyncPaginator.__init__s    !rjc>|jjSrc) _get_page __await__rs rgrzAsyncPaginator.__await__s~~))++rjcKdfd }|j_jjjjd{S7w)Ncl|jjjj|S)N)rrr)rryrwr)resprfs rg_parserz)AsyncPaginator._get_page.._parsers2  ( (kk || )  Krj)rrUrnrU)rw post_parserrrequestr)rfrs` rgrzAsyncPaginator._get_pages? %, !\\))$..$--HHHHsA AAAchKtt|d{}|23d{}|77 6ywrc)rrUrs rg __aiter__zAsyncPaginator.__aiter__s< J   $J  $s$2, 20.0202N) rAsyncAPIClientrr;rType[AsyncPageT]rrxrnro)rnz Generator[Any, None, AsyncPageT])rnrUrnzAsyncIterator[_T])rprqrrrhrrrrdrjrgrrsG " "% "# "  "  ", IrjrcjeZdZUejZded< ddZd dZd dZ d dZ y) BaseAsyncPagerrc.||_||_||_yrcr)rfrrrs rgrz%BaseAsyncPage._set_private_attributesrrjczK|j23d{}|jD]}| $76ywrcrrs rgrzBaseAsyncPage.__aiter__'sB//+  $,,.    +s;979;9;ctK|} ||jr|jd{}ny07wrcrrs rgrzBaseAsyncPage.iter_pages,s=J!!#!//11 2s ,868cK|j}|s td|j|}|jj |j |j |d{S7wrrrs rgrzBaseAsyncPage.get_next_page5sd""$k ''-\\33DKKdnn^e3ffffsA$A-&A+'A-N)rrxrrrr;rnror)rfrUrnzAsyncIterator[AsyncPageT])rfrUrnrU) rprqrrrrrrtrrrrrdrjrgrrsR2h224G^4   %     grjr _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) rfversionbase_urlrrrlimits transportproxiesrrs rgrhzBaseClient.__init__Qs  55c(mD&   #-3)/R+F(#' *.  b  rjcz|jjdr|S|j|jdzS)N/raw_path)rendswithrres rgrz"BaseClient._enforce_trailing_slashqs3 <<  &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_responsevs   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 "##rjc@||S|j|jSrc)get_max_retriesr)rfremaining_retriesrs rg_remaining_retrieszBaseClient._remaining_retriess' %6$A pwG^G^_c_o_oGpprjc@|jxsi}t|j|}|j||t j |}|j }|rB|jjdk7r%||vr!|jxs|j||<|S)Nget) headers_merge_mappingsdefault_headers_validate_headersrr%rmethodloweridempotency_key_idempotency_key)rfrr headers_dictridempotency_headers rg_build_headerszBaseClient._build_headerss .B&t';';^L  |^<-- -!55 '.."6"6"8E"AFX`gFg*1*A*A*\TEZEZE\G& '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)rJrs rg_make_sse_decoderzBaseClient._make_sse_decoders |rjc$tjtjr!tj dt |di}|j }|jW|tt|j}n:t|rt||j}ntdt|d|j|}t|j|j }|j#d}|_|j%drNd|vr|j'd|r7t)|st+d t|d |j-||d <|j.j0d |t3|j4t6r |j4n |j4|j8|j;|j<|r6|j>jAttBtDtFf|nd||jHd |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_rarfilesrd)%rR isEnabledForloggingDEBUGdebugr9 json_data extra_jsonrr"r7rrtyper default_queryrar startswithpopr2r_serialize_multipartformr build_requestrrr'r rr_qs stringifyr rrr)rfrkwargsr#rra content_types rg_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*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)r+stringify_itemsrr3append)rfrr} serializedkeyvalueexistings rgr)z#BaseClient._serialize_multipartforms'' # (  )+  4JC!~~c*H"' 3x &#+U"3 3% 4(rjct|js|St|j}|jtt }t|r||_t tt|S|Src) r5rrr(rGr!rr r()rfcast_torroverride_cast_tos rg_maybe_override_cast_toz"BaseClient._maybe_override_cast_tos^(Nw' #;;'> J $ %%GOY)9: :rjcF|jjtdk(S)Nstream)rrrFrfrs rg_should_stream_response_bodyz'BaseClient._should_stream_response_body#s""#678CCrjc|ttdS|turtt|S tj|r1t |t r!tt|j||S|jrttt||Sttt||S#tj$r}t|||d}~wwxYw)N)rr)type_r7)rr)rr(objectinspectisclass issubclassr1buildrr<r=rValidationErrorrP)rfrr:rerrs rg_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&B4B44CCCctSrcrrs rgr+z BaseClient.qs>s }rjcyrcrdrs rg custom_authzBaseClient.custom_authBsrjciSrcrdrs rg auth_headerszBaseClient.auth_headersFs rjcrdd|jd|j|j|jS)Nzapplication/json)Acceptrz User-Agent) user_agentplatform_headersrOrrs rgrzBaseClient.default_headersJsN).// ##%    ""   rjci|jSrc)rrs rgr&zBaseClient.default_queryUs     rjcy)zaValidate the given default headers and custom headers. Does nothing by default. Nrd)rfrrs rgr zBaseClient._validate_headers[s rjcL|jjd|jS)Nz/Python )rrprrs rgrRzBaseClient.user_agentfs"..))*(4==/BBrjc|jSrc)rrs rgrzBaseClient.base_urljs ~~rjcz|jt|tr ||_yt||_yrc)rrrrres rgrzBaseClient.base_urlns-55ZS=Qc`WZ[^W_`rjcDt|j|jS)N)platform)rSrrrs rgrSzBaseClient.platform_headersrs  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-msiz 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_headerxs  # .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?)rrrgminrEpowrCr) rfrrrbr retry_after nb_retries sleep_secondsjitterrs rg_calculate_retry_timeoutz#BaseClient._calculate_retry_timeouts --d.>.>? 445EF  "q;'<"'< (=!#44 /#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)rrrRr"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-)uuiduuid4rs rgr zBaseClient._idempotency_keys(77rj)rrr str | URLrrrrrzfloat | Timeout | NonerrrrrrrMapping[str, str] | NonerMapping[str, object] | Nonernro)r_rrnr)rhttpx.ResponsernrM)rrrrCrr|rnz_exceptions.APIStatusError)r Optional[int]rr;rnr)rr;rnz httpx.Headers)r_rrnr)rnzSSEDecoder | SSEBytesDecoder)rr;rn httpx.Request)rzMapping[object, object]rndict[str, object])r:type[ResponseT]rr;rnr)rr~rnr)rrCr:rrr|rnr()rnr)rnzhttpx.Auth | None)rnzdict[str, str])rnzdict[str, str | Omit])rnr)rr%rr%rnrornr)rnr)r_z URL | strrnro)rnDict[str, str]rc)rbOptional[httpx.Headers]rnz float | None)rrrr;rbrrnr\)rr|rnr)#rprqrrrtrrDrBrhrrrrrrrr/r)r<r@rJpropertyr+rMrOrr&r rRrsetterrSrgrprur rdrjrgrrDs MN (( !!11!%%##8<5</*94848  &*   (5%12 @; N N N,$$ $ ! $ $ $q(q%q q  8 $8  8 t<"DTT! T ! T  T0         CC__aaH /L59 ..%.2 .  ..!F8rjrc eZdZdfd ZxZS)_DefaultHttpxClientc |jdt|jdt|jddt|di|yNrrfollow_redirectsTrd setdefaultrBrHsuperrhrfr-rs rgrhz_DefaultHttpxClient.__init__E)_5($=>,d3 "6"rjr-rrnrorprqrrrh __classcell__rs@rgrr ##rjrceZdZddZy)SyncHttpxClientWrappercD |jy#t$rYywxYwrc)closerrs rg__del__zSyncHttpxClientWrapper.__del__s"  JJL   s  Nrnrorprqrrrrdrjrgrrsrjrc ,eZdZUded<dZded<eeddddddd d1fdZd2dZd3d Z d4d Z d5d Z d6d Z d7d Z e d8 d9dZe d8dd d:dZe d8ddd d;dZ d8ddd ddZ d?dZ d@dZeidd dAdZeid dBdZeidd dCdZiddd dCd Zediddd! dDd"Zedidd# dEd$Zediddd% dFd&Zdidddd' dFd(Zdid) dGd*Zddid+ dHd,Zdid) dGd-Zdid.d/ dId0ZxZS)Jrz 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)warningswarnDeprecationWarningrrHr5rHTTPX_DEFAULT_TIMEOUTrBrrClientrr%rrhrr&rr) rfrrrrrrrrrrrrs rgrhzSyncAPIClient.__init__s\   MMz+  & !qrr.F  MMm+  & !dee   MMk+  & !bcc {226KK%--)  ":k5<<+Pabfgrbsatu  '*#%)(C  # &<'*!'  rjc.|jjSrcrrrs rgrzSyncAPIClient.is_closedM||%%%rjcRt|dr|jjyy)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrs rgrzSyncAPIClient.closePs# 4 # LL    $rjc|Srcrdrs rg __enter__zSyncAPIClient.__enter__Zs rjc$|jyrcrrfexc_typeexcexc_tbs rg__exit__zSyncAPIClient.__exit__]s rjcyz#Hook for mutating the given optionsNrdrfrs rg_prepare_optionszSyncAPIClient._prepare_optionses 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. Nrdr?s rg_prepare_requestzSyncAPIClient._prepare_requestlsrjcyrcrdrfr:rrr> stream_clss rgrzSyncAPIClient.requestw rjFr>cyrcrd)rfr:rrr>s rgrzSyncAPIClient.request rjr>rcyrcrdrs rgrzSyncAPIClient.requestrrjc.|j|||||SN)r:rr>rr_requestrs rgrzSyncAPIClient.requests)}}!/   rjc |j||}|j||j||}|j|}|j |i}|j |j |d<t jd|j|j |jj|fd|xs|j|i|} t jd |j|j| j&| j(| j*t jd| j*j-d | j/|j?||| ||S#tj$r_} t jdd|dkDr|j|||||d cYd} ~ St jd t!|| d} ~ wt"$r_} t jd d|dkDr|j|||||d cYd} ~ St jd t%|| d} ~ wwxYw#tj0$r} t jdd|dkDre|j3| j4rJ| j4j7|j|||| j4j*||cYd} ~ S| j4j8s| j4j;t jd|j=| j4dd} ~ wwxYw)NauthzSending HTTP Request: %s %sr>r"Encountered httpx.TimeoutExceptionTexc_inforr>rrbRaising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz x-request-id!Encountered httpx.HTTPStatusErrorrRe-raising status errorr:rrr>r) r<rrr/rrMrRr"r r_rsendr@rTimeoutException_retry_requestrNrrOr reason_phraserrraise_for_statusHTTPStatusErrorrurrrreadr_process_response) rfr:rrr>rretriesrr-rrIs rgrzSyncAPIClient._requests..w@ g&))*;WE%%g. g& "    '!--F6N /M# ?(t||((S!B!B7!B!SHH - NN KK   " "      "H$4$4$8$8$HI P  % % '.%%! &  C%% < II:TI J{**!)%) + II- .!'2 ; ? II-I ={**!)%) + II0 1$W53 > ?8$$ P II9DI I{t11#,,? ""$**LL((!) +<<)) !!# II/ 077 E4 O) Psb!3E6I6I 2G#;I"G## I/2I !I'"I  IM $A;MM %A!MM c,|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)rRr"rprr_rasleepr rfrr:rrbr>r remainingrs rgrzSyncAPIClient._retry_requests&) > IIn % II' 3// 7DTU 7gN 7}}'!   rjc |jjjtdk(rt t t ||||||St|xs|}tj|rft|trVt|tstdtd|t d|}t t |||t||||S|tj k(rt t |St||t d||||}t#|jjjtrt t |S|j%S)Nrrrawrr:r>rr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r)rrrrFrr(rQrrDrErFr?r>rrArResponserparse rfr:rrr>rorigin response_cls api_responses rgrzSyncAPIClient._process_response/sS    # # ' '(; < F! #!)#   G$/ ??6 "z&/'Jfk2"CK=P[\b[c dee ._parserns&  ( ( )  KrjFr)rrSrnrS)rr)rfrrrrs`` ` rgrzSyncAPIClient._request_api_lisths'  &||D'%|88rjrr>cyrcrdrfpathr:rr>s rgrzSyncAPIClient.getzrrjrcyrcrdrfrr:rr>rs rgrzSyncAPIClient.getrrjrrcyrcrdrs rgrzSyncAPIClient.getrrjrr>rc xtjdd|d|}tt|j ||||SNr)r r_rrd)r; constructrr(rrfrr:rr>roptss rgrzSyncAPIClient.gets?#,,OEtOwOIt||GT&U_|`aarj)rrrr>cyrcrd)rfrr:rrrr>s rgpostzSyncAPIClient.posts rj)rrrcyrcrdrfrr:rrrr>rs rgr zSyncAPIClient.post rj)rrrrcyrcrdrs rgr zSyncAPIClient.postrrj)rrrr>rc tjdd||t|d|}tt|j ||||SNr r r_r#rrrd)r;rrrr(r) rfrr:rrrr>rr s rgr zSyncAPIClient.postsP#,, tt>%;P T[ It||GT&U_|`aarjrrcXtjdd||d|}|j||SNpatchr r_r#rdr;rrrfrr:rrr s rgrzSyncAPIClient.patchs3#,,aGQUaY`a||GT**rjrrrc ltjdd||t|d|}|j||SNputrrd)r;rrrrfrr:rrrr s rgrzSyncAPIClient.putsB#,, dd.:O SZ ||GT**rjcXtjdd||d|}|j||SNdeleterrdrrs rgr"zSyncAPIClient.deletes3#,,bH$RVbZab||GT**rjrrrr cZtjd|||d|}|j|||SNrrdr;rrrfrrrrrr r s rg get_api_listzSyncAPIClient.get_api_list7#,,`FPT`X_`%%eT488rj)rrrryrrr!float | Timeout | None | NotGivenrzTransport | Nonerrr Limits | Nonerzhttpx.Client | Nonerrzrr{rrrnrorrrfrVrnrVrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonernrorr;rnrorr~rnrorc) r:Type[ResponseT]rr;rr}r> Literal[True]rzType[_StreamT]rnrY) r:r0rr;rr}r>Literal[False]rnr() r:r0rr;rr}r>rrzType[_StreamT] | NonernResponseT | _StreamT) r:r0rr;rr}r>rrtype[_StreamT] | Nonernr3) r:r0rr;r int | Noner>rrr4rnr3)rr;r:r0rrrbhttpx.Headers | Noner>rrr4rnr3 r:r0rr;rr|r>rrz1type[Stream[Any]] | type[AsyncStream[Any]] | Nonernr()r Type[object]rType[SyncPageT]rr;rnrS rrr:r0rr0r>r2rnr() rrr:r0rr0r>r1rtype[_StreamT]rnrY) rrr:r0rr0r>rrr4rnr3)rrr:r0r Body | Nonerr0rRequestFiles | Noner>r2rnr()rrr:r0rr<rr0rr=r>r1rr;rnrY)rrr:r0rr<rr0rr=r>rrr4rnr3 rrr:r0rr<rr0rnr( rrr:r0rr<rr=rr0rnr()rrrr8rr9rr<rr0r rrnrS)rprqrrrtrrDr!rhrrrrrrrrrrrrrr rrr"r(rrs@rgrrs 4818/5>&*'+ $+/3748S S  S  S 3 S $S %S S )S 1S 2S &*S  S j&!,"%   $      ,0     %  )    #        ,0  "'    % )        ,0  ,0     %  )    *       ,0  ,0   % )    *   "c !c % c & c  c *c  c J $ !   /   *   >7$!7$% 7$ ! 7$  7$F7$ 7$r999% 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@rgrArArrjrAceZdZddZy)AsyncHttpxClientWrapperc tjj|jy#t$rYywxYwrc)asyncioget_running_loop create_taskacloserrs rgrzAsyncHttpxClientWrapper.__del__+s6   $ $ & 2 24;;= A   s14 AANrrrdrjrgrDrD*srjrDc &eZdZUded<dZded<eeddddddd d2fdZd3dZd4d Z d5d Z d6d Z d7d Z d8d Z eddd d9dZedd d:dZeddd d;dZdddd d;dZ ddZ d?dZeidd d@dZeid dAdZeidd dBd Ziddd! dBd"Zeddidd# dCd$Zeddid% dDd&Zeddidd' dEd(Zddiddd) dEd*Zdid+ dFd,Zddid% dGd-Zdid+ dFd.Zdid/d0 dHd1ZxZS)Irzhttpx.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)rrrrrHr5rrrBrr AsyncClientrr%rrhrr&rDr) rfrrrrrrrrrrrrs rgrhzAsyncAPIClient.__init__7s^   MMz+  & !qrr.F  MMm+  & !dee   MMk+  & !bcc {226KK%--)  ":k5CTCT+Ufgklwgxfyz  '*#%)(C  # &='*!'  rjc.|jjSrcrrs rgrzAsyncAPIClient.is_closedrrjcTK|jjd{y7w)rN)rrIrs rgrzAsyncAPIClient.closes ll!!###s (&(cK|Swrcrdrs rg __aenter__zAsyncAPIClient.__aenter__s  sc@K|jd{y7wrcrrs rg __aexit__zAsyncAPIClient.__aexit__s jjls c Kywrrdrs rgrzAsyncAPIClient._prepare_optionss c Kywrrdr?s rgrzAsyncAPIClient._prepare_requests rTF)r>rc Kywrcrd)rfr:rr>rs rgrzAsyncAPIClient.request  rT)rc Kywrcrdrfr:rr>rrs rgrzAsyncAPIClient.request  rT)rrc KywrcrdrYs rgrzAsyncAPIClient.requestrZrT)r>rrcJK|j|||||d{S7wrrrYs rgrzAsyncAPIClient.requests7]]!/ #    s #!#c K|j!ttd{|_|j||}|j |d{|j ||}|j |}|j|d{i}|j|j|d< |jj|fd|xs|j|i|d{} tjd |j(|j*| j,| j. | j1|jC||| ||d{S7:7 77|#tj$rh} tjdd|dkDr%|j!|||||dd{7cYd} ~ Stjd t#|| d} ~ wt$$rh} tjd d|dkDr%|j!|||||dd{7cYd} ~ Stjd t'|| d} ~ wwxYw#tj2$r} tjd d|dkDrw|j5| j6r\| j6j9d{7|j!|||| j6j:||d{7cYd} ~ S| j6j<s#| j6j?d{7tjd|jA| j6dd} ~ wwxYw7w)Nrr>rrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)"rr4 get_platformr<rrr/rrMrrr@rrrRr"rrNrrOr r_rrrrrurrIrrareadrr) rfr:rr>rrrrr-rrIs rgrzAsyncAPIClient._requestsI >> !$:8L#9#;;DN..w@##G,,,))*;WE%%g.##G,,, "    '!--F6N# ?.T\\..S!B!B7!B!SHH )7>>7;;H\H\^f^t^t  P  % % '.++! ,   ]< - - %% < II:TI J{!00!)%) 1 II- .!'2 ; ? II-I ={!00!)%) 1 II0 1$W53 > ?,$$ P II9DI I{t11#,,?ll))+++!00LL((!) 1<<))ll((*** II/ 077 E4 O) P, s$M3E /M3E#;M3E&!M356E*+E(,E*0AM32IM3M0M3#M3&M3(E**I=6G 3F64G 8I9M3>"G  I,6I"H%#I'I(M3-"IIM3M-+AM(?K3M(3K64M(8M-9M3>3M(1L426M((M--M3c\K|dz }|dk(rtjdntjd||j|||}tjd|j|t j |d{|j|||||d{S7"7wr)rRr"rprr_anyiorrrs rgrzAsyncAPIClient._retry_requestIs&) > IIn % II' 3// 7DTU 7gNkk'"""]]'! #    # s$BB,B(B,#B*$B,*B,c K|jjjtdk(rt t t ||||||St|xs|}tj|rbt|trRt|tstdtd|t d|}t d|||t||||S|tj k(rt t |St||t d||||}t#|jjjtrt t |S|j%d{S7w)Nrrrrrrr(r)rrrrFrr(rQrrDrErFr?r@rrArrrrrs rgrz AsyncAPIClient._process_responsefs`    # # ' '(; < F! #!)#   G$/ ??6 "z&/'Jf&67"CDTCUU`ag`h ijj c Kywrcrd)rfrr:rrrr>s rgr zAsyncAPIClient.posts  rTrc Kywrcrdrfrr:rrrr>rs rgr zAsyncAPIClient.post  rT)rrrrc Kywrcrdrjs rgr zAsyncAPIClient.postrkrT)rrrr>rc Ktjdd||t|d{d|}|j||||d{S7&7wrr;rr r) rfrr:rrrr>rr s rgr zAsyncAPIClient.posts^#,, ttAUV[A\;\ `g \\'4:\VVV<]Vs!"AA !AA A ArctKtjdd||d|}|j||d{S7wrrrs rgrzAsyncAPIClient.patchs=#,,aGQUaY`a\\'40000 /868c Ktjdd||t|d{d|}|j||d{S7#7wrrnrs rgrzAsyncAPIClient.putsX#,, dd@TUZ@[:[ _f \\'4000;\0s!"A AA A A  A ctKtjdd||d|}|j||d{S7wr!rrs rgr"zAsyncAPIClient.delete(s=#,,bH$RVbZab\\'40000rprr#cZtjd|||d|}|j|||Sr%r&r's rgr(zAsyncAPIClient.get_api_list3r)rj)rrrryrrrrrr*rzAsyncTransport | Nonerrrr+rzhttpx.AsyncClient | Nonerrzrr{rnrorrr,r-r.r/) r:r0rr;r>r2rr}rnr() r:r0rr;r>r1rtype[_AsyncStreamT]rr}rnrZ) r:r0rr;r>rrtype[_AsyncStreamT] | Nonerr}rnResponseT | _AsyncStreamT) r:r0rr;r>rrrurr5rnrv)rr;r:r0rrrbr6r>rrrurnrvr7)rrxrrrr;rnAsyncPaginator[_T, AsyncPageT]r:) rrr:r0rr0r>r1rrtrnrZ) rrr:r0rr0r>rrrurnrv)rrr:r0rr<rr=rr0r>r2rnr()rrr:r0rr<rr=rr0r>r1rrtrnrZ)rrr:r0rr<rr=rr0r>rrrurnrvr>r?)rrrrxrrrr<rr0r rrnrw)rprqrrrtrrDr!rhrrrPrRrrrrrrrrrr rrr"r(rrs@rgrr3sr 9=6=/5>+/'+ $043748S S  S &* S  S 3S )S %S S .S 1S 2S  S j&$,"%   $      "'+/    %   )     ,0     %    (  )       26+/     %    /  )   #    15+/   %   /  )  # "`  ` %`  ` / ` &`  #` D $ !   /   /  # :7*!7*% 7* ! 7*  7*F7* 7*rXXX% 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_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$rarr r)rr*rrr'r5)rxryrzr{r rrrs rgmake_request_optionsr}As!G *  $Z <  !Hw{{8R8HKH gx ($ "%4!" !,  Nrjc&eZdZddZeddZy) OtherPlatformc||_yrcnamerfrs rgrhzOtherPlatform.__init__g  rjc d|jS)NzOther:rrs rg__str__zOtherPlatform.__str__j {##rjNrrrnrorrprqrrrhrrrdrjrgrrf$$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)rZsystemr rdistroidr)r platform_name distro_ids rgr^r^~s"((* ))+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)rr^get_architectureget_python_runtimeget_python_version)rrZs rgrSrSs;%'.h8,.9 0 2313'9';  rjc&eZdZddZeddZy) OtherArchc||_yrcrrs rgrhzOtherArch.__init__rrjc d|jS)Nzother:rrs rgrzOtherArch.__str__rrjNrrrrdrjrgrrrrjr)x32x64armarm64unknowncJ tjS#t$rYywxYwNr)rZpython_implementationrrdrjrgrrs(--//   ""cJ tjS#t$rYywxYwr)rZpython_versionrrdrjrgrrs(&&(( rc tj\}}tjj}|dvry|dk(ry|dk(ry|dk(ry|r t |Sy#t$rYywxYw) Nr)raarch64rrx86_64r32bitr)rZ architecturemachiner rr)python_bitness_rs rgrrs$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#)obj1obj2mergedr6r7s rgrrs?  F)/ W:3z%QU?VCJ WW Ws<<)rx Query | NoneryzHeaders | Nonerzrr{r<r rrz'float | httpx.Timeout | None | NotGivenrzPostParser | NotGivenrnr0)rnPlatform)rrrZzPlatform | Nonernrr)rnArch)rMapping[_T_co, Union[_T, Omit]]rrrnzDict[_T_co, _T]) __future__rrrarwr]rFrDr rZr email.utilstypesrrtypingrrrr r r r r rrrrrrrtyping_extensionsrrrrarrrrrrr_qsr_filesrr _typesr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1_utilsr2r3r4r5r6r7_compatr8r9_modelsr:r;r<r= _responser>r?r@rA _constantsrBrCrDrErFrGrH _streamingrIrJrKrLrMrNrOrP_legacy_responserQ getLoggerrprRrtrSrUrVrWrYrZ httpx._configr[r ImportErrorr]rvrrrrrLrrrrDefaultHttpxClientrrrADefaultAsyncHttpxClientrDrr}rrr^rSrrrrrrrdrjrgrs" "<;  8&PO+UU IH 0'g''1^1 K': ; \)= >  T]4( :VC[ 1{3/?@ M-Q  F.6|WR[.6b+a8B<+a\$WR^,$N#gHRL'"+#gLuU\\5CTCT5T/UV +5kRUFV9V3WXQ878Q8h #%,,#-/_9Ju||VC[89_9D#u00##//75K9Z 1 1;s3C CDK9`$( $""&7@)2" """ "  "  "5"'""J$$      'T 4$$ Y GH HI6 X ) X ) X X{; - ' -sL'' L87L8