Ng ^ddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddl mZmZmZddlmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd lm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?ddl@mAZAmBZBddlCmDZDmEZEmFZFmGZGmHZHgdZIejJddZKejJddZLGddZMeMZNejOdZPde ZQdRdejSDZTGd d!ejUZVGd"d#e=ZWGd$d%e1ZXejYd&ejZfZ[Gd'd(Z\Gd)de\Z]Gd*de\Z^dS)+) annotationsN)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth)DEFAULT_LIMITSDEFAULT_MAX_REDIRECTSDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse)codes) ASGITransport)AsyncBaseTransport BaseTransport)AsyncHTTPTransport HTTPTransport) WSGITransport)AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxiesTypes ProxyTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypes VerifyTypes)URL QueryParams)Timer URLPatternget_environment_proxiesis_https_redirect same_origin)USE_CLIENT_DEFAULT AsyncClientClientTr:)boundUr9ceZdZdZdS)UseClientDefaulta< For some parameters such as `auth=...` and `timeout=...` we need to be able to indicate the default "unset" state, in a way that is distinctly different to using `None`. The default "unset" state indicates that whatever default is set on the client should be used. This is different to setting `None`, which explicitly disables the parameter, possibly overriding a client default. For example we use `timeout=USE_CLIENT_DEFAULT` in the `request()` signature. Omitting the `timeout` parameter will send a request using whatever default timeout has been configured on the client. Including `timeout=None` will ensure no timeout is used. Note that user code shouldn't need to use the `USE_CLIENT_DEFAULT` constant, but it is used internally when a parameter is not included. N)__name__ __module__ __qualname____doc__I/var/www/html/ai-engine/env/lib/python3.11/site-packages/httpx/_client.pyr?r?DsrEr?httpxz python-httpx/z, cg|] }|dk| S)identityrD).0keys rF rL_s"CCCS 1B1BS1B1B1BrEceZdZdZdZdZdS) ClientStaterN)r@rArBUNOPENEDOPENEDCLOSEDrDrErFrNrNcs#HFFFFrErNc*eZdZdZdd Zdd Zdd ZdS)BoundSyncStreamz A byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. streamr.responsertimerr3returnNonec0||_||_||_dSN_stream _response_timerselfrVrWrXs rF__init__zBoundSyncStream.__init__w ! rEtyping.Iterator[bytes]c#&K|jD]}|VdSr\r^rbchunks rF__iter__zBoundSyncStream.__iter__~s,\  EKKKK  rEc|j}tj||j_|jdSN)seconds)r` sync_elapseddatetime timedeltar_elapsedr^closerbrms rFrrzBoundSyncStream.closesG+**,,!)!3G!D!D!D rEN)rVr.rWrrXr3rYrZ)rYrerYrZ)r@rArBrCrcrjrrrDrErFrUrUqsZ rErUc*eZdZdZdd Zdd Zdd ZdS)BoundAsyncStreamz An async byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. rVr"rWrrXr3rYrZc0||_||_||_dSr\r]ras rFrczBoundAsyncStream.__init__rdrEtyping.AsyncIterator[bytes]c4K|j23d{V}|WV 6dSr\rgrhs rF __aiter__zBoundAsyncStream.__aiter__sF<       %KKKKK(<Zej dtd@ZdddddddeddA dudPZdvdQZdwdxdRZdwdydSZ dwdzdTZd{dUZefd|dYZd}d\Zd~d]Zdd^Zdd_ZddaZddbZ dS) BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingrAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr/rboolrintr+None | typing.Mapping[str, list[EventHook]]r URL | strrr#str | typing.Callable[[bytes], str]rYrZc &|in|}|t| |_|||_t ||_t||_t||_ t||_ ||_ ||_t|dgt|dgd|_| |_| |_t(j|_dSNrequestrW)rrW)_enforce_trailing_slashr1 _base_url _build_auth_authr2_paramsrrr_cookiesr_timeoutrrlistget _event_hooks _trust_env_default_encodingrNrQ_state) rbrrrrrrrrrrrs rFrczBaseClient.__init__s(/bb[ 55c(mmDD%%d++ "6** w'' (( (( 0*KOOIr::;;[__Z<<==  $!1!* rEc,|jtjkS)z2 Check if the client being closed )rrNrSrbs rF is_closedzBaseClient.is_closeds {k000rEc|jSr\)rrs rFrzBaseClient.trust_envs rEurlr1cv|jdr|S||jdzS)N/raw_path)rendswith copy_withrbrs rFrz"BaseClient._enforce_trailing_slashs: <  & & J}}clT&9}:::rEproxiesProxiesTypes | Noneallow_env_proxiesdict[str, Proxy | None]c|.|r*dtDSiSt|tr^i}|D]E\}}t|tt frt |n|}||t |<F|St|tt frt |n|}d|iS)Nc>i|]\}}||dnt|S)Nr)r)rJrKrs rF z-BaseClient._get_proxy_map..s> S%C...rErzall://)r5items isinstancedictstrr1r)rbrr new_proxiesrKvalueproxys rF_get_proxy_mapzBaseClient._get_proxy_maps ?  $;$=$=$C$C$E$EI gt $ $ %K%mmoo . . U,6usCj,I,IT%((((u(- CHH%% *4WsCj*I*IVEg&&&&wEe$ $rErc|jSr\)rrs rFrzBaseClient.timeouts }rEc.t||_dSr\)rr)rbrs rFrzBaseClient.timeout(( rEdict[str, list[EventHook]]c|jSr\)rrs rFrzBaseClient.event_hookss   rEct|dgt|dgd|_dSr)rrr)rbrs rFrzBaseClient.event_hookssKKOOIr::;;[__Z<<==  rE Auth | Nonec|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrs rFrzBaseClient.auths zrEr#c:|||_dSr\)rrrbrs rFrzBaseClient.auths%%d++ rEc|jS)zK Base URL to use when sending requests with relative URLs. )rrs rFrzBaseClient.base_url s ~rEcT|t||_dSr\)rr1rrs rFrzBaseClient.base_urls!55c#hh??rErc|jS)z@ HTTP headers to include when sending requests. )_headersrs rFrzBaseClient.headers }rEr&ctdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rbrclient_headerss rFrzBaseClient.headerssd !$3$:$:7$C$C,)0099      g&&&& rErc|jS)zA Cookie values to include when sending requests. )rrs rFrzBaseClient.cookies*rrEr%c.t||_dSr\)rr)rbrs rFrzBaseClient.cookies1rrEr2c|jS)zO Query parameters to include in the URL when sending requests. )rrs rFrzBaseClient.params5s |rEr)c.t||_dSr\)r2r)rbrs rFrzBaseClient.params<s"6** rE) contentdatafilesjsonrrrr extensionsmethodrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NoneTimeoutTypes | UseClientDefaultrRequestExtensions | Nonerc ||}||}|| } ||}| in| } d| vrMt | t r|jnt| } tdi| d| i} t||||||||| |  S)aR Build and return a request instance. * The `params`, `headers` and `cookies` arguments are merged with any values set on the client. * The `url` argument is merged with any `base_url` set on the client. See also: [Request instances][0] [0]: /advanced/clients/#request-instances Nr)rrrrrrrrrD) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr?rrras_dictr) rbrrrrrrrrrrrs rF build_requestzBaseClient.build_request@s4ooc""%%g..%%g..((00%-RR: J & &g'788& W%%  FF FFGOO4E4EFFFJ  !    rEct|}|jrB|jj|jdz}|j|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)r1is_relative_urlrrlstripr)rbr merge_urlmerge_raw_paths rFrzBaseClient._merge_urlss] HH  $ D"]3i6H6O6OPT6U6UUN=**N*CC CrEcn|s|jr+t|j}|||S|S)z Merge a cookies argument together with any cookies on the client, to create the cookies used for the outgoing request. )rrr)rbrmerged_cookiess rFrzBaseClient._merge_cookiessC  "dl "$T\22N  ! !' * * *! !rEcXt|j}|||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrr)rbrmerged_headerss rFrzBaseClient._merge_headerss- !..g&&&rEcj|s|jr)t|j}||S|S)z Merge a queryparams argument together with any queryparams on the client, to create the queryparams used for the outgoing request. )rr2merge)rbrmerged_queryparamss rFrzBaseClient._merge_queryparamss>  4T[ 4!,T[!9!9 %++F33 3 rEc|dSt|trt|d|dSt|tr|St |rt |St d|)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler r callabler TypeErrorrs rFrzBaseClient._build_auths <4 e $ $ Bd1gQ@@@ @ d # # BK d^^ BT*** *@@@AA ArEr#AuthTypes | UseClientDefault | Noner ct|tr|jn||}||S|jj|jj}}|s|rt||StS)Nr) rr?rrrrrr r )rbrrrrs rF_build_request_authzBaseClient._build_request_auths~ %T+;<< XDJJ$BRBRSWBXBX   K$[17;3G(  Cx ChBBB Bvv rErWrc|||}|||}||||}|||}t |j}t ||||||jS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrrrrVr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrrr)rbrrWrrrrVrs rF_build_redirect_requestz"BaseClient._build_redirect_requests &&w99  (33((#v>>&&w77$,'')     rEc|j}|jtjkr|dkrd}|jtjkr|dkrd}|jtjkr|dkrd}|S)z When being redirected we may want to change the method of the request based on certain specs or browser behavior. HEADGETPOST)r status_coder SEE_OTHERFOUNDMOVED_PERMANENTLY)rbrrWrs rFrzBaseClient._redirect_methodst   5? 2 2v7G7GF  5; . .6V3C3CF  5#: : :v?O?OF rEc|jd} t|}n(#t$r}td|d|dd}~wwxYw|jr'|js ||jj}|jr|j |}|jj r'|j s ||jj }|S)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)host)fragment) rr1rrschemerrrrjoinr)rbrrWlocationrexcs rFr zBaseClient._redirect_urls#J/ h--CC   %939997   : 7ch 7--W[%5-66C   (+""3''C ;  ?  ?--)=->>C s A?Act|j}t||jsHt |j|s|dd|jd|d<||jkr2|dkr,|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrr7rr6popnetlocdecoder)rbrrrrs rFr zBaseClient._redirect_headerss'/**3 ,, 9$W[#66 3 OT222"j//88GFO W^ # #% KK($ / / / KK+T 2 2 2  Hd###rE'SyncByteStream | AsyncByteStream | Nonec6||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rrV)rbrrs rFr zBaseClient._redirect_stream)s& W^ # #%4~rEcd|jvrct|jtr|jnt |j}t di|jd|i|_dSdS)NrrD)rrrr?rrr)rbrrs rF _set_timeoutzBaseClient._set_timeout4s} G. . .dl,<==+ T\**  "&!V!V(:!V!VGOODUDU!V!V!VG    / .rE)rrrrrrrrrr/rrrrrrrrrrrrrYrZ)rYr)rr1rYr1)rrrrrYr)rYr)rr/rYrZ)rYr)rrrYrZ)rYr)rr#rYrZ)rYr1)rrrYrZ)rYr)rr&rYrZ)rYr)rr%rYrZ)rYr2)rr)rYrZ)rrrrrrrrrrrrrrrrrrrrrrrYr)rrrYr1r\)rrrYr)rrrYr)rrrYr)rrrYr)rrrrrYr )rrrWrrYr)rrrWrrYr)rrrWrrYr1)rrrr1rrrYr)rrrrrYr&)rrrYrZ)!r@rArBrr rcpropertyrrrrrsetterrrrrrrr8rrrrrrrr rr r r r)rDrErFrrs"&)-&*&* 6!&2EI @G + + + + + +D111X1 X;;;; %%%%(X ^)))^)!!!X!    X [,,,[,X _@@@_@X  ^ ' ' '^ 'X  ^)))^)X  ]+++]+*.#'%)"&)-&*&*3E/31 1 1 1 1 1 f,     04      B B B B5G$    &.:6    WWWWWWrErceZdZdZdddddddddddedeeddddddddlfd1Zddddedddfdmd3Zddddedfdnd5Z dod8Z ddddddde e e dd9 dpdJZ e ddddddde e e dd9 dqdLZde e dMdrdQZdsdUZdtdVZdudWZddde e e ddXdvdYZddde e e ddXdwd[Zddde e e ddXdwd\Zddddddde e e dd9 dxd]Zddddddde e e dd9 dxd^Zddddddde e e dd9 dxd_Zddde e e ddXdwd`ZdydaZdzddZ d{d|dkZxZS)}r:a An HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between threads. Usage: ```python >>> client = httpx.Client() >>> response = client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **proxies** - *(optional)* A dictionary mapping proxy keys to proxy URLs. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **app** - *(optional)* An WSGI application to send requests to, rather than sending actual network requests. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrrrrrrverifycerthttp1http2rrmountsrrlimitsrrr transportapprrrrrrrrrrr.r0r/CertTypes | Noner0rr1rProxyTypes | Nonerrr20None | typing.Mapping[str, BaseTransport | None]rr/rr3rrrrrrrr4BaseTransport | Noner5'typing.Callable[..., typing.Any] | NonerrrrYrZc t||||| | |||| r$ ddl}n#t$rtddwxYw| r-d}t j|t | rtd|rd}t j|t o|duo|du}| p| |} ||_ fd| D_ | 6j d | Dttj _ dS) NrruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.JThe 'proxies' argument is now deprecated. Use 'proxy' or 'mounts' instead.*Use either `proxy` or 'proxies', not both.zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=WSGITransport(app=...)' instead.r.r/r0r1r3r4r5rc ri|]3\}}t||dn| 4SNr.r/r0r1r3rr4_init_proxy_transport rJrKrr/r0r1r3rbrr.s rFrz#Client.__init__..st @ @ @ U sOO}"T++#, @ @ @ rEc4i|]\}}t||SrDr4rJrKr4s rFrz#Client.__init__..$QQQYC)QQQrEsuperrch2 ImportErrorwarningswarnDeprecationWarning RuntimeErrorr_init_transport _transportr_mountsrrsortedrbrrrrr.r/r0r1rrr2rrr3rrrr4r5rrrLmessager proxy_map __class__s` ```` ` ` rFrczClient.__init__ts92 -'#-         !S   Q4  M'#5 6 6 6 Q"#OPPP  7V  M'#5 6 6 6%K#+K)t:K''(85:KLL ../    @ @ @ @ @ @ @ @ @ @ (oo// @ @ @     L  QQ&,,..QQQ   F4<#5#5#7#78899 =Arc X||S|t|St||||||SN)r5rB)r!r rbr.r/r0r1r3r4r5rs rFrRzClient._init_transportsO    ? S))) )     rErc .t|||||||SN)r.r/r0r1r3rr)r rbrr.r/r0r1r3rs rFrDzClient._init_proxy_transports0    rErr1c|jD]'\}}||r ||jn|cS(|jSz Returns the transport instance that should be used for a given URL. This will either be the standard connection pool, or a proxy. rTrmatchesrSrbrpatternr4s rF_transport_for_urlzClient._transport_for_urld #',"4"4"6"6 K K GYs## K*3*;tJJJ KrE rrrrrrrrrrrrrrrrrrrrrrbool | UseClientDefaultrrrrc | d}tj|t|||||||||| | |  }||| | S)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = client.send(request, ...) ``` See `Client.build_request()`, `Client.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/clients/#merging-of-configuration NSetting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead. rrrrrrrrrrrrrrNrOrPrsendrbrrrrrrrrrrrrrrWrs rFrzClient.requestsB  C  M'#5 6 6 6$$!%   yyt>NyOOOrEtyping.Iterator[Response]c #K|||||||||| | |  }||| | d} |V|dS#|wxYwa  Alternative to `httpx.request()` that streams the response body instead of loading it into memory at once. **Parameters**: See `httpx.request`. See also: [Streaming Responses][0] [0]: /quickstart#streaming-responses rmT)rrrrVN)rrprrrbrrrrrrrrrrrrrrrWs rFrVz Client.streamGs8$$!%   99-     NNN NN     HNN    s AA-rVrrrrrVc|jtjkrtdtj|_t |t r|jn|}||| ||}| |||g} |s| |S#t$r}| |d}~wwxYw)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `Client.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/clients/#request-instances 5Cannot send a request, as the client has been closed.rrhistoryN)rrNrSrQrRrr?rr)r_send_handling_authread BaseExceptionrrrbrrVrrrWrs rFrpz Client.send{s* ;+, , ,VWW W!( *,<== "D ! !!  '"""''66++ - ,      O    NN   I sB11 C;CCr rzlist[Response]c||} t|} ||||} ||}n&#t$r|cY|SwxYwt ||_||}| |n(#t$r}||d}~wwxYw#|wxYwNT)rrz) sync_auth_flownext_send_handling_redirectsrp StopIterationrrrrzr|appendr} rbrrrrz auth_flowrW next_requestrs rFr{zClient._send_handling_auths,''00  9ooG 88%5#9 ('0~~h'?'? ((((' OO    ((,G}}H$MMOOO*GNN8,,,,$NN$$$I# * OO    sN(C&AB= A:#B=9A::AB=<C&= C"CC""C&&C<c t||jkrtd||jdD] }||||} |jdD] }||t ||_|js|S|||}||gz}|r| n ||_ |Sn(#t$r}| |d}~wwxYwNTz#Exceeded maximum allowed redirects.rrrW) lenrrr_send_single_requestrrzhas_redirect_locationr r|rr}rrrbrrrzhookrWrs rFrzClient._send_handling_redirectss@  7||d000&97))4  W 0099H  -j9##DDNNNN#'== 5$#O66wII!XJ.#$MMOOOO,3H)#O$ !        7 s7C;C C6C11C6c||j}t}|t |jt stdt|5| |}dddn #1swxYwYt |jt sJ||_ t|j|||_|j ||j|_t d|j|j|j|j|j|S)L Sends a single request, without handling any redirections. z?Attempted to send an async request with a sync Client instance.rNrWrXHTTP Request: %s %s "%s %d %s")rgrr3 sync_startrrVr.rQrhandle_requestrrUrextract_cookiesrrloggerinfor http_versionr reason_phraserbrr4rXrWs rFrzClient._send_single_requestsx++GK88  '..99 Q W - - - 9 9 //88H 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9(/>:::::") Ohe    $$X...$($:! , N K  !   "    s6BBBrrrrrrrc >|d|||||||| S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrr rbrrrrrrrrs rFrz Client.gets:"||  -!   rEAuthTypes | UseClientDefaultc >|d|||||||| S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrrrs rFoptionszClient.options6s:"||  -!   rEc >|d|||||||| S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrrrs rFheadz Client.headSs:"||  -!   rEc F|d||||||||| | | |  S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrir rbrrrrrrrrrrrrs rFpostz Client.postpsF*||  -!   rEc F|d||||||||| | | |  S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrirrs rFputz Client.putsF*||  -!   rEc F|d||||||||| | | |  S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrirrs rFpatchz Client.patchsF*||  -!   rEc >|d|||||||| S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErrrs rFdeletez Client.deletes:"||  -!   rEc|jtjkr\tj|_|j|jD]}||dSdSz. Close transport and proxies. N)rrNrSrSrrrTvalues)rbr4s rFrrz Client.closesx ;+, , ,%,DK O ! ! # # #!\0022 & & (OO%%% - , & &rErbr;cP|jtjkr4tjdtjdi|j}t |tj|_|j|j D]}|||SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrNrQrRrSrQrS __enter__rTr)rbmsgr4s rFrzClient.__enter__s ;+. . ."$S"O k C s## #!(  !!###,,.. & &I$##%%% rEexc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonectj|_|j||||jD]}|||||dSr\)rNrSrrS__exit__rTr)rbrrrr4s rFrzClient.__exit__sr "(    9i@@@,,.. C CI$""8Y BBB C CrE),rrrrrrrrr.r0r/r6r0rr1rrr7rrr2r8rr/rrr3rrrrrrrr4r9r5r:rrrrrYrZ)r.r0r/r6r0rr1rr3rr4r9r5r:rrrYr)rrr.r0r/r6r0rr1rr3rrrrYr)rr1rYrrrrrrrrrrrrrrrrrrrrrrrjrrrrrYr)rrrrrrrrrrrrrrrrrrrrrrjrrrrrYrr rrrVrrrrrjrYr rrrr rrrzrrYrrrrrrzrrYrrrrYrrrrrrrrrrrrrjrrrrrYrrrrrrrrrrrrrjrrrrrYrrrrrrrrrrrrrrrrrrrrrjrrrrrYrrt)rbr;rYr;NNNrrrrrrrYrZ)r@rArBrCrr r rcrRrDrgr8rrrVrpr{rrrrrrrrrrrrr __classcell__rYs@rFr:r:>s33p"&)-&*&*"!%#''+EI 6!&'2EI *.7;@G/`:`:`:`:`:`:`:`:H#!%'*.7;     :#!%'     (     *.#'%)"&)-&*&*4F4F3E/36P6P6P6P6P6Pp *.#'%)"&)-&*&*4F4F3E/311111^1n4F4F 111111f    D####J""""P*.&*&*4F4F3E/3      B*.&*&*-?4F3E/3      B*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.&*&*-?4F3E/3      : & & & &(04*.*. C C C C C C C C CrEceZdZdZdddddddddddedeeddddddddlfd1Zddddedddfdmd3Zddddedfdnd5Z dod8Z ddddddde e e dd9 dpdJZ e ddddddde e e dd9 dqdLZde e dMdrdQZdsdUZdtdVZdudWZddde e e ddXdvdYZddde e e ddXdwd[Zddde e e ddXdwd\Zddddddde e e dd9 dxd]Zddddddde e e dd9 dxd^Zddddddde e e dd9 dxd_Zddde e e ddXdwd`ZdydaZdzddZ d{d|dkZxZS)}r9a An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between tasks. Usage: ```python >>> async with httpx.AsyncClient() as client: >>> response = await client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **proxies** - *(optional)* A dictionary mapping HTTP protocols to proxy URLs. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **app** - *(optional)* An ASGI application to send requests to, rather than sending actual network requests. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrrr-rrrrrrrrr.r0r/r6r0rr1rr7rrr25None | typing.Mapping[str, AsyncBaseTransport | None]rr/rr3rrrrrrrr4AsyncBaseTransport | Noner5r:rrrrYrZc t||||| | |||| r$ ddl}n#t$rtddwxYw| r-d}t j|t | rtd|rd}t j|t o|duo|du}| p| |} ||_ fd| D_ | 6j d | Dttj _ dS) Nrrr<r=r>zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=ASGITransport(app=...)' instead.r?c ri|]3\}}t||dn| 4SrArCrEs rFrz(AsyncClient.__init__..st E E E U sOO}"T++#, E E E rEc4i|]\}}t||SrDrGrHs rFrz(AsyncClient.__init__..rIrErJrVs` ```` ` ` rFrczAsyncClient.__init___s92 -'#-         !S   Q4  M'#5 6 6 6 Q"#OPPP  7V  M'#5 6 6 6%K#+K)t:K''(85:KLL ../    E E E E E E E E E E (oo// E E E     L  QQ&,,..QQQ   F4<#5#5#7#78899 rZrc X||S|t|St||||||Sr\)rrr]s rFrRzAsyncClient._init_transportsO    ? S))) )!     rErc .t|||||||Sr_)rr`s rFrDz!AsyncClient._init_proxy_transports0"    rErr1c|jD]'\}}||r ||jn|cS(|jSrbrcres rFrgzAsyncClient._transport_for_urlrhrErirrrrrrrrrrrrjrrrrc K| d}tj|t|||||||||| | |  }||| | d{VS)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = await client.send(request, ...) ``` See `AsyncClient.build_request()`, `AsyncClient.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/clients/#merging-of-configuration Nrlrmrnrorqs rFrzAsyncClient.requestsD  C  M'#5 6 6 6$$!%   YYwTDTYUUUUUUUUUrEtyping.AsyncIterator[Response]c K|||||||||| | |  }||| | dd{V} |WV|d{VdS#|d{VwxYwrt)rrpr}rus rFrVzAsyncClient.stream3s8$$!%   - #          $NNNN//## # # # # # # # # #(//## # # # # # # # #s A$$BrvrrrVcK|jtjkrtdtj|_t |t r|jn|}||| ||}| |||gd{V} |s| d{V|S#t$r!}| d{V|d}~wwxYw)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `AsyncClient.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/clients/#request-instances rxryN)rrNrSrQrRrr?rr)rr{areadr}r}r~s rFrpzAsyncClient.sendgs@* ;+, , ,VWW W!( *,<== "D ! !!  '"""''6611 - 2           'nn&&&&&&&&&O   //## # # # # # # #I s!B?? C* C%%C*r rzrc`K||} |d{V} ||||d{V} ||d{V}n,#t$r|cY|d{VSwxYwt ||_|d{V|}| |n.#t$r!}|d{V|d}~wwxYw#|d{VwxYwr) async_auth_flow __anext__rasendStopAsyncIterationr}rrzrrr}rs rFr{zAsyncClient._send_handling_auths((11  %%//11111111G !%!>!>%5#"?"" (-6__X-F-F'F'F'F'F'F'F -((('""$$ $ $ $ $ $ $ $ $((,G}}H$"..**********GNN8,,,,$"//+++++++++I# *""$$ $ $ $ $ $ $ $ $sN9DA0/C"0 B<C"BAC"!D" D ,DD  DD-c6K t||jkrtd||jdD]}||d{V||d{V} |jdD]}||d{Vt ||_|js|S|||}||gz}|r| d{Vn ||_ |Sn.#t$r!}| d{V|d}~wwxYwr) rrrrrrrzrr rrr}r}rs rFrz$AsyncClient._send_handling_redirectss  7||d000&97))4 $ $d7mm########!66w????????H  -j9))D$x..((((((((#'== 5$#O66wII!XJ.#$"..**********,3H)#O+ !   oo'''''''''  9 s*=C+(AC++ D5DDcK||j}t}|d{Vt |jt stdt|5| |d{V}dddn #1swxYwYt |jt sJ||_ t|j|||_|j ||j|_t d|j|j|j|j|j|S)rNz?Attempted to send an sync request with an AsyncClient instance.rrr)rgrr3 async_startrrVr"rQrhandle_async_requestrrvrrrrrrrrrrrs rFrz AsyncClient._send_single_requests++GK88 !!!!!!!!!'./:: Q W - - - E E&;;GDDDDDDDDH E E E E E E E E E E E E E E E(/?;;;;;"* Ohe    $$X...$($:! , N K  !   "    s>B&&B*-B*rc NK|d|||||||| d{VS)rrrNrrs rFrzAsyncClient.gets\"\\  -!"         rErc NK|d|||||||| d{VS)rrrNrrs rFrzAsyncClient.options"s\"\\  -!"         rEc NK|d|||||||| d{VS)rrrNrrs rFrzAsyncClient.head?s\"\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrriNrrs rFrzAsyncClient.post\sh*\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrriNrrs rFrzAsyncClient.putsh*\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrriNrrs rFrzAsyncClient.patchsh*\\  -!"         rEc NK|d|||||||| d{VS)rrrNrrs rFrzAsyncClient.deletes\"\\  -!"         rEcK|jtjkrhtj|_|jd{V|jD] }||d{VdSdSr)rrNrSrSr}rTr)rbrs rFr}zAsyncClient.acloses ;+, , ,%,DK/((** * * * * * * *,,.. ) )$,,..((((((( - , ) )rErbr=clK|jtjkr4tjdtjdi|j}t |tj|_|jd{V|j D]}||d{V|Sr) rrNrQrRrSrQrS __aenter__rTr)rbrrs rFrzAsyncClient.__aenter__s ;+. . ."$S"O k C s## #!( o((*********\((** ) )E &&((((((((( rErrrrrrcKtj|_|j|||d{V|jD]!}|||||d{V"dSr\)rNrSrrS __aexit__rTr)rbrrrrs rFrzAsyncClient.__aexit__s "( o'')YGGGGGGGGG\((** F FE ooh 9EEEEEEEEE F FrE),rrrrrrrrr.r0r/r6r0rr1rrr7rrr2rrr/rrr3rrrrrrrr4rr5r:rrrrrYrZ)r.r0r/r6r0rr1rr3rr4rr5r:rrrYr)rrr.r0r/r6r0rr1rr3rrrrYr)rr1rYrr)rrrrrrrrrrrrrrrrrrrrrrjrrrrrYrrrrrrrrrt)rbr=rYr=rr)r@rArBrCrr r rcrRrDrgr8rrrVrpr{rrrrrrrrrr}rrrrs@rFr9r9(s44r"&)-&*&*"!%#''+JN 6!&'2EI /37;@G/`:`:`:`:`:`:`:`:H#!%'/37;     :#!%'     (     *.#'%)"&)-&*&*4F4F3E/37V7V7V7V7V7Vr *.#'%)"&)-&*&*4F4F3E/31$1$1$1$1$1$n4F4F 111111f % % % %D$$$$L!!!!N*.&*&*4F4F3E/3      B*.&*&*-?4F3E/3      B*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.&*&*-?4F3E/3      : ) ) ) )(04*.*. F F F F F F F F FrE)_ __future__rroenumloggingtypingrN contextlibrrtypesrrrr r r _configr r rrrr _decodersr _exceptionsrrrr_modelsrrrr _status_codesr_transports.asgir_transports.baserr_transports.defaultrr _transports.wsgir!_typesr"r#r$r%r&r'r(r)r*r+r,r-r.r/r0_urlsr1r2_utilsr3r4r5r6r7__all__TypeVarr;r=r?r8 getLoggerrrrkeysrEnumrNrUrvCallableAny EventHookrr:r9rDrErFrs""""""  ::::::::$$$$$$0000000000*))))) 988888888888 ++++++????????BBBBBBBB++++++"$####### : 9 9FN3h'''FN3m,,,(&%''  7 # # *[ * * ))CC+&+--CCC     $)   n.$$$$$$$$. OCO , YWYWYWYWYWYWYWYWx g Cg Cg Cg Cg CZg Cg Cg CTi Fi Fi Fi Fi F*i Fi Fi Fi Fi FrE