OYhfNrUddlmZddlZddlZddlZddlZddlZddlZddlZddl 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 dlCmDZDmEZEmFZFmGZGmHZHd dlImJZJmKZKd dlLmMZMmNZNmOZOmPZPd dlQmRZRmSZSmTZTmUZUd dlVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]d dl^m_Z_m`Z`maZambZbd dl+mcZcmdZdmeZemfZfd dlgmhZhejejZkdeld<eddZmeddZnedZoedd Zped!e_eZqed"eaeZrerdd#lsmtZun dd#lsmtZuGd%d&ZwGd'd(eMeeoZxGd)d*exeoeeoZyGd+d,eeoenfZzGd-d.exeoeeoZ{ed/ee$je$jfZ~ed0ee_eeaefZGd1d2ee~efZGd3d4e$jZer e$jZneZGd5d6eZGd7d8ee$je_efZGd9d:e$jZer e$jZneZGd;dee$jeaefZddddde2e2d? dNd@ZGdAdBZeee dCfZdOdDZeGdEdPdFZGdGdHZeee dIfZdQdJZdQdKZdRdLZ dSdMZy#ev$r e7d$ZuYwxYw)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_listis_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/var/www/feuerwehr-webapp/venv/lib/python3.12/site-packages/openai/_base_client.py__init__zPageInfo.__init__z cyrbrc)rer`s rfrgzPageInfo.__init__rhrir^r`c ||_||_yrbrk)rer^r`s rfrgzPageInfo.__init__s  riN)r^rreturnNone)r`r$rmrn)r^r]r`r_rmrn)__name__ __module__ __qualname____doc____annotations__rrgr!rcrirfr\r\qs               (#, !   rir\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)reitemss rf has_next_pagezBasePage.has_next_pages*$$&""$D00ricyrbrcres rfr{zBasePage.next_page_info ricyrbrcrs rfrzzBasePage._get_page_itemsrrictjtt|jj j |j Srb)httpx QueryParamsrrrvr`mergerds rf_params_from_urlzBasePage._params_from_urls3  c4==+?+?!@AGG SSrict|j}|jt|jt s!i|j|j|_|St|j t sc|j|j }|j j|}t|j|_t||_|Std)N)r`zUnexpected PageInfo state) r7rv_strip_raw_response_header isinstancer`r'r^r copy_withdictstr ValueError)reinfooptionsr`r^s rf_info_to_optionszBasePage._info_to_optionssT]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455riNrmbool)rmzOptional[PageInfo])rmz Iterable[_T])r^rrmzhttpx.QueryParams)rr\rmr:) rorprqrrrrvrsrxr}r{rzrrrcrirfrurus< %0MH!1"}FH$1   T6rirucjeZdZUejZded< ddZd dZd dZ d dZ y) BaseSyncPage SyncAPIClient_clientc.||_||_||_yrbrxrrv)reclientmodelrs rf_set_private_attributesz$BaseSyncPage._set_private_attributes    ric#hK|jD]}|jD]}|ywrb iter_pagesrzrepageitems rf__iter__zBaseSyncPage.__iter__s9OO% D,,.    s02c#^K|} ||jr|j}ny'wrbr} get_next_pagerers rfrzBaseSyncPage.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_listrx __class__rerrs rfrzBaseSyncPage.get_next_pagesZ""$k ''-||--dkkX_-``riN)rrrrwrr:rmrn)rmz Iterator[_T])rerRrmzIterator[SyncPageT])rerRrmrR) rorprqpydanticrrrsrrrrrcrirfrrsR1X113G]3   %    $ arirc@eZdZ ddZddZddZd dZy) AsyncPaginatorc<||_||_||_||_yrb)rxrrv _page_cls)rerrpage_clsrs rfrgzAsyncPaginator.__init__s    !ric>|jjSrb) _get_page __await__rs rfrzAsyncPaginator.__await__s~~))++ricKdfd }|j_jjjjd{S7w)Ncl|jjjj|S)N)rrr)rrxrvr)respres rf_parserz)AsyncPaginator._get_page.._parsers2  ( (kk || )  Kri)rrTrmrT)rv post_parserrrequestr)rers` rfrzAsyncPaginator._get_pages? %, !\\))$..$--HHHHsA AAAchKtt|d{}|23d{}|77 6ywrb)rrTrs rf __aiter__zAsyncPaginator.__aiter__s< J   $J  $s$2, 20.0202N) rAsyncAPIClientrr:rType[AsyncPageT]rrwrmrn)rmz Generator[Any, None, AsyncPageT])rmrTrmzAsyncIterator[_T])rorprqrgrrrrcrirfrrsG " "% "# "  "  ", IrircjeZdZUejZded< ddZd dZd dZ d dZ y) BaseAsyncPagerrc.||_||_||_yrbr)rerrrs rfrz%BaseAsyncPage._set_private_attributesrriczK|j23d{}|jD]}| $76ywrbrrs rfrzBaseAsyncPage.__aiter__'sB//+  $,,.    +s;979;9;ctK|} ||jr|jd{}ny07wrbrrs rfrzBaseAsyncPage.iter_pages,s=J!!#!//11 2s ,868cK|j}|s td|j|}|jj |j |j |d{S7wrrrs rfrzBaseAsyncPage.get_next_page5sd""$k ''-\\33DKKdnn^e3ffffsA$A-&A+'A-N)rrwrrrr:rmrnr)rerTrmzAsyncIterator[AsyncPageT])rerTrmrT) rorprqrrrrsrrrrrcrirfrrsR2h224G^4   %     grir _HttpxClientT_DefaultStreamTc<eZdZUded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<dZded<eeddd d3dZd4dZ d5dZ d6dZ d7dZ d8dZ d9dZ d:d Z d;d!Zdd$Z d?d%Zed@d&ZedAd'ZedBd(ZedCd)Z dDd*ZedEd+ZedFd,Zej8dGd-ZdHd.ZdIdJd/Z dI dKd0ZdLd1Z dEd2Z!y)M 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|_ | 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 TypeError) reversionbase_urlrrrlimits transportproxiesrrs rfrgzBaseClient.__init__Qs  55c(mD&   #-3)/R+F(#'  b  ricz|jjdr|S|j|jdzS)N/raw_path)rendswithrrds rfrz"BaseClient._enforce_trailing_slashps3 <<  &J}}cllT&9}::ricJ|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)rerrerr_msgerr_texts rf _make_status_error_from_responsez+BaseClient._make_status_error_from_responseus   h&A&AD$X%9%9$:;G}}**,HD Lzz(+()=)=(>c$H&&wTH&MM L"K X5I5I4J&K Ls'BB"!B"ctrb)NotImplementedError)rerrrs rfrzBaseClient._make_status_errors "##ric@||S|j|jSrb)get_max_retriesr)reremaining_retriesrs rf_remaining_retrieszBaseClient._remaining_retriess' %6$A pwG^G^_c_o_oGppric@|jxsi}t|j|}|j||t j |}|j }|rB|jjdk7r%||vr!|jxs|j||<|S)Nget) headers_merge_mappingsdefault_headers_validate_headersrr%rmethodloweridempotency_key_idempotency_key)rerr headers_dictridempotency_headers rf_build_headerszBaseClient._build_headerss .B&t';';^L  |^<-- -!55 '.."6"6"8E"AFX`gFg*1*A*A*\TEZEZE\G& 'rict|}|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)rer^ merge_urlmerge_raw_paths rf _prepare_urlzBaseClient._prepare_urlsZ H  $ $!]]33i6H6H6O6OPT6UUN==**N*C CrictSrb)rIrs rf_make_sse_decoderzBaseClient._make_sse_decoders |ric$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)rrrr^r`rfilesrc)%rQ isEnabledForloggingDEBUGdebugr8 json_data extra_jsonrr"r6rrtyperrr`r startswithpopr2r_serialize_multipartformr build_requestrrr'rrr^qs stringifyr rrr)rerkwargsr!rr` content_types rf_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--    ric|jj|d}i}|D]B\}}|j|}|s|||<t|r|j |<||g||<D|S)Nbrackets) array_format)r(stringify_itemsrr3append)rerr| serializedkeyvalueexistings rfr&z#BaseClient._serialize_multipartforms'' # (  )+  4JC!~~c*H"' 3x &#+U"3 3% 4(rict|js|St|j}|jtt }t|r||_t tt|S|Srb) r4rrr%rFr!rr r()recast_torroverride_cast_tos rf_maybe_override_cast_toz"BaseClient._maybe_override_cast_tos^(Nw' #;;'> J $ %%GOY)9: :ricF|jjtdk(S)Nstream)rrrErers rf_should_stream_response_bodyz'BaseClient._should_stream_response_body"s""#678CCric|ttdS|turtt|S tj|r1t |t r!tt|j||S|jrttt||Sttt||S#tj$r}t|||d}~wwxYw)N)rr)type_r4)rr)rr(objectinspectisclass issubclassr1buildrr;r<rValidationErrorrO)rerr7rerrs rf_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&B4B44CCCctSrbrrs rfr(z BaseClient.qs=s }ricyrbrcrs rf custom_authzBaseClient.custom_authAsriciSrbrcrs rf auth_headerszBaseClient.auth_headersEs ricrdd|jd|j|j|jS)Nzapplication/json)Acceptrz User-Agent) user_agentplatform_headersrLrrs rfrzBaseClient.default_headersIsN).// ##%    ""   ricy)zaValidate the given default headers and custom headers. Does nothing by default. Nrc)rerrs rfrzBaseClient._validate_headersTs ricL|jjd|jS)Nz/Python )rrorrs rfrOzBaseClient.user_agent_s"..))*(4==/BBric|jSrb)rrs rfrzBaseClient.base_urlcs ~~ricz|jt|tr ||_yt||_yrb)rrrrrds rfrzBaseClient.base_urlgs-55ZS=Qc`WZ[^W_`ric,t|jSrb)rPrrs rfrPzBaseClient.platform_headersks ..ric|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)reresponse_headersretry_ms_header retry_headerretry_date_tuple retry_dates rf_parse_retry_after_headerz$BaseClient._parse_retry_after_headerns  # .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?)rrrbminrDpowrBr) rerrr]r retry_after nb_retries sleep_secondsjitterrs rf_calculate_retry_timeoutz#BaseClient._calculate_retry_timeouts --d.>.>? 445EF  "q;'<"'< (=!#44 /#c:2FFX TFH_$&(!Q,w-A-ricP|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)rrrQr r)rershould_retry_headers rf _should_retryzBaseClient._should_retrys&..223CD & ( IIL M ' ) IIQ R   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M   3 & II68L8L M .!ric0dtjS)Nzstainless-python-retry-)uuiduuid4rs rfr zBaseClient._idempotency_keys(77ri)rrr str | URLrrrrrzfloat | Timeout | NonerrrrrrrMapping[str, str] | NonerMapping[str, object] | Nonermrn)r^rrmr)rhttpx.ResponsermrL)rrrr@rrwrmz_exceptions.APIStatusError)r Optional[int]rr:rmr)rr:rmz httpx.Headers)r^rrmr)rmzSSEDecoder | SSEBytesDecoder)rr:rm httpx.Request)rzMapping[object, object]rmzdict[str, object])r7type[ResponseT]rr:rmrz)rryrmr)rr@r7rzrrwrmr()rmr)rmzhttpx.Auth | None)rmzdict[str, str])rmzdict[str, str | Omit])rr%rr%rmrnrmr)rmr)r^z URL | strrmrn)rmDict[str, str]rb)r]Optional[httpx.Headers]rmz float | None)rrrr:r]r}rmrW)rrwrmr)"rorprqrsrrCrArgrrrrrrrr,r&r9r=rGpropertyr(rJrLrrrOrsetterrPrbrkrpr rcrirfrrDs MN (( !!11!%%##8<5</*94848  &*   (5%12 >; N N N,$$ $ ! $ $ $q(q%q q  8 $8  8 t<"DTT! T ! T  T0        CC__aa/ /L59 ..%.2 .  ..!F8rirc eZdZdfd ZxZS)_DefaultHttpxClientc |jdt|jdt|jddt|di|yNrrfollow_redirectsTrc setdefaultrArGsuperrgrer*rs rfrgz_DefaultHttpxClient.__init__E)_5($=>,d3 "6"rir*rrmrnrorprqrg __classcell__rs@rfrr ##rirceZdZddZy)SyncHttpxClientWrappercD |jy#t$rYywxYwrb)closerrs rf__del__zSyncHttpxClientWrapper.__del__s"  JJL   s  Nrmrnrorprqrrcrirfrrsrirc ,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)warningswarnDeprecationWarningrrGr4rHTTPX_DEFAULT_TIMEOUTrArrClientrr#rrgrr&rr) rerrrrrrrrrrrrs rfrgzSyncAPIClient.__init__s\   MMz+  & !qrr.F  MMm+  & !dee   MMk+  & !bcc {226KK%--)  ":k5<<+Pabfgrbsatu  '*#%)(C  # &<'*!'  ric.|jjSrbrrrs rfrzSyncAPIClient.is_closedC||%%%ricRt|dr|jjyy)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrs rfrzSyncAPIClient.closeFs# 4 # LL    $ric|Srbrcrs rf __enter__zSyncAPIClient.__enter__Ps ric$|jyrbrreexc_typeexcexc_tbs rf__exit__zSyncAPIClient.__exit__Ss ricyz#Hook for mutating the given optionsNrcrers rf_prepare_optionszSyncAPIClient._prepare_options[s ricyaThis 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. Nrcr<s rf_prepare_requestzSyncAPIClient._prepare_requestbsricyrbrcrer7rrr; stream_clss rfrzSyncAPIClient.requestm riFr;cyrbrc)rer7rrr;s rfrzSyncAPIClient.requesty rir;rcyrbrcrs rfrzSyncAPIClient.requestrric.|j|||||SN)r7rr;rr_requestrs rfrzSyncAPIClient.requests)}}!/   ric |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;rr]Raising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz x-request-id!Encountered httpx.HTTPStatusErrorrRe-raising status errorr7rrr;r) r9rrr,rrJrQr rr^rsendr=rTimeoutException_retry_requestrMrrNr reason_phraserrraise_for_statusHTTPStatusErrorrprrrreadr_process_response) rer7rrr;rretriesrr*rrFs rfrzSyncAPIClient._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)rr7rr;r)rQr rkrr^r\sleepr rerr7rr]r;r remainingrs rfrzSyncAPIClient._retry_requests&) > IIn % II' 3// 7DTU 7gN 7}}'!   ric |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)Nrmrawrr7r;rr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]rz)rrrrErr(rPrrArBrCr>r=rr@rResponserparse rer7rrr;rorigin response_cls api_responses rfrzSyncAPIClient._process_response%sS    # # ' '(; < F! #!)#   G$/ ??6 "z&/'Jfk2"CK=P[\b[c dee ._parserds&  ( ( )  KriFr)rrRrmrR)rr)rerrrrs`` ` rfrzSyncAPIClient._request_api_list^s'  &||D'%|88rirr;cyrbrcrepathr7rr;s rfrzSyncAPIClient.getprrircyrbrcrerr7rr;rs rfrzSyncAPIClient.get{rrirrcyrbrcrs rfrzSyncAPIClient.getrrirr;rc xtjdd|d|}tt|j ||||SNr)rr^rrc)r: constructrr(rrerr7rr;roptss rfrzSyncAPIClient.gets?#,,OEtOwOIt||GT&U_|`aari)rrrr;cyrbrc)rerr7rrrr;s rfpostzSyncAPIClient.posts ri)rrrcyrbrcrerr7rrrr;rs rfrzSyncAPIClient.post ri)rrrrcyrbrcrs rfrzSyncAPIClient.postr ri)rrrr;rc tjdd||t|d|}tt|j ||||SNrrr^r!rrrc)r:rrrr(r) rerr7rrrr;rrs rfrzSyncAPIClient.postsP#,, tt>%;P T[ It||GT&U_|`aarirrcXtjdd||d|}|j||SNpatchrr^r!rcr:rrrerr7rrrs rfrzSyncAPIClient.patchs3#,,aGQUaY`a||GT**rirrrc ltjdd||t|d|}|j||SNputr rc)r:rrrrerr7rrrrs rfrzSyncAPIClient.putsB#,, dd.:O SZ ||GT**ricXtjdd||d|}|j||SNdeleterrcrrs rfrzSyncAPIClient.deletes3#,,bH$RVbZab||GT**rirrrrcZtjd|||d|}|j|||SNrrcr:rrrerrrrrrrs rf get_api_listzSyncAPIClient.get_api_list7#,,`FPT`X_`%%eT488ri)rrrrtrrr!float | Timeout | None | NotGivenrzTransport | Nonerrr Limits | Nonerzhttpx.Client | NonerrurrvrrrmrnrrrerUrmrUrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonermrnrr:rmrnrryrmrnrb) r7Type[ResponseT]rr:rrxr; Literal[True]rzType[_StreamT]rmrX) r7r*rr:rrxr;Literal[False]rmr() r7r*rr:rrxr;rrzType[_StreamT] | NonermResponseT | _StreamT) r7r*rr:rrxr;rrtype[_StreamT] | Nonermr-) r7r*rr:r int | Noner;rrr.rmr-)rr:r7r*rrr]httpx.Headers | Noner;rrr.rmr- r7r*rr:rrwr;rrz1type[Stream[Any]] | type[AsyncStream[Any]] | Nonermr()r Type[object]rType[SyncPageT]rr:rmrR rrr7r*rr0r;r,rmr() rrr7r*rr0r;r+rtype[_StreamT]rmrX) rrr7r*rr0r;rrr.rmr-)rrr7r*r Body | Nonerr0rRequestFiles | Noner;r,rmr()rrr7r*rr6rr0rr7r;r+rr5rmrX)rrr7r*rr6rr0rr7r;rrr.rmr- rrr7r*rr6rr0rmr( rrr7r*rr6rr7rr0rmr()rrrr2rr3rr6rr0rrrmrR)rorprqrsrrCr!rgrrrrrrrrrrrrrrrrrr"rrs@rfrrs 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  9rirc eZdZdfd ZxZS)_DefaultAsyncHttpxClientc |jdt|jdt|jddt|di|yrrrs rfrgz!_DefaultAsyncHttpxClient.__init__ rrirrrs@rfr;r; rrir;ceZdZddZy)AsyncHttpxClientWrapperc tjj|jy#t$rYywxYwrb)asyncioget_running_loop create_taskacloserrs rfrzAsyncHttpxClientWrapper.__del__!s6   $ $ & 2 24;;= A   s14 AANrrrcrirfr>r> srir>c &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)rrrrrGr4rrrArr AsyncClientrr#rrgrr&r>r) rerrrrrrrrrrrrs rfrgzAsyncAPIClient.__init__-s^   MMz+  & !qrr.F  MMm+  & !dee   MMk+  & !bcc {226KK%--)  ":k5CTCT+Ufgklwgxfyz  '*#%)(C  # &='*!'  ric.|jjSrbrrs rfrzAsyncAPIClient.is_closedrricTK|jjd{y7w)rN)rrCrs rfrzAsyncAPIClient.closes ll!!###s (&(cK|Swrbrcrs rf __aenter__zAsyncAPIClient.__aenter__s  sc@K|jd{y7wrbrrs rf __aexit__zAsyncAPIClient.__aexit__s jjls c Kywrrcrs rfrzAsyncAPIClient._prepare_optionss c Kywrrcr<s rfrzAsyncAPIClient._prepare_requests rNF)r;rc Kywrbrc)rer7rr;rs rfrzAsyncAPIClient.request  rN)rc Kywrbrcrer7rr;rrs rfrzAsyncAPIClient.request  rN)rrc KywrbrcrSs rfrzAsyncAPIClient.requestrTrN)r;rrcJK|j|||||d{S7wrrrSs rfrzAsyncAPIClient.requests7]]!/ #    s #!#c K|j||}|j|d{|j||}|j|}|j |d{i}|j |j |d< |j j|fd|xs|j|i|d{} tjd |j"|j$| j&| j( | j+|j=||| ||d{S7 77y#tj$rh} tjdd|dkDr%|j|||||dd{7cYd} ~ Stjd t|| d} ~ wt$rh} tjd d|dkDr%|j|||||dd{7cYd} ~ Stjd t!|| d} ~ wwxYw#tj,$r} tjd d|dkDrw|j/| j0r\| j0j3d{7|j|||| j0j4||d{7cYd} ~ S| j0j6s#| j0j9d{7tjd|j;| j0dd} ~ wwxYw7w)Nrr;rrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)r9rrr,rrJrrr=rrrQr rrMrrNrr^rrrrrprrCrrareadrr) rer7rr;rrrrr*rrFs rfrzAsyncAPIClient._requests#..w@##G,,,))*;WE%%g.##G,,, "    '!--F6N# ?.T\\..S!B!B7!B!SHH )7>>7;;H\H\^f^t^t  P  % % '.++! ,   W - - %% < 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'MD3;M%D6&!M6D:>D8?D:AMH'M.M/M6M8D::H$ 6F0FF0H$ M"F00 H$<6H2G53H7H$8M="HH$$M'L=;AL8J3L8KL8L= M3L8L6L88L==Mc\K|dz }|dk(rtjdntjd||j|||}tjd|j|t j |d{|j|||||d{S7"7wr)rQr rkrr^anyiorrrs rfrzAsyncAPIClient._retry_request:s&) > 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)Nrmrrrrr(rz)rrrrErr(rPrrArBrCr>r?rr@rrrrrs rfrz AsyncAPIClient._process_responseWs`    # # ' '(; < F! #!)#   G$/ ??6 "z&/'Jf&67"CDTCUU`ag`h ijj +/'+ $043748S S  S &* S  S 3S )S %S S .S 1S 2S  S j&$,"%   $      "'+/    %   )     ,0     %    (  )       26+/     %    /  )   #    15+/   %   /  )  # "[  [ %[  [ / [ &[  #[ z $ !   /   /  # :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 ( 9rir)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"r`rr r)rr*rrr'r4)rqrrrsrtr rrrs rfmake_request_optionsrv2s!G *  $Z <  !Hw{{8R8HKH gx ($ "%4!" !,  Nric&eZdZddZeddZy) OtherPlatformc||_yrbnamerer{s rfrgzOtherPlatform.__init__X  ric d|jS)NzOther:rzrs rf__str__zOtherPlatform.__str__[ {##riNr{rrmrnr{rorprqrgrrrcrirfrxrxW$$rirx)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)platformsystemr rdistroidrx)r platform_name distro_ids rf get_platformros"((* ))+113 = Fm$;   M! IIK  !  !]++ G sAB B B )maxsizecxd|tttttt dS)Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)rrget_architectureget_python_runtimeget_python_version)rs rfrPrPs6%'.ln- 0 2313'9';  ric&eZdZddZeddZy) OtherArchc||_yrbrzr|s rfrgzOtherArch.__init__r}ric d|jS)Nzother:rzrs rfrzOtherArch.__str__rriNrr{rrcrirfrrrrir)x32x64armarm64unknowncJ tjS#t$rYywxYwNr)rpython_implementationrrcrirfrrs(--//   ""cJ tjS#t$rYywxYwr)rpython_versionrrcrirfrrs(&&(( rc tj\}}tjj}|dvry|dk(ry|dk(ry|dk(ry|r t |Sy#t$rYywxYw) Nr)raarch64rrx86_64r32bitr)r architecturemachiner rr)python_bitness_rs rfrrs$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#)obj1obj2mergedr3r4s rfrrs?  F)/ W:3z%QU?VCJ WW Ws<<)rq Query | NonerrzHeaders | Nonersrrtr6r rrz'float | httpx.Timeout | None | NotGivenrzPostParser | NotGivenrmr0)rmPlatform)rrrmr|r{)rmArch)rMapping[_T_co, Union[_T, Omit]]rrrmzDict[_T_co, _T]) __future__rrr\rrrXr@rArrr email.utilstypesrrtypingrrrr r r r r rrrrrrrtyping_extensionsrrrrZrrrrrrr_qsr_filesrr _typesr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1_utilsr2r3r4r5r6_compatr7r8_modelsr9r:r;r< _responser=r>r?r@ _constantsrArBrCrDrErFrG _streamingrHrIrJrKrLrMrNrO_legacy_responserP getLoggerrorQrsrRrTrUrVrXrY httpx._configrZr ImportErrorr\rurrrrrFrrrrDefaultHttpxClientrrr;DefaultAsyncHttpxClientr>rrvrxrrrPrrrrrrrcrirfrs" "<;  8&FE+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 +5kRUFV9V3WXG878G8T #%,,#-/_9Ju||VC[89_9D#u00##//75F9Z 1 1;s3C CDF9V$( $""&7@)2" """ "  "  "5"'""J$$      'T 4$$ Y GH HI6 X ) X ) X X]; - ' -s?L%% L65L6