uPjUdZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z ddl m Z ddlZddlmZddlmZddlmZdd lmZdd lmZmZd d lmZmZmZmZmZd Z e e!d<er ddl"m#Z$ddl"m%Z%ne Z$GddZ&y)z Base Vertex, Google AI Studio LLM Class Handles Authentication and generating request urls for Vertex AI and Google AI Studio N)Mapping) TYPE_CHECKINGAnyFinalLiteral)urlparse)verbose_logger)asyncify)AsyncHTTPHandler)get_secret_str)VERTEX_CREDENTIALS_TYPESVertexPartnerProvider)_get_gemini_url_get_vertex_urlall_gemini_url_modesget_vertex_base_model_nameget_vertex_base_urlzqGoogle Cloud SDK not found. Install it with: pip install 'litellm[google]' or pip install google-cloud-aiplatformGOOGLE_IMPORT_ERROR_MESSAGE) Credentials TokenStatec eZdZdLfd ZededzdedefdZdedzdedzdee effd Z d Z d Z d Z d ZdZdZdefdZdedzdedzdefdZe dMdededededzdededzdefdZdedzdedzdedzdedededzdedefdZde ddfdZdedej2fdZdedej2ddfdZdededzdeeefdzfdZdededzdeeed e edzfdzfd!Zdedee edzffd"Zde dd fd#Zdedzdedzdedee edzffd$Z de ded%edzddfd&Z!deddfd'Z"de ded%edzddfd(Z#dedzdedzd)e$d*deeeffd+Z%d,e&defd-Z' dNdedzd)ed.edzd/ededzd0edzd1ededzdedzdedzd2e$d3dzd4edeedzeffd5Z( dOded0edzd.edzdedzdedzd6edzdedzd)e$d*dedzd7edzd8e)d4edeedzeffd9Z*dedzdedzded:e+deeeff d;Z,dedzdedzded:e+deeeff d<Z- dPdedzdedzd=edeeeffd>Z.dedzdedzdeeeffd?Z/dedzdedzd)e$d*deeeffd@Z0d0edzdAe&dzde&fdBZ1edCe&dedzfdDZ2edCe&dedzfdEZ3edCe&dedzfdFZ4edCe&dedzfdGZ5edCe&dedzfdHZ6edIe7ee8fdedzfdJZ9edCe7ee8fdedzfdKZ:xZ;S)Q VertexBasereturnNct|d|_d|_d|_i|_d|_d|_i|_i|_ i|_ tj|_ yN)super__init__ access_token refresh_token _credentials_credentials_project_mapping project_id async_handler_async_refresh_locks_async_refresh_lock_refcounts_background_refresh_tasks threadingRLock_sync_refresh_lock)self __class__s k/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/llms/vertex_ai/vertex_llm_base.pyrzVertexBase.__init__*sq (,)-<@  )'+6:@B!?A*DF& #,//"3 vertex_regionmodelcddl}|jdsd|n|}|jj|i}|jd}|r>2E#F %6!7!!;$(++$55&&i!%%a( )++ - -r/ credentialsr$c,|t|trtjj |}t j d|tj |r*t|5}tj|}dddntj|}n*t|tr|}nt!dt|dvr|ddk(r|j#di}t|tr|j#ddnd}t|trHd |vrDd d lm} | j)|} | r| j+|| d g } n|j-|d g} nt|trd|vr|j/|d g} nX|j1|d g} nCd|vr+|ddk(r#|j3|d g} |!| j4}n|j7|d g} |(t9| dd}n|j;d g\} } || }|j=| |s t!dt|tst?dt|| |fS#1swYxYw#t$r&}tdt|jd}~wwxYw)NzCVertex: Loading vertex credentials, is_file_path=%s, current dir %szUnable to load vertex credentials from environment. Ensure the JSON is valid (check for unescaped newlines in private_key). Parse error: zInvalid credentials type: typeexternal_accountcredential_sourceenvironment_idawsr)VertexAIAwsWifAuthz.https://www.googleapis.com/auth/cloud-platform) aws_paramsscopesrH executableauthorized_userr$Could not resolve project_idz(Expected project_id to be a str but got ) isinstancestrospathexistsr debuggetcwdopenjsonloadloads Exceptionr@__name__dict ValueErrorr8(litellm.llms.vertex_ai.vertex_ai_aws_wifrFextract_aws_paramscredentials_from_explicit_aws(_credentials_from_identity_pool_with_aws_credentials_from_pluggable_credentials_from_identity_pool!_credentials_from_authorized_userquota_project_id!_credentials_from_service_accountgetattr_credentials_from_default_auth refresh_auth TypeError) r,r>r$_is_pathfjson_objerBrCrFrGcredscreds_project_ids r. load_authzVertexBase.load_authcs  "+s+"$''..#$$YIIK !+.4!'+yy|H44$(::k#:K.& #=d;>O=P!QRR!hv&6:L&L+3<<8KR+P!CMN_aeCf%))*:B?lnnc2u7N);(M(Mh(WJ! 2 P P$'1$T#U!Q! !% M M$$T#U!N! 148\M^=^ << PQ=E !@@ PQAE 8#(8>LM?%..>>LM? !$UL$? &*&I&IHI'J' #E#!-  % ;< <*c*FtJGWFXYZ Zj  g44!#((,Q(8(8'9;s0 I$*II$I!I$$ J-!JJc ddlm}|jj |}|r)t |dr|jr|j|}|S#t$rttwxYw)Nr) identity_poolrequires_scopes) google.authrq ImportErrorrr from_infohasattrrr with_scopes)r,rkrHrqrms r.raz*VertexBase._credentials_from_identity_poolsi ; 1))33H= ge%67Erfrom_authorized_user_infor,rkrHgoogles r.rbz,VertexBase._credentials_from_authorized_usersP ; ,}}((44NNx`fNgg ;9: : ; 7Ac ddl}|jjj j ||S#t$rttwxYwr})google.oauth2.service_accountrtrrservice_accountrfrom_service_account_infors r.rdz,VertexBase._credentials_from_service_accountsQ ; 0}},,88RRS[djRkk ;9: : ;rcl ddlm}|j |S#t$rttwxYwr})rsauthrtrdefault)r,rH google_auths r.rfz)VertexBase._credentials_from_default_auths= ; -""&"11 ;9: : ;s3cy)Nr4)r,s r.get_default_vertex_locationz&VertexBase.get_default_vertex_locationsr/api_basevertex_locationcD|r|St|xs|jSr)rr)r,rrs r. get_api_basezVertexBase.get_api_bases# O"?#Xd6V6V6XYYr/vertex_projectpartnerstreamc| t|}|tjk(r |d|d|dS|tjk(r|r|d|d|d|dS|d|d|d|dS|tjk(r|r|d|d|d |dS|d|d|d |dS|tj k(r|r|d|d|d |dS|d|d|d |dSy) z1Return the base url for the vertex partner modelsNz /v1/projects/z /locations/z#/endpoints/openapi/chat/completionsz/publishers/mistralai/models/z:streamRawPredictz :rawPredictz/v1beta1/projects/z/publishers/ai21/models/z/publishers/anthropic/models/)rrllama mistralaiai21clauderrrrr1rs r.create_vertex_urlzVertexBase.create_vertex_url s  *?;H +11 1Z}^,">-)7Z #?#  +11 1# # %%c* +a /'--c226HH..$ + )7Z-#/  8r/c ddlm}|j5|j |dddy#t$rttwxYw#1swYyxYw)Nr)Request)google.auth.transport.requestsrrtrr+refresh)r,r>rs r.rgzVertexBase.refresh_authXs^ ;  $ $ +    * + + ;9: : ; + +s4AA Acredential_cache_keyc|jj|tj}|jj |ddz|j|<|S)aIncrement the refcount and return the lock for ``credential_cache_key``. Every call must be paired with ``_release_async_refresh_lock`` once the caller is done with the lock so the entry can be pruned when no other coroutine is holding or waiting on it. rr)r& setdefaultasyncioLockr'r8)r,rlocks r._acquire_async_refresh_lockz&VertexBase._acquire_async_refresh_lockls[//::;OQXQ]Q]Q_`  . . 2 23G Ka O **+?@ r/rc|jj|ddz }|dkDr||j|<y|jj|d|jj||ur|jj|dyy)aSDecrement the refcount and drop the lock entry when it reaches zero. Must be called only after the caller has released ``lock`` (i.e. once the surrounding ``async with`` has exited). asyncio is cooperative, so the decrement-then-pop sequence below runs atomically with respect to other coroutines. rrN)r'r8popr&)r,rr remainings r._release_async_refresh_lockz&VertexBase._release_async_refresh_lockys ==AABVXYZ]^^ q=GPD . ./C D  **../CTJ  $ $ ( ()= >$ F  % % ) )*> E Gr/cddlm}|j|\}}|Z|j||jk(r<|j 0t |j tr|xs|}|r|j |fSy)z Look up cached credentials and return (token, project_id) if the token is FRESH. Returns None if not cached or not fresh. rrN)google.auth.credentialsr_unpack_cached_credentials_get_token_stateFRESHtokenrMrN)r,rr$rrmcached_project_idresolved_projects r._try_get_cached_tokenz VertexBase._try_get_cached_tokensw 7#'#B#BCW#X   %%e, 0@0@@ '5;;,&0&E4E {{$444r/rcddlm}|j|\}}|y|j|}||j|j fvry|j t|j tsy|xs|}|sy|j ||||fS)a` Look up cached credentials and return usable token info for FRESH or STALE tokens (both are still valid for outbound requests). STALE tokens are returned along with their state and the underlying credentials object so the caller can schedule a background refresh without holding the per-key async lock. rrN) rrrrrSTALErrMrN)r,rr$rrmr token_staters r._try_get_usable_cached_tokenz'VertexBase._try_get_usable_cached_tokens 7#'#B#BCW#X  =!2259 z//1A1AB B ;; jc&B","A0A{{,k5BSSSr/c||jvry|j|}t|tr|S||jxs t |ddfS)z Return (credentials, project_id) from the cache, or (None, None) if not cached. Handles both tuple and legacy cache formats. )NNr$N)r#rMtuplercre)r,r cached_entrys r.rz%VertexBase._unpack_cached_credentialssW t'H'H H"??@TU lE * \::gglT`bf>gggr/cddlm}t|dd}t||r|St|ddr |jSt|ddr |j S|jS) z Return the token state using google-auth's TokenState enum. Falls back to expired/valid checks if token_state is unavailable (e.g. older google-auth versions or mock objects in tests). rrrNexpiredTvalidF)rrrerMINVALIDr)r,r> _TokenStaters r.rzVertexBase._get_token_statesb F$[-F k; /  ; 4 0&& & ; /$$ $"""r/cK t|j||d{\}}| t d||f|j|<||fS7)#t$r%}tjdt |d}~wwxYww)z@Load credentials via load_auth (in thread) and cache the result.r>r$Nz%Failed to load vertex credentials: %szCould not resolve credentials)r rorXr exceptionrNr[r#)r,r>r$rr"credential_project_idrls r._load_and_cache_credentialsz&VertexBase._load_and_cache_credentialss 8P8P'%93 /L/  <= =  !C ))*>?2223   $ $%LcRSf U  s7B AAA"BA A> A99A>>Brc"K tjdt|j|d{|j |\}}||ur||f|j |<yy7/#t $rtjddYywxYww)u Refresh credentials in the background without blocking the calling request. Called when the token is still valid but nearing expiry (proactive refresh). Errors are logged but not raised — the current token is still usable. z'Background proactive credential refreshNz@Background credential refresh failed, will retry on next requestT)exc_info)r rRr rgrr#rX)r,r>rr cached_credsrs r._background_refresh_credentialsz*VertexBase._background_refresh_credentialss   !J K-(4,,-k: : :#==>RSOL!{*)K112FG+ ;   R  s8B3A)A'-A)%B'A)) B  B B  BcK|jj|}||jry |d{y7#t$rYywxYww)abWait for an in-flight background refresh to finish, if any. google-auth's ``Credentials.refresh()`` is not safe to invoke concurrently on the same credentials object. Coroutines that need a blocking refresh must first drain any background refresh that was scheduled while a previous STALE token was being served. N)r(r8donerX)r,r existing_tasks r.#_await_in_flight_background_refreshz.VertexBase._await_in_flight_background_refreshsT $==AABVW  M$6$6$8        s1/A?=?A? A A A  Achjj}||jsyjjdt j j ||}dtjtddffd }|j||j<y)a1Kick off a single background refresh for ``credential_cache_key``. Skips scheduling if a refresh is already in flight. The done-callback guards against removing a newer task that has replaced this one in the tracking dict (done_callbacks are scheduled via ``call_soon``). N_futrczjj|urjjdyyr)r(r8r)rrr,s r._drop_background_refresh_taskzNVertexBase._schedule_background_refresh.._drop_background_refresh_task9s:--112FG4O..223GNPr/) r(r8rrr create_taskrFutureradd_done_callback)r,r>rrexistingtaskrs` ` r._schedule_background_refreshz'VertexBase._schedule_background_refresh%s88<<=QR     &&**+?F))  0 0>RTi j  Os0C O O <=?C&&';r$rs r._ensure_access_tokenzVertexBase._ensure_access_token@s- ( *(('%) r/optional_paramscy)z use this helper to decide if request should be sent to v1 or v1beta1 Returns true if any beta feature is enabled Returns false in all other cases Fr)r,rs r.is_using_v1beta1_featuresz$VertexBase.is_using_v1beta1_featuresSsr/rrrrr)rv1beta1use_psc_endpoint_formatc |r|dk(r+| td|d|d|}| td|d|i}n| rI| r| r|s tdt|} | xsd }d j|jd || | | |}nFt |j d vr(|jd t |j z}n|d|}|d ur|dz}||fS)ag for cloudflare ai gateway - https://github.com/BerriAI/litellm/issues/4317 Handles custom api_base for: 1. Gemini (Google AI Studio) - constructs /models/{model}:{endpoint} 2. Vertex AI with standard proxies - constructs {api_base}:{endpoint}; if api_base has no path (bare host), grafts the default vertex URL path onto it 3. Vertex AI with PSC endpoints - constructs full path structure {api_base}/v1/projects/{project}/locations/{location}/endpoints/{model}:{endpoint} (only when use_psc_endpoint_format=True) Args: use_psc_endpoint_format: If True, constructs PSC endpoint URL format. If False (default), uses api_base as-is and appends :{endpoint} ## Returns - (auth_header, url) - Tuple[Optional[str], str] rz;Model parameter is required for Gemini custom API base URLsz/models/rVMissing Gemini API key. Set the GEMINI_API_KEY or GOOGLE_API_KEY environment variable.x-goog-api-keyzYvertex_project, vertex_location, and model are required when use_psc_endpoint_format=True)r1rz.{}/{}/projects/{}/locations/{}/endpoints/{}:{}/)rDrTz?alt=sse)r[rformatrstriprrP)r,rrrrrrrr1rrrr model_for_urlversions r.rzVertexBase._check_custom_proxy\sB "h.=$%bcc! (5'8*=!)$p"-#3^"DK++5(w,FE+RM%7%?4GJQQ ,&'% Ch',, 9"//#.#1C1CCC%Jaz2C~J&Cr/vertex_credentialsshould_use_v1beta1_featuresmodec d} |dk(r#|s tdt| ||\}}d|i}n/|j||}| durdnd } t| ||||| \}}|j | |||||||||| | S) z Internal function. Returns the token and url for the call. Handles logic if it's google ai studio vs. vertex ai. Returns token, url Nrr)rr1rr)r0r1Trr)rr1rrrr) rrrrrrrr1rrrr)r[rr=rr)r,r1rrrrrrrrrrrrrrs r._get_token_and_urlzVertexBase._get_token_and_urls.48 ( *! l,MC ,^r$ _retry_reauthzUReauthentication retry failed for project_id: %s. Original error: %s. Retry error: %sN)r rRr#rrXr)r,r>r$rr retry_errors r._handle_reauthenticationz#VertexBase._handle_reauthentications2  ]_i 4#D#D D112FG (('%")     g  K sA A/A**A/cKtjd||jj|d |j |||d{\}}|Nt |t r>|}t |trtj|n|}||f}||f|j|<|jt |jt s,tdt|jjd| td|j|fS7#t$r} tjd||| |d} ~ wwxYww)zX Async reauthentication retry that stays within the per-key async lock. zUHandling async reauthentication for project_id: %s. Clearing cache and retrying once.N)r>r$rHCould not resolve credentials token. Got None or non-string token (type=)rLz[Async reauthentication retry failed for project_id: %s. Original error: %s. Retry error: %s)r rRr#rrrMrNrZrUdumpsrr[r@rYrXr) r,r>r$rrr"rcache_credentialsresolved_cache_keyrs r._handle_reauthentication_asyncz)VertexBase._handle_reauthentication_asyncs~  ceo  ))--.BDI% 66'%%97 % !j1F&L2 FPQ\^bFc4::k+Bit!-> ,K" !)I112DE !!)Lr$rrr r rL)rMrZrUr r rRr#rrcrerorXrr[rNrr+rgrrr@rY) r,r>r$rr rr"rrrlr s r.rzVertexBase.get_access_tokenRs2?IVZ>[4::k#:al'8*&E7; MzZ 4#D#D D  !OQ[ \"&"C"CDX"YL  !3\ B,.6B3 3 , (4(E(E(rQ]_kmqIr%  =%   \^h  6:nnQ\isn6t3 3# noynz{ %GD - -.B C 56  "7"C ShjmHn.J):J(G !)J)JJ )I112DE  AB B   (( '' &,,-NO)),7(1S99:NO  .    %Z 8J8JC-PZ[_`l`r`r[s[|[|Z}}~   ;< <!!:--C ((G  X%  83q6A-#'#@#@,7+55I&' $A$  (     sT.I K&7I; I8I33I8; J=#J8'J=(K6J88J==KK cKddlm}t|trt j |n|}||f}|j ||}|.|\}}} } } | |jk(r|j| || ||fS|j|} | 4d{|j||} | %| cdddd{|j|| S|j|\}}||j|||d{\}}|'t|tr|}||f}||f|j|<|j!|} | |jk(rr| t#d|j$}|t|ts |j&} n:|j|||||fcdddd{|j|| S| |j&k(r|j)|d{|j||} | %| cdddd{|j|| S t+j,dt/|j0|d{||f|j|<|j$t|j$ts,t#d t7|j$j8d | t#d|j$|fcdddd{|j|| S7h7E77\7$77#t2$ro}dt|vr\t+j,d|j5||||d{7cYd}~cdddd{7|j|| Sd}~wwxYw7#1d{7swYnxYw |j|| y#|j|| wxYww) aJ Async version of get_access_token with single-flight refresh coordination. Prevents thundering herd: when credentials expire under high concurrency, only one coroutine refreshes while others wait on the lock. Uses native async refresh for service_account and authorized_user credentials. rrNrLrrz4Reauthentication needed, clearing cache and retryingrr r )rrrMrZrUr rrrrrrrrrNr#rr[rrrr rRr rgrXrr@rY)r,r>r$rr rusable cached_tokenrrrmrrcachedr"rr  current_tokenrls r.get_access_token_asyncz!VertexBase.get_access_token_asyncs{ 7>HVZ>[4::k#:al'8*&E99:NPZ[  TZ QL*K@Qj...11%9MO`a!11 1667KL\ IY 6Y 6334H*U%! Y 6Y 6Y 6v  , ,-A4 Hk7;6U6UVj6k3 3 '#>>{JXlmm$-%*5JC*P!6J1BJ0O&%-MD556HI#33LA *"2"22!)()GHH+7+=+=M$,J}c4R'1&8&8 99(01 -j8cY 6Y 6Y 6v  , ,-A4 HQ*"4"44 BBCWXXX!778LjYF)%yY 6Y 6Y 6v  , ,-A4 H9&,,-NO9ht'8'89,GGG(1S99:NO  %%-Z @R@RTW5X$bcghthzhzc{dEdEcFFGH%$%CDD#)):5sY 6Y 6Y 6v  , ,-A4 HwY 6Y 6nY 6rYsY 6BH % 73q6A*001gh)-)L)L,7+55I&' *M*$$SY 6Y 6Y 6v  , ,-A4 H MY 6Y 6Y 6Y 6Y 6v  , ,-A4 HD , ,-A4 HsdBON0K6N0N( N04K95N09O ,N8K<9BN N0#K?$N0(O;#NLN8 N0LN0 O3L LL &A,N N0NN0#O6N09N0<N?N0NN0L  N:M= MM=NN N0#M&$N0)O<M==NNN0N N NN0O0OOcPK|dk(ry|j||d{S7w)z7 Async version of _ensure_access_token rrrN)rrs r._ensure_access_token_asyncz%VertexBase._ensure_access_token_asyncIs; ( *44'%5 s &$& extra_headerscHddi}|d||d<||j||S)Nz Content-Typezapplication/jsonzBearer Authorization)update)r,rrheaderss r. set_headerszVertexBase.set_headers\s? .   ")0 '>GO $  $ NN= )r/litellm_paramsc|jddxs1|jddxstjxs tdS)Nrvertex_ai_projectVERTEXAI_PROJECT)rr5rr r!s r.get_vertex_ai_projectz VertexBase.get_vertex_ai_projectgsN   / 6 2!!"5t< 2%% 201  r/ch|jddxs|jddxs tdS)Nrvertex_ai_credentialsVERTEXAI_CREDENTIALS)rr r%s r.get_vertex_ai_credentialsz$VertexBase.get_vertex_ai_credentialsps>   3T : 6!!"94@ 645 r/c|jddxs>|jddxs*tjxstdxs tdS)Nrvertex_ai_locationVERTEXAI_LOCATIONVERTEX_LOCATION)rr5rr r%s r.get_vertex_ai_locationz!VertexBase.get_vertex_ai_locationxs^   0$ 7 1!!"6= 1&& 112 1/0  r/c|jdxs0|jdxstjxs tdS)a Safely get Vertex AI project without mutating the litellm_params dict. Unlike get_vertex_ai_project(), this does NOT pop values from the dict, making it safe to call multiple times with the same litellm_params. Args: litellm_params: Dictionary containing Vertex AI parameters Returns: Vertex AI project ID or None rr#r$)r8r5rr r%s r.safe_get_vertex_ai_projectz%VertexBase.safe_get_vertex_ai_projectsJ   / 0 2!!"56 2%% 201  r/cd|jdxs|jdxs tdS)a Safely get Vertex AI credentials without mutating the litellm_params dict. Unlike get_vertex_ai_credentials(), this does NOT pop values from the dict, making it safe to call multiple times with the same litellm_params. Args: litellm_params: Dictionary containing Vertex AI parameters Returns: Vertex AI credentials or None rr(r))r8r r%s r.safe_get_vertex_ai_credentialsz)VertexBase.safe_get_vertex_ai_credentialss:   3 4 6!!"9: 645 r/paramsc|jd|jdfD]}t|ts|s|cSy)z The location explicitly configured in the given params, without any module-level or environment fallback. None when not configured. rr,N)r8rMrN)r4 configureds r.explicit_vertex_ai_locationz&VertexBase.explicit_vertex_ai_locationsC "::&78&**EY:Z[ "J*c*z!! "r/ctj|xs*tjxst dxs t dS)a Safely get Vertex AI location without mutating the litellm_params dict. Unlike get_vertex_ai_location(), this does NOT pop values from the dict, making it safe to call multiple times with the same litellm_params. Args: litellm_params: Dictionary containing Vertex AI parameters Returns: Vertex AI location/region or None r-r.)rr7r5rr r%s r.safe_get_vertex_ai_locationz&VertexBase.safe_get_vertex_ai_locationsC  2 2> B 1&& 112 1/0  r/)rNr)NNNNF)FchatF)F) T6 hu hsTWZ^T^I_ h#C#L#&3-43$J3$ 3 sC$J  3.$ #Tz   BeX\&DD$D #Tz D  D6-4$J% 3  sCx&$$!%)&*>B(-H *H !H d H  H t H 4ZH H TzH d H tH $O4t;H "&H  sTz3 H j49%+(-A A 4ZA d A d A t A 5t;A t A %%LMA *A &*D[A #A "&A  sTz3 A F0-40$J0$ 0  0 sCx 0d5-45$J5$ 5  5 sCx 5v$ w.-4w.$Jw. w. sCx w.r|I-4|I$J|I sCx |I|-4$J% 3  sCx& sTz $+ RV  d sTz   $ 3:   t d    4 C$J  ( t d   &GCK,@S4Z GCK4H SSWZ  r/r)'__doc__rrUrOr)collections.abcrtypingrrrr urllib.parserr5litellm._loggingr #litellm.litellm_core_utils.asyncifyr &litellm.llms.custom_httpx.http_handlerr litellm.secret_managers.mainr litellm.types.llms.vertex_air r common_utilsrrrrrr__annotations__rrGoogleCredentialsObjectrrrr/r.rMso  #55!+8C7XxUN2!` ` r/