TCjddZddlZddlmZddlZddlmZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlmZmZmZmZmZmZmZmZmZddlmZddlmZddlZddl Z ddl!Z!ddl"Z#ddl$Z#ddl$m%Z%dd l&m'Z'dd l"m(Z)ddl*Z*dd l+m,Z,dd l+m-Z-ddl.Z.d dl/m0Z0d dl/m1Z1d dl/m2Z2d dl3m4Z4d dl3m5Z5d dl3m6Z7d dl3m8Z8d dl3m9Z9 ddl:m;Z<n#e=$r ddl>m;Z<YnwxYwdZ? ddl@Z@dZ?n #eA$rYnwxYw ddlBZBn #eA$rdZBYnwxYwerddlCmDZDddlEmFZFddlGmHZHe jIdZJdZKdZLdZMd ZNd ZOd!d"hZPeBe*jQfn e*jQeBjQfZReBe*jSfn e*jSeBjSfZTeBe*jUe*jVfne*jUe*jVeBjUeBjVfZWGd#d$eXZYd%eeZfd&Z[d'e\eZeZfd%dfd(Z]d)e4d*e4d%e4fd+Z^d'e\eZeZfd,eee_e`fd%dfd-Zad.eZd/eZd%eZfd0Zbd1eeZdfd%ee%eZffd2Zcd3e%d%e%fd4Zdd5eee_e`fd%ee_fd6ZeeGd7d8ZfGd9d:Z6d;ZgdZld)ee8d%e0jmfd?ZnGd@dAe*joZpGdBdCe*jqZrGdDdEZsdFdEd3e#jtjuj%d%eZfdGZvdFdEd3e#jtjuj%d%eZfdHZwdS)IzBase client for calling HTTP APIs sending and receiving JSON. The BaseApiClient is intended to be a private module and is subject to change. N) Generator) dataclass) Any AsyncIteratorIteratorOptional TYPE_CHECKINGTupleUnioncastoverload)urlparse) urlunparse) Credentials)mtls) exceptions) BaseModel)ValidationError)_common)errors)version) HttpOptions)HttpOptionsOrDict) HttpResponse)HttpRetryOptions) ResourceScope)connectFTAuthorizedSession)CIMultiDictProxy)CaseInsensitiveDictzgoogle_genai._api_clientii@useuceZdZdZdS)EphemeralTokenAPIKeyErrorz)Error raised when the API key is invalid.N)__name__ __module__ __qualname____doc__\C:\Projects\Historical\FacebookAutoPoster\venv\Lib\site-packages\google/genai/_api_client.pyr(r({s1111r.r(returnctjdd}tjdd}|r|rtd|p|pdS)zGets the API key from environment variables, prioritizing GOOGLE_API_KEY. Returns: The API key string if found, otherwise None. Empty string is considered invalid. GOOGLE_API_KEYNGEMINI_API_KEYzEBoth GOOGLE_API_KEY and GEMINI_API_KEY are set. Using GOOGLE_API_KEY.)osenvirongetloggerwarning)env_google_api_keyenv_gemini_api_keys r/get_env_api_keyr;snz~~&6==z~~&6==. NNO  91 9T9r.headerscdtj}dtjdz}|d|}d|vr||dvr|d|dz|d<n(d|vr||dvr|dd||d<n d|vr||d<d|vr||dvr|d|dz|d<dSd|vr||dvr|dd||d<dSd|vr||d<dSdS)z1Appends the telemetry header to the headers dict.zgoogle-genai-sdk/z gl-python/r z user-agentzx-goog-api-clientN)r __version__syssplit)r< library_labellanguage_labelversion_header_values r/append_library_version_headersrEs;g&9;;-#+"3"3"5"5a"88.)<9N#N#N&|4GG~GGGL7""0GLW$$ w':; ; ; """W-@%AA    W$$ (; < < < & '::.::    '))#7G    *)r.options patch_optionsc z|}|jpi}|jpi}i|||_tj}|D]M}|dkr t ||d}|t |||.t ||t ||N|jt|j|S)Nr<) model_copyr<r model_fieldskeysgetattrsetattrrE)rFrG copy_optionoptions_headerspatch_options_headershttp_options_keyskey patch_values r/patch_http_optionsrTs""$$+'-2/'/52+ ".3355 77c i-d33K k3 ,,,, k3 5 56666$";#6777 r.timeout_in_secondscb|r*d|vr(ttj||d<dSdSdS)z8Populates the server timeout header in the headers dict.zX-Server-TimeoutN)strmathceil)r<rUs r/populate_server_timeout_headerrZsNE.g=="%di0B&C&C"D"DG EE==r.base_urlpathct|}|jdr|jddn|j}|dr |ddn|}t ||dz|zS)N/r)r\)rr\endswith startswithr_replace)r[r\ parsed_base base_paths r/ join_url_pathres""+   " "3 ' 'kss   __S)) 3abbt$ K((i#o.D(EE F FFr.projectc|tjdg\}}|s|}|std||fS)z-Loads google auth credentials and project id.z.https://www.googleapis.com/auth/cloud-platform)scopesz@Could not resolve project using application default credentials.)googleauthdefault ValueError)rf credentialsloaded_project_ids r/ load_authrosc#);#6#6> ?$7$$ +   G  J   g r.rmcLddlm}|||S)Nr)Request)google.auth.transport.requestsrqrefresh)rmrqs r/ refresh_authrts4444444 ggii   r.timeoutc|r|dz }nd}|S)z Converts the timeout to seconds.g@@Nr-)rurUs r/get_timeout_in_secondsrws( !6) r.ceZdZUeeefed<eed<eed<eeeefefed<dZ e e ed<dS) HttpRequestr<urlmethoddataNru) r)r*r+dictrW__annotations__r objectbytesrurfloatr-r.r/ryrysk S> ((( +++ d3;&''''!'8E?!!!!!r.ryc zeZdZ ddeeeefejddfdeeefdeee ffdZ dd Z defd Z e defd Zdeeddffd Zdeefd Zdeee efddffdZdeeefddfdZdeefdZdeefdZededefdZdS)rNr<zCIMultiDictProxy[str]r"response_stream byte_streamcttr|_nttr&fdD|_nt jx} >t|jjr$d D|_n=tj dkr%fdD|_d|_ ||_ ||_dS)Ncbi|]+}|d|,Sz, )joinget_list.0rRr<s r/ z)HttpResponse.__init__..sB47#tyy))#..//r.ci|]\}}|| Sr-r-)rrRvalues r/rz)HttpResponse.__init__..&sCCCZS%c5CCCr.r!cbi|]+}|d|,Sr)rgetallrs r/rz)HttpResponse.__init__..(s@25#tyy,,--r.) isinstancer}r<_HTTPX_HEADERS_TYPESrKrloaded_requests structuresr"itemstyper) status_coderr)selfr<rrrequests_modules ` r/__init__zHttpResponse.__init__s('4  dll G1 2 2 ;B<<>>dll#2444   +?  DC7==??CCCdll g #5 5 59@dl D*D"Dr.r0c8||_|SN)async_segmentssegment_iteratorrs r/ __aiter__zHttpResponse.__aiter__1s //11D Kr.cpK |jd{VS#t$rtwxYwr)r __anext__ StopIterationStopAsyncIterationrs r/rzHttpResponse.__anext__5sS(2244 4 4 4 4 4 44  s#5ct|jtsdS|jr |jdsdS||jdS)Nr)rrlist_load_json_from_responsers r/jsonzHttpResponse.json;sY d*D 1 1 T  t';A'> R  ( ()=a)@ A AAr.c# Kt|jtr'|jD]}|r||niVdS|j gEd{VdS|D]}||VdSr)rrrr_iter_response_stream)rchunks r/segmentszHttpResponse.segmentsGs$&-- 3'DD%6;Cd++E222CCCCDD  %mmmmmmmmm--//33%++E22222233r.c*Kt|jtr(|jD]}|r||niWVdS|jg23d{V}|WV 6dS|23d{V}||WV 6dSr)rrrr_aiter_response_stream)rrcs r/rzHttpResponse.async_segmentsSs $&-- 3'DD%6;Cd++E222CCCCCDD  %RR44663333333++E2222222766s A2Bc#Kt|jtr|jEd{VdS|j gEd{VdStd)Nz8Byte segments are not supported for streaming responses.)rrrrlrs r/ byte_segmentszHttpResponse.byte_segments`so$"D))!!!!!!!!!!  !mmmmmmmmm  D  r.response_payloadct|dt|D]'}tjt ||||<(dS)Nr)delattrdircopydeepcopyrL)rr attributes r/ _copy_to_dictzHttpResponse._copy_to_dictksX D$%%%YYLL $(M'$ 2J2J$K$Ky!!LLr.c#Ktj}t|jtsF|t|j|js*t dt|jjdd}d}g}t|jtr|j }n|j d}|D]}|s|rd |Vg} | d r+| |td d`|D]}|d kr|d z }|d kr|d z}||z }|dkr|Vd}|r|V|rd |VdSdS) z,Iterates over chunks retrieved from the API.NzFExpected self.response_stream to be an httpx.Response object, but got .rrT)decode_unicode data: {r})rrrr_HTTPX_RESPONSE_TYPESResponse TypeErrorrr) iter_linesrraappendlen)rrrbalance data_bufferrliners r/rz"HttpResponse._iter_response_streamqs-//O4')>??   '4/1IJJ (  <$.//8 < < <   EGK$&(=>>M,7799oo,77t7LLo    +&& & & &+  " "4H /000 ! 88 Q,'' #XX Q,' tme A   kkk# IIk " """"""##r.cKt|jtp%tot|jtj}|s*t dt|jjdd}d}g}t|jtr |j}| 23d{V}|s|rd |WVg}&| dr+| |tddf|D]}|dkr|d z }|d kr|d z}||z }|dkr|WVd}6|r|WV|rd |WV|d{VdS#|d{VwxYwtrt|jtjrx |jjt" d{V}n4#t $r'|jjd{V}YnwxYw|sn|d }|s|rd |WVg}| dr+| |tdd|D]}|dkr|d z }|d kr|d z}||z }|dkr|WVd}|r|WV|rd |WV|jdS#|jwxYwdSdS)z;Asynchronously iterates over chunks retrieved from the API.z`Expected self.response_stream to be an httpx.Response or aiohttp.ClientResponse object, but got rrrNrrrrrT)max_line_lengthutf-8)rrr has_aiohttpaiohttpClientResponserrr) aiter_linesrrarraclosecontentreadlineREAD_BUFFER_SIZEdecoderstriprelease) ris_valid_responserrrrrr line_bytess r/rz#HttpResponse._aiter_response_streams" 3 P 4#79OPP   54'((1 5 5 5   EGK$&(=>>X'"'#3)5577       $  IIk******k __X & &    tCMMNN3 4 4 4    aCxxlggclg 4-% \\KKKKE184  ++++  ' +&& & & & &$$&&&&&&&&&&&o$$&&&&&&&&&& 2' g42'/'&  G#3;DD 0 E  JJ G G G $3;DDFFFFFFFFJJJ G  ""7++2244$  IIk******k __X & &    tCMMNN3 4 4 4    aCxxlggclg 4-% \\KKKKEM& P  ++++  ' +&& & & & & $$&&&&&$$&&&&e2'2'2'2'sJE?,E2B1E??FL +G54L5.H&#L%H&&CLL9responsec tj|S#tj$r}tjd||d}~wwxYw)zFLoads JSON from the response, or raises an error if the parsing fails.z0Failed to parse response as JSON. Raw response: N)rloadsJSONDecodeErrorrUnknownApiResponseError)clsres r/rz%HttpResponse._load_json_from_responses\ Z ! !!    * GX G G   sA=A)NN)r0r)r)r*r+r r}rWhttpxHeadersrrrrrpropertyrrrrrrrrrrr classmethodrr-r.r/rrs*.'+## sCx. - !  !#S#X#e$####Bs   BC B B B 8 B 3 #tT/2 3 3 3 3 3M#$6 3 3 3 3 YuUCZ'8$'DE    LDf,=L$LLLL 5#Xc]5#5#5#5#nj'M#,>j'j'j'j'Xcc;r.rg?gN@)iiiiiic|tjdddS|jdkrd|_tj|jpt}|jpt tjfd}tj|jpt|j pt|j pt|jpt}||d|tjt"t$jdS) aReturns the retry args for the given http retry options. Args: options: The http retry options to use for the retry configuration. If None, the 'never retry' stop strategy will be used. Returns: The arguments passed to the tenacity.(Async)Retrying constructor. NrT)stopreraiserctt|tjr |jvpt|tSr)rrAPIErrorcode_HTTPX_TRANSIENT_EXC)rretriable_codess r/zretry_args..Cs5Av//MAFo4M- A+ , ,r.)initialmaxexp_basejitter)rretryrwait before_sleep)tenacitystop_after_attemptattempts_RETRY_ATTEMPTShttp_status_codes_RETRY_HTTP_STATUS_CODESretry_if_exceptionwait_exponential_jitter initial_delay_RETRY_INITIAL_DELAY max_delay_RETRY_MAX_DELAYr_RETRY_EXP_BASEr _RETRY_JITTERbefore_sleep_logr7loggingINFO)rFrrrrs @r/ retry_argsr 2s _/22t D DD G  $W%5%H I I$-I1I/  %----  %  )#;';   //2? ^ ,}    $/ EE   r.c4eZdZdZdeddffd ZddZxZS)SyncHttpxClientzSync httpx client.kwargsr0Nc f|ddtjdi|dSzInitializes the httpx client.follow_redirectsTNr- setdefaultsuperrrr  __class__s r/rzSyncHttpxClient.__init__X= ($///EGGvr.c |jrdSn#t$rYnwxYw |dS#t$rYdSwxYw)zCloses the httpx client.N) is_closed Exceptionclosers r/__del__zSyncHttpxClient.__del__]ss      d   jjlllll     dd s 3 AAr0Nr)r*r+r,rrr __classcell__rs@r/r r Usest         r.r c4eZdZdZdeddffd ZddZxZS)AsyncHttpxClientzAsync httpx client.r r0Nc f|ddtjdi|dSrrrs r/rzAsyncHttpxClient.__init__mrr.c |jrdSn#t$rYnwxYw tj|dS#t$rYdSwxYwr)rrasyncioget_running_loop create_taskrrs r/rzAsyncHttpxClient.__del__rs      d     ,,T[[]];;;;;     dd s 8A A%$A%rrrs@r/r r jsest         r.r ceZdZUdZdZeeed<dZee ed< dFdeedee dee j j j dee dee d eef d Zd efd Zd efd Zded efdZedeeefd dfdZed eefdZd efdZe dGdeded eejejffdZe dGdeded ejfdZe dGdeded ejfdZ d efdZ!d e fdZ"d e fdZ#d e$j%fdZ&d e'e effdZ( dHde de d ee e)fd eed e*f d!Z+ dGd"e*d#ed e,fd$Z- dId"e*d eed#ed e,fd%Z. dGd"e*d#ed e,fd&Z/ dId"e*d eed#ed e,fd'Z0d ejfd(Z1 dHde de d ee e)fd eed e2f d)Z3 dHde de d ee e)fd eed e4e2ddff d*Z5 dHde de d ee e)fd eed e2f d+Z6 dHde de d ee e)fd eed ef d,Z7dd-d.e'e e8j9fd/e d0e:d eed e,f d1Z;dd-d2e8j9d/e d0e:d eed e,f d3Zf d8Z?e=dd4d9de d eed6e'e e@jAe e8j9fd7e:d df d:Z?ddd4d5de d eed6ee'e e@jAe e8j9fd7e:d ee>f d;Z?dd-d.e'e e8j9fd/e d0e:d eed e,f d<ZBdd-d2e'e8j9eCjDefd/e d0e:d eed e,f d=ZEe=ddd4d5de d eed6dd7e:d e>f d>ZFe=dd4d9de d eed6e'e e@jAe e8j9fd7e:d df d?ZFddd4d5de d eed6ee'e e@jAe e8j9fd7e:d ee>f d@ZFdAejGd dfdBZHdJdCZIdJdDZJdJdEZKdS)K BaseApiClientz8Client for calling HTTP APIs sending and receiving JSON.Nvertexaicustom_base_urlapi_keyrmrflocation http_optionsc ||_d|_|jtjdd}tjdd}d} ||dv} d} ||dv} | | | | krt jd| | |_n | | |_|s|r|jstd|r|rtdt} t|tr8 tj |} n@#t$r} td| d} ~ wwxYw|rtj|tr|} | jr| jstdtjd d} tjd d}t%}|p| |_|p||_|p||_||_t|_t1j|_i|_|jr,|r$|r"t8d d|_n|r1|s/|s-| s|r)t8d d|_d|_nW|s|r&|s$|r"t8d d|_n-|s+|s)|s'| s|r#|r!t8dd|_| jr| jnd|_|js7|js0|jsd|_n!|jdrd|_|js4|js-|js&t?d\}|_|js||_|jr|jp|j}|s|jstd|jr|jr |jdkr|js d|j_n|jt@vr|jsd|jd|j_n\|jr@|jds&|r|s"|s |j|j_d|_d|_nd|jd|j_d|j_!n.|jstdd|j_d|j_!ddi|j_"|jr>|j#|_|jj"|j|jj"d<|rtI|j| |_n%|jj"tK|jj"|&|jtO|j\}}||_(d|_)|jj*r|jj*|_+ntYd'i||_+|jj-r|jj-|_.nt_d'i||_.i|_0|1r d dl2}|3|jtO|j|_4|5rPd!|j4d"<|jj6tod#nto|jj6|j4d$<d%|j4d&<n#tp$rYnwxYwts|jj:}|;|jtO|j|_<t{j>d'i||_?t{j@d'i||_AdS)(NGOOGLE_GENAI_USE_ENTERPRISEGOOGLE_GENAI_USE_VERTEXAI)true1zWarning: Both GOOGLE_GENAI_USE_ENTERPRISE and GOOGLE_GENAI_USE_VERTEXAI are set with conflicting values. The value of GOOGLE_GENAI_USE_ENTERPRISE will be used.z-Gemini API does not support project/location.zICredentials and API key are mutually exclusive in the client initializer.zInvalid http_optionsz9base_url must be set when base_url_resource_scope is set.GOOGLE_CLOUD_PROJECTGOOGLE_CLOUD_LOCATIONzoThe user provided Google Cloud credentials will take precedence over the API key from the environment variable.zrThe user provided Vertex AI API key will take precedence over the project/location from the environment variables.zqThe user provided project/location will take precedence over the Vertex AI API key from the environment variable.zyThe project/location from the environment variables will take precedence over the API key from the environment variables.globalz.googleapis.comrfz>*GNN(CTJJn  '+1133}Dl  %'--//=@   $& ,,  B    #&  #$  H8HT]H F G GGw     )]],%%,8!,!;L!I!I 888/00a78 ,'1, LL,+ 6&/  E   *..!7>>K:>>"94@@L!##K)kDL, DM)kDL#D$D%>++DLND }m0 ''  A        +    B     x[  B        +      M    $ ,  ) ) m#,## #"$--  ! * *+< = = #"$-l*,*&* %.d$;$;$;! T\  *)$ !\;dmL   )=  J    < $  26-82K2K$3L&K## -4 4 4& 5 F$- E E E ##   &//0ABB  ' ,3 '+&:#   Bt} A A A #(1d$$ \  >   %Qd!'/d$"02D!ED |D\''))dl  # /7;|"#34C-  4d   # /&t'9'ABBB%)%?%? dm$$&@&&"K"%6D!>BD &:-:d*99[99d ,G!%!3!Fd!1!F!F4E!F!Fd.0D     ( ("dm,, )   /  & & ( ( H;?$ 1% 8!)1INI I I 7< (8 8   12D E GH$ 12B C      d0>??L"<< dm$$=D#33l33DK .>>>>Ds+ D!! E+D;;EBY,, Y98Y9r0cttdsdSt|jo>tjo+tjo|jjp |jj S)Nshould_use_client_certF) hasattrrrNr(rohas_default_client_cert_sourcerDrQrkrs r/_use_google_auth_syncz#BaseApiClient._use_google_auth_syncss 41 2 2 U    ' ) )  / 1 1    + Mt/A/M   r.cF ddl}|d}|j}d}n#ttf$rd}YnwxYwt t oP|oN|joGttdo2tj otj o |j j S)Nrgoogle.auth.aio.credentialsTFro) importlib import_modulerrZAttributeErrorrNrr(rprrorqrDrS)rruaio_creds_module_has_google_auth_aios r/rYz$BaseApiClient._use_google_auth_asyncs""001NOO  &a   ("""!"  6  6 M 6 D2 3 3 6  ' ) )  6  / 1 1  6 "5 5  s "%;;sessionct|drt|jSt|dr.t|jdrt|jjSdS)z&Returns True if the session is closed.closed _auth_request_closedF)rprNr}r~r)rr{s r/_is_session_closedz BaseApiClient._is_session_closedsjw!!" '. ! !!w((1Wy..1''/ 0 00 5r.entriesc*d|DD]}||=dS)aDrops entries of a loop-keyed cache whose event loop has been closed. Servers that run every request on a fresh loop (ADK's sync `Runner.run()`, used by Agent Engine, calls `asyncio.run()` per request) would otherwise grow these caches without bound, pinning one aiohttp session, connector and set of sockets per request served. A session on a closed loop cannot be awaited shut, but dropping the last reference to it lets the garbage collector release the connector and its sockets. c:g|]}||Sr-)r)rloops r/ z>BaseApiClient._discard_closed_loop_entries..s'>>>$T^^-=-=>>>>r.Nr-)rrs r/_discard_closed_loop_entriesz*BaseApiClient._discard_closed_loop_entriess4?>'>>> $--r.c|jjr |jjS tj}|j|S#t $rYdSwxYw)zUReturns the aiohttp client session for the current loop (for backward compatibility).N)rDaiohttp_clientr#r$rUr6 RuntimeErrorrrs r/_aiohttp_sessionzBaseApiClient._aiohttp_sessionsj  (/   ..  % ' 'd  # ' ' - --  TTs,A AAc,K|jjr |jjStj}|j5||j|j|}|||rd}dddn #1swxYwY|| rl ddl }| dj }| dj }Gdd|}|||}n]#t$rYnQwxYwGddtj}Gd d tj}||d d t$ }|r)|j5||j|<dddn #1swxYwY|S)z#Returns the aiohttp client session.Nrrtz"google.auth.aio.transport.sessionsc leZdZdZd fd Zdedededeeefd d f d Ze d e fd Z xZ S)HBaseApiClient._get_aiohttp_session.._RefreshableAsyncCredentialszJAdapter to use the client's sync credentials in an AsyncAuthorizedSession.clientr'cVt||_dSr)rr_client)rrrs r/rzQBaseApiClient._get_aiohttp_session.._RefreshableAsyncCredentials.__init__s$gg   #dlllr.requestr{rzr<r0NcK|jd{V}d||d<|jjr'|jjjr|jjj|d<dSdSdS)NBearer Authorizationx-goog-user-project)r_async_access_tokenrCquota_project_id)rrr{rzr<tokens r/before_requestzWBaseApiClient._get_aiohttp_session.._RefreshableAsyncCredentials.before_requests!L<<>>>>>>>>e):5):):go&,+l/@ L->-... r.cB|jjsdS|jjj SNF)rrCexpiredrs r/validzNBaseApiClient._get_aiohttp_session.._RefreshableAsyncCredentials.valids%\.u2:::r.)rr') r)r*r+r,rrrWr}rrrNrrrs@r/_RefreshableAsyncCredentialsrs \ \ $ $ $ $ $ $      c3h        " ;t ; ; ;X ; ; ; ; ;r.rc"eZdZefdeddfdZdS)@BaseApiClient._get_aiohttp_session..AiohttpClientSession _warningsr0NcH|js|dd}|j|j|d<dSdSdS)NzUnclosed client session)client_sessionmessagesource_traceback)r}_source_traceback)rrcontexts r/rzHBaseApiClient._get_aiohttp_session..AiohttpClientSession.__del__ sR; E$(6g'3.2.D*+++  E E 43r.r)r*r+r>rrr-r.r/AiohttpClientSessionrsG-5 E Es E$ E E E E E Er.rc"eZdZefdeddfdZdS)?BaseApiClient._get_aiohttp_session..AiohttpTCPConnectorrr0Nc|jrdS|jsdSd|jD}|||dd}|j |j|d<dSdS)Nc,g|]}t|Sr-)repr)rrs r/rz[BaseApiClient._get_aiohttp_session..AiohttpTCPConnector.__del__..s;;;T!WW;;;r.zUnclosed connector) connector connectionsrr)r_connsvalues_closer)rrconnsrs r/rzGBaseApiClient._get_aiohttp_session..AiohttpTCPConnector.__del__s| f; f;;dk&8&8&:&:;;;E KKMMM!$/G %1,0,Bg()))21r.rr-r.r/AiohttpTCPConnectorrsG-5 C Cs C$ C C C C C Cr.r)limitT)r trust_env read_bufsize)rDrr#r$rGrrUr6rrYrurvrAsyncAuthorizedSessionrZr ClientSession TCPConnectorr) rrr{ruAsyncCredentialsrrrrs r/_get_aiohttp_sessionz"BaseApiClient._get_aiohttp_sessions (/   ..  # % %D  ''(>???&**400g  !8!8!A!A    $ $ & &M &     &445RSS_ #,#:#:;_#`#`#w  ; ; ; ; ;-= ; ; ;<+*+G+G+M+MNN''    $  E E E E E7#8 E E E C C C C C'"6 C C C&'&))222)    1  ! 1 1)0$  & 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 Ns7ABBB1AD DD2 F  F F FrFcd|j}|j}|r|n|r|nd}||rVttdd}|> |}n2#t $r%}t d|Yd}~nd}~wwxYw|btj tj dtj tj d}dttjd tjd tjffd }||||||fS) a,Ensures the SSL context is present in the HTTPX client args. Creates a default SSL context if one is not provided. Args: options: The http options to check for SSL context. vertexai: Whether Vertex AI is enabled. Returns: A tuple of sync/async httpx client args. verifyNget_default_ssl_context6Failed to get default SSL context from google-auth: %s SSL_CERT_FILE SSL_CERT_DIRcafilecapathargsctxr0c*|pi}|s||<d|vrd|d<|}|D]/}|tjtjjjvr||=0|S)-Sets the SSL context in the client args if not set. Does not override the SSL context if it is already set. Args: args: The client args to to check for SSL context. ctx: The SSL context to set. Returns: The client args with the SSL context included. ruN)rr6inspect signaturerClientr parametersrr copied_argsrRrs r/ _maybe_setz7BaseApiClient._ensure_httpx_ssl_ctx.._maybe_setbsjb   d XXf  V $  YIIKKk!!### g' (=>>I I I# r.)rkrlr6rLrrr7r8r9create_default_contextr4r5certifiwhererr StringDict SSLContext) rFr(r async_argsr get_ctx_fnrrrs @r/rMz#BaseApiClient._ensure_httpx_ssl_ctx3s"F  D*J   Z^^F+++   { XT#>/7=??CC:>>.11    w)* ^  8  4 :s## s A** B4BBcFd|j}|r|nd}||rVttdd}|> |}n2#t$r%}t d|Yd}~nd}~wwxYw|btjtj dtj tj d}dttjd tjd tjffd }|||S) 1Ensures the SSL context is present in the async client args. Creates a default SSL context if one is not provided. Args: options: The http options to check for SSL context. vertexai: Whether Vertex AI is enabled. Returns: An async aiohttp ClientSession._request args. r9Nrrrrrrrr0c|r|s|pi}||<|}|D]/}|tjtjjjvr||=0|S)r)r6rrrrr_requestrrs r/rz9BaseApiClient._ensure_aiohttp_ssl_ctx.._maybe_sets&))   ""V IIKKk!!### $W%:%CDDO P P# r.rlr6rLrrr7r8r9rr4r5rrrrrrrFr(rrrrrrs @r/rWz%BaseApiClient._ensure_aiohttp_ssl_ctxsO F*J$. 8*.. DC { XT#>/7=??CC:>>.11    w)* ^  8 :j# & && A A;A66A;cFd|j}|r|nd}||rVttdd}|> |}n2#t$r%}t d|Yd}~nd}~wwxYw|btjtj dtj tj d}dttjd tjd tjffd }|||S) rr9Nrrrrrrrr0c|r|s|pi}||<|}|D]+}|tjtjvr |dkr||=,|S)rr9)r6rrr ws_connectrrs r/rz;BaseApiClient._ensure_websocket_ssl_ctx.._maybe_sets&))   ""V IIKKk!!### g' 33> > >3%<<# r.rrs @r/r\z'BaseApiClient._ensure_websocket_ssl_ctxsQ"F*J$. 8*.. DC { XT#>/7=??CC:>>.11    w)* ^  2 :j# & &&rcrto0|jjpidduo |jjduS)N transport)rrDrlr6rSrs r/rVzBaseApiClient._use_aiohttpsJ  <   1 7R < <[ I I   <  2d : r.c|jr|jp|j}|jr |s|jSt |jj}|dS)Nwss)scheme) rfr+r*r)rrDr[rbgeturl)rrj url_partss r/_websocket_base_urlz!BaseApiClient._websocket_base_urlsl<9DMJdl "$7" !!+455I   U  + + 2 2 4 44r.c|j5|js+t|j\|_}|js||_|jr!t ||jcdddSt d#1swxYwYdS)z/Retrieves the access token for the credentials.r5N0Could not resolve API token from the environment)rGrCrorfget_token_from_credentialsr)rrfs r/ _access_tokenzBaseApiClient._access_tokens  O O  !%.t|%D%D%D"7| ! $, O)$0ABB O O O O O O O OMNNN O O O O O O O O O OsAA2#A22A69A6cKtj}|j5||j||jvrtj|j|<|j|cdddS#1swxYwYdS)aLazily initializes and returns an asyncio.Lock for async authentication. This method ensures that a single `asyncio.Lock` instance is created and shared among all asynchronous operations that require authentication within the same event loop. N)r#r$rGrrHrFrs r/_get_async_auth_lockz"BaseApiClient._get_async_auth_lock's  # % %D ** ''(>??? T+ + +'.|~~t$  #D ) ******************sA A55A9<A9cK|js|d{V}|4d{V|jsRetrieves the access token for the credentials asynchronously.Nr5r)rCrr# to_threadrorf async_get_token_from_credentialsr)rasync_auth_lockrfs r/rz!BaseApiClient._async_access_token5s   #"7799999999o # # # # # # # #  #-4->. . . ( ( ( ( ( ( $$ W #"DL " # # # # # # # # # # # # # # # # # # # # # # # # # # # M3    K L LLsAB B B  http_methodr\ request_dictcd|D}|D]}||=|rSt|trt|j|}n/t|jtj|}n|j}d}|jr|dkr|drd}|jrW|dsB|s@|js|j r2|j r|j tj ksd|jd|j d|z}|jd|} n |jd|} |j|jst!d |j} t#|d r!|jrt'j||j| } |j r|jr|j s|jr7|j tj krt-| |} n=t-| | } n,|j r%|j tj krt-| |} |jr)|jd rt/d t1|j} |jt!d t7|j| t9|| |j|| S)Nc<g|]}|d|S)ry)ra)rrRs r/rz0BaseApiClient._build_request..Ts)PPPcCNN3j !|tE|j|r|n|j#gS)Nrrrrrrmax_refresh_attemptsgoogleapis.comsandboxsandbox.googleapis.commtls.sandbox.googleapis.commtls.googleapis.comr{rzr|r<rurr{rzrr<rur)$r(rfr+r*rr<rCrr|rdumpsrrrrrWrzrPrrr rdefault_client_cert_sourceconfigure_mtls_channel_is_mtlsreplacerr{upperrurR build_requestsendrrraise_for_responsertext) rrrr|rzr client_cert_sourcer httpx_requests r/ _request_oncezBaseApiClient._request_onces )-D } #$, #$- # #.N8J8J8L8L.N.Nl?+  t0A   . 23/;.? ITZ ) * * *Tdd  #,+U33 #2>2CML-...$$"$ !!##$G   ! !c ! )DDDDDD#4#4  !"$ $ $  "<>>  77      ! *E/?3/F/F    &(E  ## ,.CDD#)11$**,,&& 2hh(66$&& 7m#((v(FFh O&&x000 fA((8=/  r.c|rat|tr tdi|n|}|jr7t |j}t jdi|}||j||S||j||SNr-) rr}rr[r rr^rr_rrr,rparameter_modelrmrs r/rzBaseApiClient._requests  ? d + + + % % % % %  &?!/"?@@ !11L11uT'v>>> ;;t)< @ @@r.c RKd}|jra|js|jrS|jsLd|d{V|jd<|jr |jjr|jj|jd<|jrNt|jts-tj |j d}n|j}|r|rV|d{V}|j}|rjt%j}||d{V|jr5d|vr1d|vr|dd}n|dd } |jd|j||j|t3j|j d |jd{V}n##t2jt2jt2jt2j tBj"f$r}tGj$d tKj&d dzd{VtN(d|z|)|j*tW|j|_|d{V}|jd|j||j|t3j|j d |jd{V}Yd}~nd}~wwxYwtXj-.|d{Vt_|dr|j0}tc|j|S|j23|j|j||j|j} |j24| |d{V} tXj-.| d{Vtc| j| S|r|d{V}|j}|rjt%j}||d{V|jr5d|vr1d|vr|dd}n|dd } |jd|j||j|t3j|j d |jd{V}tXj-.|d{V|} t_| dr| j0} tc| j| 5d{VgS#t2jt2jt2jt2j tBj"f$rP}tGj$d tKj&d dzd{VtN(d|z|)|j*tW|j|_|d{V}|jd|j||j|t3j|j d |jd{V}tXj-.|d{V|} t_| dr| j0} tc| j| 5d{VgcYd}~Sd}~wwxYw|j2|j|j|j||jd{V} tXj-.| d{Vtc| j| j5gS)Nrrrrrr r r r totalrrr z!Retrying due to aiohttp error: %sr8 _responserrr{rzr<rrur-)6r(rfr+r*rr<rCrr|rrrrencoderVrrzrYrrrrrrr{r ClientTimeoutrurXClientConnectorErrorClientConnectorDNSError ClientOSErrorServerDisconnectedErrorauth_exceptionsTransportErrorr#sleeprandomrandintr7rIrWrDrNrrraise_for_async_responserpr%rrTrrr) rrrr|r{rzrrrrclient_responseunwrapped_responseunwrapped_retry_responses r/_async_request_oncez!BaseApiClient._async_request_once sQ !D } $, $-  6$2244444444 6 6?+   t0A   . 23!  )5 1 1!z,+,,33G<<  WM    GF1133333333  & & ( ( I#>@@ ..            I"2c"9"9CKK*,IccKK 02GHHc" *7? !("*+,2FGGG   7         ((  (  +  !  +  *      a&.A"6"6677 7 7 7 7 7 7 7 ++9A= > > >**$ ..+  13355555555'*7? !("*+,2FGGG   7         ((((((% 6o66x@@@@@@@@@ 8[ ) ) ('(H,h7770>>&  ( ( ?  !% 8 = = !>! !       o66GGGGGGGGGO3_EEE    MM1133333333  & & ( ( I#>@@ ..            I"2c"9"9CKK*,IccKK 02GHHc3 *7? !("*+,2FGGG   7         (88BB B B B B B B B$,  ' 5 5 >!3!=  (1C1H1H1J1J+J+J+J+J+J+J*K     (  +  !  +  *  " " "  a&.A"6"6677 7 7 7 7 7 7 7 ++9A= > > >**$ ..+  13355555555'*7? !("*+,2FGGG   7         (88BB B B B B B B B*2 " -{ ; ; J'?'I $&.-22444444445        ?" J!% 8 @ @&  ( ( !A! !       o66GGGGGGGGGO3o6J5KLLLs::AF<<)rrrrrrarrr raise_errorr6decoderrr7debugr@r<) rrr\rr,rsession_responser chunk_dump chunk_jsons r/request_streamedzBaseApiClient.request_streamedsK&&T<L}}\<}MM!**,,OO:e$$j    - - z*--* / % %nnWb))--f55   \ )    ?* L      $4$<: N N NNNNNOOsA1C1DDcK|||||}|||dd{V}|jr |jdnd}t|j|S)NFrr,rrrr>)rr8rr@r<)rrr\rr,rresultrAs r/ async_requestzBaseApiClient.async_requests&&T<L&&! U'F281GOF*1--RM 6> F F FFr.cK|||||}|||dd{Vfd}|S)NTrNcK23d{V}tj|} |drbtj|}tj|did|d{Vn7#tjj $r t d|zYnwxYwtj |WV6dS)NrCrDrrEr>)rrrarrrraise_error_asyncr6rGrr7rHr@r<)rrJrKrs r/async_generatorz=BaseApiClient.async_request_streamed..async_generator sA!IIIIIIIZ&&    " "; / / J//J/33w++//77        |+    ,,AJN    $   h&6ZHHHHHHHH"sC+A7B1C C)rr8)rrr\rr,rrTrs @r/async_request_streamedz$BaseApiClient.async_request_streameds&&T<L((! T)HIIIII$ ?  r.r, file_path upload_url upload_sizect|tjr|||||St |d5}|||||cdddS#1swxYwYdS)a%Transfers a file to the given URL. Args: file_path: The full path to the file or a file like object inherited from io.BytesIO. If the local file path is not found, an error will be raised. upload_url: The URL to upload the file to. upload_size: The size of file content to be uploaded, this will have to match the size requested in the resumable upload request. http_options: The http options to use for the request. returns: The HttpResponse object from the finalize request. rVrbN)rioIOBase _upload_fdopen)rrWrXrYr,files r/ upload_filezBaseApiClient.upload_file4s,)RY'' __ Z<  4  D *k                     sA**A.1A.r`cd}|r|n|j}t|tr|dnt |dd}|rLt |}t |}t ||j|j } | t} d} | rt| } d} | |z|kr| dz } t|tr|dn|j } | 2t|jtr |jj n |jj } t| } t|tr|d int |d ipi}|rt|ni}|| t!|t!| d t#|| d}|t$krp|jd ||| | }|jd rn6t,t.|zz}|dz }t1j||t$kp|| z }|jd dkrn||krt5dt6j||jd dkrt5dt=|j|jgS)aTransfers a file to the given URL. Args: file: A file like object inherited from io.BytesIO. upload_url: The URL to upload the file to. upload_size: The size of file content to be uploaded, this will have to match the size requested in the resumable upload request. http_options: The http options to use for the request. returns: The HttpResponse object from the finalize request. rr[NrnetlocTupload , finalizerur<zX-Goog-Upload-CommandzX-Goog-Upload-OffsetzContent-LengthPOSTr&x-goog-upload-statusractiveFAll content has been uploaded, but the upload status is not finalized.final6Failed to upload file: Upload status is not finalized.r) rDrr}r6rLrrrbrrdread CHUNK_SIZErrurwupdaterWrZMAX_RETRY_COUNTrRrr<INITIAL_RETRY_DELAYDELAY_MULTIPLIERtimer/rlrrrrr)rr`rXrYr,offsetr[rc parsed_upload file_chunk chunk_sizeupload_commandrurU user_headersupload_headers retry_countr delay_secondss r/r^zBaseApiClient._upload_fdTs[(F#/G<> O P PP (8=/ J J JJr.i)r, destinationryrrycdSrr-rr\r,rrys r/ download_filezBaseApiClient.download_file Cr.)r,rycdSrr-rs r/rzBaseApiClient.download_filerr.cQtttjfs0t ds t dt d|d|i|}d}|jr;t|jtstj |j}n|j}dttddffd }| rt|j}|jJd d lm} | |jd |_t'j} |j| |jjr5d|vr1d|vr|dd}n|dd}|j|j|||j|jd} t:j| || || !n#| !wxYwdS|j|j|||j|j} t:j| tEt| j#S|j$%|j|j||j|j} |j$&| d} t:j| || '|| !n#| !wxYwdS|j$|j|j||j|j} t:j| | (S)aUDownloads the file data. Args: path: The request path with query params. http_options: The http options to use for the request. destination: Optional local file path or writable stream. chunk_size: The chunk size in bytes to stream. Returns: The file bytes if destination is None, otherwise None. NwriteUnsupported destination type: <. Expected str, os.PathLike, or a writable file-like object.r6r\rr,chunksr0c6tttjfrFt d5}|D]}|| ddddS#1swxYwYdS*t dr|D]}|dSdSdSNwbr)rrWr4PathLiker_rrp)rfrrs r/ _write_chunksz2BaseApiClient.download_file.._write_chunkss K#r{!3 4 4# +t $ $   e GGENNNN                     "w{G'D'D " # #E   E " " " " # " " " # #sAA #A rrrrrr r r r Tr ryr{rzr|r<rurr))rrWr4rrprlrrr|rrrrrrrzrPrrr rCrrrrrrr{rr<rurrr iter_contentrr rrRrr iter_bytesro) rr\r,rryrr|rrzr rrrs ` r/rzBaseApiClient.download_files6&zc2;'((k7++  G4 +<+< G G G   && Dr 'L)-D!  )5 1 1!z,+,, #huo#$###### !!##F   ! !c ! )DDDDDD#4#4  !"$ $ $  "<>>  77      ! *E/?3/F/F    &(E  ## ,.CDD#  +33&,,.. ( ( 4    / , ,X 6 6 6 ----DD E E E ..    (..    t+33&,,.. ( ( 4   **8444E8+,,,  *88&  ( ( 9  %**=*FF  / , ,X 6 6 6 -++z+BB C C C ..    (..    t%--&  ( ( .   **8444}}s >HH4>MM-cpKt|tjr|||||d{VSt j|}|dd{V}|4d{V|||||d{Vcdddd{VS#1d{VswxYwYdS)aTransfers a file asynchronously to the given URL. Args: file_path: The full path to the file. If the local file path is not found, an error will be raised. upload_url: The URL to upload the file to. upload_size: The size of file content to be uploaded, this will have to match the size requested in the resumable upload request. http_options: The http options to use for the request. returns: The HttpResponse object from the finalize request. rVNr[)rr\r]_async_upload_fdanyioPathr_)rrWrXrYr,r`fds r/async_upload_filezBaseApiClient.async_upload_fileDs*)RY''  (( Z<)Z " "d4 b        **  Kl+                                      s3B%% B/2B/c Kd}|r|n|j}t|tr|dnt |dd}|rLt |}t |}t ||j|j }| r| d{V} t|tj r|t} n |td{V} d} | rt!| } d} | |z|kr| dz } t|tr|dn|j} | 2t|jtr |jjn |jj} t%| }t|tr|d int |d ipi}|rt|ni}|| t)|t)| d t+||d}d}|t,kr| d || |t1j|  d{V}|jdrnL  Y + + +, 266<"  0<Cl+++%3$'KK!*oo     '~7IJJJ O++"??$+2DEEE +        (  ! !"8 9 9  -1A;1NO-  + m,, , , , , , , ,O++ *   $$%;<<HH  &    B H O 4 4X > >>>>>>>>  ""#9::gEE D     8==??-B-B-B-B-B-B,C E dBI & & 3yy,,**!YYz22222222*  ':*!  + - - L (.,-- &L  Y ' ' '%  ?D.55.d ((%-  4G<<,-- >L  Y + + +, 266<"  0<Cl+++%3$'KK!*oo     '~7IJJJ O++"&":"B"B $( #C# #       /)!)*!)--.DEE* -1A;1NO-  + *] # # #!O++$ *  ''++,BCCxOO  &    EE N O 4 4_ E EEEEEEEE  %%))*@AAWLL D     !O4H3Ir.c KdSrr-rs r/async_download_filez!BaseApiClient.async_download_file0 Cr.c KdSrr-rs r/rz!BaseApiClient.async_download_file; rr.c KQtttjfs0t ds t dt d|d|i|}d}|jrNt|jts-tj |j d}n|j}dttd dffd }|r|d{V}|j} |rjt%j} || d{V|jr5d | vr1d | vr| d d} n| d d} |jd|j| |j|t5j|jd|jd{V}  t<j | d{Vt | dr| j!} n| } || j"#|d{V| $n#| $wxYwdS t<j | d{VtKt| &d{V| $S#| $wxYw|j'(|j|j||j|j} |j')| dd{V} t<j |d{V||*|d{V|+d{Vn#|+d{VwxYwdS|j'|j|j|j||jd{V}t<j |d{V|&S)adDownloads the file data asynchronously. Args: path: The request path with query params. http_options: The http options to use for the request. destination: Optional local file path or writable stream. chunk_size: The chunk size in bytes to stream. Returns: The file bytes if destination is None, otherwise None. Nrrrr6rrrr0cKtttjfrLt d5}|23d{V}||6 ddddS#1swxYwYdSNt dr@|23d{V}|}tj|r|d{V96dSdSdSr) rrWr4rr_rrpr isawaitable)rrrresrs r/rz8BaseApiClient.async_download_file.._write_chunksl s_ K#r{!3 4 4 +t $ $ #       E GGENNNN$V                    "w{G'D'D "!       %!!%((#   % % IIIIIII"66 # " " "s!A$AA$$A(+A(B>rr r r r r"rr%rTrrr&r-),rrWr4rrprlrrr|rrrr'rrVrrzrYrrrrrrr{r<rr(rurXrrr2r%r iter_chunkedrr rorTrr aiter_bytesr)rr\r,rryrr|rr{rzrr raw_responserr3s ` r/rz!BaseApiClient.async_download_fileF s&zc2;'((k7++  G4 +<+< G G G   && Dr 'L!D!  )5 1 1!z,+,,33G<<  M%$8 T       G&//11111111g  c $ $ & & G!<>>,,             G 0C 7 7 #  ++(*GCC++.0EFFC&w$&'l.BCCC   3 h   88BB B B B B B B B X{ + + $#-LL#L l2?? KKLL L L L L L L L ..    (..    t 88BB B B B B B B Be8==??22222233 ..    (..      0>>&  ( ( ?  !% 8 = = !>! !        )88II I I I I I I I ))Z)@@          &&(( ( ( ( ( ( ( ( (&&(( ( ( ( ( ( ( ( (t $ 8 @ @&  ( ( !A! !       o66GGGGGGGGG##%%%s'A(II+1AKK-A N--O response_modelcdSrr-)rrs r/_verify_responsezBaseApiClient._verify_response sDr.c|jjs |jr|j|jr|jdSdS)zCloses the API client.N)rDrQrRrrPrs r/rzBaseApiClient.close sa   *!t/A!     ' $$&&&&&''r.cK|jjs|jd{V|jr|jjs t j}n#t$rd}YnwxYwt|j D]w\}}||kr| d{V&| r9 t j | |c#t$rYowxYwtdSdSdS)zCloses the API async client.N)rDrSrTrrUrr#r$rrrr is_runningrun_coroutine_threadsafe)r current_looprr{s r/rzBaseApiClient.aclose s`   0.  $ + + - --------  d&8&G /11    6 < < > >??-$ <            __      ,W]]__d C C C C    D       s$A A%$A% 'C11 C>=C>c |jjs|n#t$rYnwxYw t j|dS#t$rYdSwxYw)zCloses the API client when the object is garbage collected. ADK uses this client so cannot rely on the genai.[Async]Client.__del__ for cleanup. N)rDrQrrr#r$r%rrs r/rzBaseApiClient.__del__ s   ,     d     ,,T[[]];;;;;     dd s # 008A.. A<;A<)NNNNNN)Frrr)Lr)r*r+r,r(rrNr~r)rWrirjrmrrrrrrYrr staticmethodr}rrrrrr rrrMrWr\rVrrr#rFrr rrryrrrrr6r8r<r@rrrLrPrUr\r]intrar^r rrr4rrr AsyncFilerrrrrrrr-r.r/r'r'~s @@!(HTN!!!#'/8C='''"&#CG# $26B?B?B?}B?FK3?@ B? } B?  B?./B?B?B?B?H T    d(       DcN t   <   }    8 c ccccJLLLL W !3 34LLL<L\>'>'>'>'>'>'>'<>'@A'A'A'A'A'A'A'<A'FD535555 OS O O O O *', * * * *MsCxMMMM837 iii if% i ./ i  iiii\==== ====D37 AAA./A A  AAAA*7<kMkM%kM/3kMkMkMkMkM`37 ./   *'*<37 III If% I ./ I  IIII*37 OOO Of% O ./ O $,- OOOOD37 GGG Gf% G ./ G  GGGG,37 !!! !f% ! ./ !  !!!!R37    sBI~&    ./      L37 aKaKaK IaKaK aK ./ aKaKaKaKaKF 37#  ./       8 37#  ./  bk#. 9:     837GK# uuu u./ u E#r{3'7"BCD u  uuuuuz37    sBI~&    ./      N37 III ")U_S11 2II I ./ IIIIIV 37#  ./       8 37#  ./  bk#. 9:     837GK# x&x&x& x&./ x& E#r{3'7"BCD x&  x&x&x&x&x&z W-> 4    ''''*      r.r'rcv|js|jst||jstd|jS)=Refreshes the authentication token for the given credentials.r)rrrtr)rrms r/rr sK  1  K I J JJ  r.cDK|js|jst|d{V}|4d{V|js|js tjt |d{Vdddd{Vn#1d{VswxYwY|jst d|jS)rNr)rrrr#rrtr)rrmrs r/rr sU ; 1;"7799999999O;;;;;;;;  ;K$5; k:::::::::;;;;;;;;;;;;;;;;;;;;;;;;;;;  K I J JJ  s/A44 A>A>)xr,r#collections.abcrr dataclassesrrr\rrrXr4r0r9r@rErutypingrrrrr r r r r urllib.parserrr>rr google.authrigoogle.auth.credentialsrgoogle.auth.transportrrr-rpydanticrrrrrrrtypesrrrr@rrwebsockets.asyncio.clientrrModuleNotFoundErrorwebsockets.clientrrrZhttpx2rrr multidictr!requests.structuresr" getLoggerr7rprrrrsrtrJrrrrTimeoutException ConnectErrorrrlr(rWr;r}rErTrrrZrerortrwryrrrrrrrr rr  AsyncClientr r'rjrmrrr-r.r/rsV" %%%%%% !!!!!!   ffffffffffffffffffffff!!!!!!###### //////&&&&&&555555 $$$$$$$$$$$$222222###### 6=======666555555556  ...++$---- &&&6>>>>>>((((((555555  5 6 6  !4L U^enfo-NU]U]FN,K ~ U/00    22222 222 :#::::"8DcN8t8888@ )48E #s(^E19%s :K1LE EEEEGCGsGsGGGG%T *u[#5E/F"kk  eE3J' (  e_     """"""" "NNNNNNNNj  !12 w7I    F     el   *     u(   (v v v v v v v v r;   (4       (4 s6C C%$C%+C22C:9C:>DD  D