ó
    °"³jêv  ã                  ó´  • S SK Jr  S SKrS SKrS SKrS SKJrJrJrJ	r	J
r
JrJrJrJr  S SKJr  S SKJrJr  S SKrSSKJrJrJr  SSKJrJr  SS	KJrJr  SS
KJ r   SSK!J"r"J#r#  SSK$J%r%  SSK&J'r'  SSK(J)r)J*r*J+r+  SSK,J-r-J.r.  \" \.SS9r/\" \-SS9r0\(       a  S SK1J2r3  Sr4Sr5\/ \64   r7\/ S4   r8\
" S\\Rr                  \Rt                  4   S9r;\
" S\\"\   \#\   4   S9r< " S S5      r= " S S\*\;\<4   5      r>            S%S jr?        S&S jr@S'S  jrA " S! S"\>\Rr                  \"\   4   \5      rB " S# S$\>\Rt                  \#\   4   \5      rCg)(é    )ÚannotationsN)	ÚTYPE_CHECKINGÚAnyÚUnionÚMappingÚTypeVarÚCallableÚSequenceÚ	AwaitableÚcast)Úpartial)ÚSelfÚoverrideé   )ÚTimeoutÚNotGivenÚ	not_given)ÚasyncifyÚis_given)Ú	AnthropicÚAsyncAnthropic)ÚFinalRequestOptions)ÚStreamÚAsyncStream)ÚAnthropicError)ÚMiddlewareInput)ÚDEFAULT_MAX_RETRIESÚ
BaseClientÚmerge_headersé   )Úrefresh_credentialsÚload_default_credentialsÚgoogle_cloud)Úextra)ÚCredentialsznhttps://claude.googleapis.com/v1alpha/projects/{project}/locations/{location}/workspaces/{workspace_id}/invokeÚglobalzstr | Awaitable[str]Ú_HttpxClientT)ÚboundÚ_DefaultStreamTc                  ó,   • \ rS rSrSrSS jrSS jrSrg)	Ú_GoogleCredentialsStateé/   u‘  Holder for the Google credentials object, its refresh lock, and the project
ADC resolved.

Shared between a client and its `copy()`/`with_options()` clones (when the
credential configuration is inherited) so a lazily-loaded ADC credential is
minted once â€” not once per clone â€” and concurrent loads/refreshes are
serialized: google-auth credential objects are not safe to `refresh()`
concurrently.
c                óR   • [         R                  " 5       U l        Xl        S U l        g ©N)Ú	threadingÚLockÚ_lockÚcredentialsÚadc_project)Úselfr2   s     Ú_/home/mande/repo/quber/.venv/lib/python3.13/site-packages/anthropic/lib/google_cloud/_client.pyÚ__init__Ú _GoogleCredentialsState.__init__:   s   € Ü—^’^Ó%ˆŒ
Ø5@ÔØ'+ˆÕó    c                ó²  • U R                      U R                  c  [        5       u  U l        U l        OKU R                  R                  (       d  U R                  R
                  (       d  [        U R                  5        U R                  R
                  nU(       d  [        S5      e[        U[        5      (       d   eUsSSS5        $ ! , (       d  f       g= f)zJReturn a valid access token, loading ADC / refreshing as needed. Blocking.NzKCould not resolve a GCP access token from the configured Google credentials)
r1   r2   Ú_load_adc_credentialsr3   ÚexpiredÚtokenÚ_refresh_credentialsr   Ú
isinstanceÚstr)r4   r<   s     r5   r<   Ú_GoogleCredentialsState.token?   s“   € à�Z‹ZØ×ÑÑ'Ü5JÓ5LÑ2�Ô  $Õ"2Ø×!Ñ!×)×)°×1AÑ1A×1G×1GÜ$ T×%5Ñ%5Ô6à×$Ñ$×*Ñ*ˆEÞÜ$Ð%rÓsÐsÜ˜e¤S×)Ñ)Ð)Ð)Ø÷ �Z�Zús   �B1CÃ
C)r1   r3   r2   N)r2   úGoogleCredentials | NoneÚreturnÚNone©rB   r?   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r6   r<   Ú__static_attributes__© r8   r5   r+   r+   /   s   † ñô,÷
r8   r+   c                  óº   • \ rS rSr% SrS\S'   S\S'   S\S'   S\S	'   S
\S'   S
\S'   \\SS j5       5       r\R                  SS j5       r\SS j5       r
SS jrSrg)ÚBaseGoogleCloudClientéN   zÒMarker base so `_is_base_client()` keeps these clients off the first-party
credential-discovery chain (it matches only the exact `Anthropic` /
`AsyncAnthropic` classes). Auth is handled entirely by this helper.ú
str | NoneÚworkspace_idÚ_projectr?   Ú	_locationr+   Ú_creds_stateÚboolÚ_base_url_deferredÚ_base_url_overriddenc                ó   • U R                   $ r.   )Ú	_base_url©r4   s    r5   Úbase_urlÚBaseGoogleCloudClient.base_urlZ   s   € ð �~‰~Ðr8   c                ó¨   • SU l         U R                  [        U[        R                  5      (       a  UO[        R                  " U5      5      U l        g )NF)rU   Ú_enforce_trailing_slashr>   Úhttpx2ÚURLrX   )r4   Úurls     r5   rZ   r[   _   s=   € ð #(ˆÔØ×5Ñ5¼ZÈÌVÏZÉZ×=XÑ=X±cÔ^d×^hÒ^hÐilÓ^mÓnˆ�r8   c                ó.   • U R                   R                  $ )zÎThe `google.auth` credentials in use (explicit or lazily-loaded ADC), if any.

Distinct from `.credentials`, which is the base client's first-party
credentials provider and is always `None` on this client.
)rS   r2   rY   s    r5   Úgoogle_credentialsÚ(BaseGoogleCloudClient.google_credentialsf   s   € ð × Ñ ×,Ñ,Ð,r8   c                óô   • U R                   (       d  gU R                  c  [        S5      eU R                  c   e[        R                  U R                  U R                  U R                  S9U l        SU l         g)z±Derive and set the real base URL once the project is known.

Called on every request (after the project back-fill from ADC, if any);
a no-op once the base URL has been derived.
NzÌNo `project` was provided and one could not be resolved from Google credentials. Pass the `project` argument, set the `ANTHROPIC_GOOGLE_CLOUD_PROJECT` environment variable, or provide `base_url` directly.©ÚprojectÚlocationrP   F)rU   rQ   r   rP   ÚDEFAULT_URL_TEMPLATEÚformatrR   rZ   rY   s    r5   Ú_resolve_deferred_base_urlÚ0BaseGoogleCloudClient._resolve_deferred_base_urlo   sw   € ð ×&×&ØØ�=‰=Ñ Ü ðHóð ð × Ñ Ñ,Ð,Ð,Ü,×3Ñ3Ø—M‘M¨D¯N©NÈ×IZÑIZð 4ð 
ˆŒð #(ˆÕr8   )rX   rU   rZ   N)rB   z
httpx2.URL)r`   zhttpx2.URL | strrB   rC   )rB   rA   )rB   rC   )rE   rF   rG   rH   rI   Ú__annotations__Úpropertyr   rZ   Úsetterrb   rj   rJ   rK   r8   r5   rM   rM   N   sz   ‡ ñKð ÓØÓØƒNØ)Ó)ØÓØÓàØóó ó ðð ‡_�_óoó ðoð ó-ó ð-÷(r8   rM   c                ój   • U b  U $ Uc   eUc  U(       a  g[        S5      e[        R                  XUS9$ )zõbase_url (arg or `ANTHROPIC_GOOGLE_CLOUD_BASE_URL`, resolved by the caller)
> derived template.

Returns `None` when derivation must wait for the project to be back-filled
from Google credentials on the first request (`allow_deferred_project`).
Nz‰No `project` was provided. Pass `project`, set the `ANTHROPIC_GOOGLE_CLOUD_PROJECT` environment variable, or provide `base_url` directly.re   )Ú
ValueErrorrh   ri   ©rZ   rf   rg   rP   Úallow_deferred_projects        r5   Ú_resolve_base_urlrs   …   sT   € ð ÑØˆð Ñ#Ð#Ð#Ø�Þ!ØÜðDó
ð 	
ô  ×&Ñ&¨wÐXdÐ&ÐeÐer8   c                ó6   • U (       a  Uc  Ub  [        S5      eg g )Nzx`skip_auth` is mutually exclusive with `token_provider` and `credentials`; `skip_auth` disables authentication entirely.)rp   ©Ú	skip_authÚtoken_providerr2   s      r5   Ú_reject_skip_auth_conflictrx   £   s+   € ö �nÑ0°KÑ4KÜð<ó
ð 	
ð 5L€yr8   c                ór   • S H1  n[        XS5      n[        U[        5      (       d  M&  U(       d  M/  Us  $    g)u{   Best-effort project from an explicit credentials object â€” service-account /
impersonated credentials usually know theirs.)Ú
project_idÚquota_project_idN)Úgetattrr>   r?   )r2   ÚattrÚvalues      r5   Ú_project_from_credentialsr   °   s5   € ó 3ˆÜ˜¨4Ó0ˆÜ�eœS×!Ó!§e eØŠLñ 3ð r8   c                  ó|  ^ • \ rS rSr% SrS\S'   S\S'   SSSSSSS\\SSSSSS	.                             SU 4S
 jjjr\	\
SS j5       5       r\
SS j5       rSS jr\
SS j5       r\
SS j5       rSS\\\SS\S\\SSSS0 S.                                 SS jjr\rSrU =r$ )ÚAnthropicGoogleCloudéº   a  Synchronous client for the first-party Anthropic API served through Google's
gateway (Claude Platform on Google Cloud).

The whole first-party surface is proxied verbatim (no URL or body rewriting), so
this subclasses the full `Anthropic` client. Authentication is a GCP bearer
token.
rO   rP   rT   Ú
_skip_authNF©rf   rg   rP   rw   r2   rv   rZ   ÚtimeoutÚmax_retriesÚdefault_headersÚdefault_queryÚhttp_clientÚ
middlewareÚ_strict_response_validationc               ó   >• [        XdUS9  X`l        X@l        [        U5      U l        Uc  [
        R                  R                  S5      nUc  [        nX l	        Uc  [
        R                  R                  S5      nUc  [
        R                  R                  S5      nUc  Ub  [        U5      nXl        Uc  [
        R                  R                  S5      nUSLU l        Uc  [
        R                  R                  S5      nUc  U(       a  Uc  [        S5      eX0l        [        UU R                  U R                  U R                  U(       + S	9nUSL U l        ["        TU ]I  Ub  UOS
UU	U
UUUUS9  SU l        SU l        g)uî  Construct a new synchronous Claude Platform on Google Cloud client.

Auth precedence (first match wins, unless `skip_auth=True`):
  1. `token_provider` â€” a callable returning a GCP access token, invoked per request.
  2. `credentials` â€” a `google.auth` Credentials object, refreshed as needed.
  3. Application Default Credentials (`google.auth.default`).

Args:
    project: GCP consumer project id (or `ANTHROPIC_GOOGLE_CLOUD_PROJECT`,
        else `GOOGLE_CLOUD_PROJECT`). Only needed when the base URL must be
        derived; if omitted there, it is taken from an explicit `credentials`
        object when it exposes one, or back-filled from ADC on the first request.
    location: GCP location (or `ANTHROPIC_GOOGLE_CLOUD_LOCATION`). Optional â€”
        defaults to `global`, the region the gateway should normally be
        addressed through.
    workspace_id: The Anthropic workspace ID (or `ANTHROPIC_GOOGLE_CLOUD_WORKSPACE_ID`).
        Required unless `skip_auth` is set with an explicit `base_url`.
    skip_auth: For pre-authenticated proxies â€” skips token attachment. A
        workspace ID is still needed to derive the base URL; pass `base_url`
        to construct without one. Mutually exclusive with the credential
        arguments.
ru   NÚANTHROPIC_GOOGLE_CLOUD_LOCATIONÚANTHROPIC_GOOGLE_CLOUD_PROJECTÚGOOGLE_CLOUD_PROJECTÚANTHROPIC_GOOGLE_CLOUD_BASE_URLÚ#ANTHROPIC_GOOGLE_CLOUD_WORKSPACE_IDúyNo workspace ID found. Set the `workspace_id` argument or the `ANTHROPIC_GOOGLE_CLOUD_WORKSPACE_ID` environment variable.rq   Ú ©rZ   r…   r†   r‡   rˆ   r‰   rŠ   r‹   ©rx   rƒ   Ú_token_providerr+   rS   ÚosÚenvironÚgetÚDEFAULT_LOCATIONrR   r   rQ   rV   rp   rP   rs   rU   Úsuperr6   Úapi_keyÚ
auth_token©r4   rf   rg   rP   rw   r2   rv   rZ   r…   r†   r‡   rˆ   r‰   rŠ   r‹   Úresolved_base_urlÚ	__class__s                   €r5   r6   ÚAnthropicGoogleCloud.__init__Æ   sƒ  ø€ ôP 	#¨YÐcnÒoà#ŒØ-ÔÜ3°KÓ@ˆÔØÑÜ—z‘z—~‘~Ð&GÓHˆHØÑÜ'ˆHØ!ŒØ‰?Ü—j‘j—n‘nÐ%EÓFˆGØ‰?Ü—j‘j—n‘nÐ%;Ó<ˆGØ‰?˜{Ñ6Ü/°Ó<ˆGØŒàÑÜ—z‘z—~‘~Ð&GÓHˆHð %-°DÐ$8ˆÔ!àÑÜŸ:™:Ÿ>™>Ð*OÓPˆLð Ñ®°xÑ7KÜðNóð ð )Ôä-ØØ—M‘MØ—^‘^Ø×*Ñ*à'0¤=ñ
Ðð #4°tÐ";ˆÔä‰Ñð +<Ñ*GÑ&ÈRØØ#Ø+Ø'Ø#Ø!Ø(Cð 	ñ 	
ð" ˆŒØˆ�r8   c                ó   • 0 $ r.   rK   rY   s    r5   Úauth_headersÚ!AnthropicGoogleCloud.auth_headers/  s	   € ð
 ˆ	r8   c                ó   • g r.   rK   ©r4   ÚheadersÚomitteds      r5   Ú_validate_headersÚ&AnthropicGoogleCloud._validate_headers6  s   € ð 	r8   c                óî   • U R                   nUbM  U" 5       n[        R                  " U5      (       a)  [        [        U5      R                  5         [        S5      eU$ U R                  R                  5       $ )Nzp`token_provider` returned an awaitable. Async token providers are only supported on `AsyncAnthropicGoogleCloud`.)	r–   ÚinspectÚisawaitabler   r   Úcloser   rS   r<   ©r4   Úproviderr<   s      r5   Ú
_get_tokenÚAnthropicGoogleCloud._get_token<  sm   € Ø×'Ñ'ˆØÑÙ“JˆEÜ×"Ò" 5×)Ñ)Ü”S˜%Ó ×&Ñ&Ô(Ü$ð@óð ð ˆLà× Ñ ×&Ñ&Ó(Ð(r8   c                ó  • U R                   (       dp  U R                  (       a_  U R                  cB  U R                  c5  U R                  R                  5         U R                  R                  U l        U R                  5         U$ r.   )rƒ   rU   rQ   r–   rS   r<   r3   rj   ©r4   Úoptionss     r5   Ú_prepare_optionsÚ%AnthropicGoogleCloud._prepare_optionsJ  s^   € à�� 4×#:×#:Ø�}‰}Ñ$¨×)=Ñ)=Ñ)Eð ×!Ñ!×'Ñ'Ô)Ø $× 1Ñ 1× =Ñ =�”Ø×+Ñ+Ô-àˆr8   c                ó¢   • U R                   (       a  g UR                  R                  S5      b  g SU R                  5        3UR                  S'   g ©NÚAuthorizationzBearer ©rƒ   r§   r™   r±   ©r4   Úrequests     r5   Ú_prepare_requestÚ%AnthropicGoogleCloud._prepare_requestW  sC   € à�?�?Øà�?‰?×Ñ˜Ó/Ñ;ð à-4°T·_±_Ó5FÐ4GÐ+Hˆ�‰˜Ò(r8   ©rf   rg   rP   rw   r2   rv   rZ   r…   r‰   rŠ   r†   r‡   Úset_default_headersrˆ   Úset_default_queryÚ_extra_kwargsc               ó  • Ub  Ub  [        S5      eUb  Ub  [        S5      eU R                  nUb  [        UU5      nOUb  UnU R                  nUb  0 UEUEnOUb  UnUb  UOU R                  n[        U5      =(       d    [        U5      nSnSnU(       a)  [        U5      (       a  UOSn[        U5      (       a  UOSnO)U(       d"  U R                  nU R                  R                  nUc  U R                  (       d  SnOUb  UOU R                  nU R                  " SUb  UOU R                  Ub  UOU R                  [        U5      (       a  UOU R                  UUUU[        U[         5      (       a  U R"                  OUU	=(       d    U R$                  [        U5      (       a  UOU R&                  UU[        U
[         5      (       a  U R(                  OU
U R*                  S.UD6nU(       d  U(       d  U R                  Ul        U$ )u�  Create a new client re-using the current options, with optional overrides.

Passing either of `token_provider` / `credentials` replaces the
inherited credential configuration wholesale â€” the source not passed is
cleared, so an explicit lower-precedence credential takes effect.
`workspace_id=None` clears the workspace ID; `project` /
`location` overrides re-derive a template-derived base URL.
NúPThe `default_headers` and `set_default_headers` arguments are mutually exclusiveúLThe `default_query` and `set_default_query` arguments are mutually exclusive©rf   rg   rP   rw   r2   rv   rZ   r…   r‰   r†   r‡   rˆ   rŠ   r‹   rK   ©rp   Ú_custom_headersr   Ú_custom_queryrƒ   r   r–   rS   r2   rV   rZ   r    rQ   rR   rP   r>   r   r…   Ú_clientr†   Ú_middlewarer‹   ©r4   rf   rg   rP   rw   r2   rv   rZ   r…   r‰   rŠ   r†   r‡   rÁ   rˆ   rÂ   rÃ   r§   ÚparamsÚresolved_skip_authÚcredential_overriddenÚnew_token_providerÚnew_credentialsÚnew_base_urlÚclients                            r5   ÚcopyÚAnthropicGoogleCloud.copyd  sø  € ð8 Ñ&Ð+>Ñ+JÜÐoÓpÐpàÑ$Ð):Ñ)FÜÐkÓlÐlà×&Ñ&ˆØÑ&Ü# G¨_Ó=‰GØ Ñ,Ø)ˆGà×#Ñ#ˆØÑ$Ø0˜Ð0 -Ð0‰FØÑ*Ø&ˆFà*3Ñ*?™YÀTÇ_Á_ÐÜ (¨Ó 8× Q¼HÀ[Ó<QÐØ37ÐØ48ˆÞ Ü3;¸N×3KÑ3K¡ÐQUÐÜ-5°k×-BÑ-B™kÈ‰OÞ#Ø!%×!5Ñ!5ÐØ"×/Ñ/×;Ñ;ˆOàÑ D×$=×$=ð 59‰Là'/Ñ';™8ÀÇÁˆLà—’ð 
Ø&Ñ2‘G¸¿¹Ø!)Ñ!5‘X¸4¿>¹>Ü)1°,×)?Ñ)?™ÀT×EVÑEVØ-Ø'Ø(Ø!Ü$.¨w¼×$AÑ$A�D—L’LÀwØ#×3 t§|¡|Ü'/°×'<Ñ'<™À$×BRÑBRØ#Ø Ü+5°jÄ(×+KÑ+K�t×'Ò'ÐQ[Ø(,×(HÑ(Hñ
ð ñ
ˆö" %Ö-?ð #'×"3Ñ"3ˆFÔØˆr8   ©
rU   rV   rS   rR   rQ   rƒ   r–   rœ   r�   rP   )rf   rO   rg   rO   rP   rO   rw   zTokenProvider | Noner2   rA   rv   rT   rZ   ústr | httpx2.URL | Noner…   ú!float | Timeout | None | NotGivenr†   Úintr‡   úMapping[str, str] | Nonerˆ   úMapping[str, object] | Noner‰   úhttpx2.Client | NonerŠ   ú Sequence[MiddlewareInput] | Noner‹   rT   rB   rC   ©rB   zdict[str, str]©r§   zhttpx2.Headersr¨   zfrozenset[str]rB   rC   rD   ©rµ   r   rB   r   ©r½   zhttpx2.RequestrB   rC   )"rf   rO   rg   rO   rP   ústr | None | NotGivenrw   zTokenProvider | None | NotGivenr2   ú#GoogleCredentials | None | NotGivenrv   úbool | NonerZ   rØ   r…   rÙ   r‰   rÝ   rŠ   ú+Sequence[MiddlewareInput] | None | NotGivenr†   úint | NotGivenr‡   rÛ   rÁ   rÛ   rˆ   rÜ   rÂ   rÜ   rÃ   úMapping[str, Any]rB   r   ©rE   rF   rG   rH   rI   rl   r   r   r6   rm   r   r£   r©   r±   r¶   r¾   rÕ   Úwith_optionsrJ   Ú__classcell__©r    s   @r5   r�   r�   º   sO  ø‡ ñð ÓØÓð
 #Ø#Ø#'Ø/3Ø04ØØ,0Ø5>Ø.Ø48Ø59Ø,0Ø7;Ø,1ñ!gð ðgð ð	gð
 !ðgð -ðgð .ðgð ðgð *ðgð 3ðgð ðgð 2ðgð 3ðgð *ðgð 5ðgð  &*ð!gð" 
÷#gð gðR Øóó ó ðð
 óó ðô
)ð ó
ó ð
ð ó
Ió ð
Ið #Ø#Ø.7Ø:CØ;DØ!%Ø,0Ø5>Ø,0ØBKØ&/Ø48Ø8<Ø59Ø9=Ø+-ñ%Uð ðUð ð	Uð
 ,ðUð 8ðUð 9ðUð ðUð *ðUð 3ðUð *ðUð @ðUð $ðUð 2ðUð 6ðUð  3ð!Uð" 7ð#Uð$ )ð%Uð& 
õ'Uðn †Lr8   r�   c                  ó|  ^ • \ rS rSr% SrS\S'   S\S'   SSSSSSS\\SSSSSS	.                             SU 4S
 jjjr\	\
SS j5       5       r\
SS j5       rSS jr\
SS j5       r\
SS j5       rSS\\\SS\S\\SSSS0 S.                                 SS jjr\rSrU =r$ )ÚAsyncAnthropicGoogleCloudi¾  z•Asynchronous client for the first-party Anthropic API served through Google's
gateway (Claude Platform on Google Cloud). See `AnthropicGoogleCloud`.
rO   rP   rT   rƒ   NFr„   c               ó   >• [        XdUS9  X`l        X@l        [        U5      U l        Uc  [
        R                  R                  S5      nUc  [        nX l	        Uc  [
        R                  R                  S5      nUc  [
        R                  R                  S5      nUc  Ub  [        U5      nXl        Uc  [
        R                  R                  S5      nUSLU l        Uc  [
        R                  R                  S5      nUc  U(       a  Uc  [        S5      eX0l        [        UU R                  U R                  U R                  U(       + S	9nUSL U l        ["        TU ]I  Ub  UOS
UU	U
UUUUS9  SU l        SU l        g)zãConstruct a new asynchronous Claude Platform on Google Cloud client.

`token_provider` may be sync or async; sync providers are run off the
event loop. See `AnthropicGoogleCloud` for the full argument and
auth-precedence docs.
ru   Nr�   rŽ   r�   r�   r‘   r’   rq   r“   r”   r•   rž   s                   €r5   r6   Ú"AsyncAnthropicGoogleCloud.__init__Æ  s€  ø€ ô0 	#¨YÐcnÒoà#ŒØ-ÔÜ3°KÓ@ˆÔØÑÜ—z‘z—~‘~Ð&GÓHˆHØÑÜ'ˆHØ!ŒØ‰?Ü—j‘j—n‘nÐ%EÓFˆGØ‰?Ü—j‘j—n‘nÐ%;Ó<ˆGØ‰?˜{Ñ6Ü/°Ó<ˆGØŒàÑÜ—z‘z—~‘~Ð&GÓHˆHØ$,°DÐ$8ˆÔ!àÑÜŸ:™:Ÿ>™>Ð*OÓPˆLð Ñ®°xÑ7KÜðNóð ð )Ôä-ØØ—M‘MØ—^‘^Ø×*Ñ*à'0¤=ñ
Ðð #4°tÐ";ˆÔä‰Ñð +<Ñ*GÑ&ÈRØØ#Ø+Ø'Ø#Ø!Ø(Cð 	ñ 	
ð ˆŒØˆ�r8   c                ó   • 0 $ r.   rK   rY   s    r5   r£   Ú&AsyncAnthropicGoogleCloud.auth_headers  s	   € ð ˆ	r8   c                ó   • g r.   rK   r¦   s      r5   r©   Ú+AsyncAnthropicGoogleCloud._validate_headers  s   € àr8   c              ƒ  óÂ  #   • U R                   nUb™  [        R                  " U5      (       a(  U" 5       I S h  v•N n[        U[        5      (       d   eU$ [        U5      " 5       I S h  v•N n[        R                  " U5      (       a
  UI S h  v•N n[        U[        5      (       d   eU$ [        U R                  R                  5      " 5       I S h  v•N $  NŸ Np NM N
7fr.   )	r–   r¬   Úiscoroutinefunctionr>   r?   r   r­   rS   r<   r¯   s      r5   r±   Ú$AsyncAnthropicGoogleCloud._get_token"  sº   é € Ø×'Ñ'ˆØÑÜ×*Ò*¨8×4Ñ4Ù&›j×(�Ü! %¬×-Ñ-Ð-Ð-Ø�ô # 8Ô,Ó.×.ˆEÜ×"Ò" 5×)Ñ)Ø#Ÿ�Ü˜e¤S×)Ñ)Ð)Ð)ØˆLä˜d×/Ñ/×5Ñ5Ô6Ó8×8Ð8ñ )ñ
 /á#ñ 9ùsF   ‚5C·C¸0CÁ(CÁ)$CÂCÂACÃCÃCÃCÃCÃCc              ƒ  ó8  #   • U R                   (       d‚  U R                  (       aq  U R                  cT  U R                  cG  [	        U R
                  R                  5      " 5       I S h  v•N   U R
                  R                  U l        U R                  5         U$  N17fr.   )	rƒ   rU   rQ   r–   r   rS   r<   r3   rj   r´   s     r5   r¶   Ú*AsyncAnthropicGoogleCloud._prepare_options3  sq   é € à�� 4×#:×#:Ø�}‰}Ñ$¨×)=Ñ)=Ñ)Eô ˜t×0Ñ0×6Ñ6Ô7Ó9×9Ð9Ø $× 1Ñ 1× =Ñ =�”Ø×+Ñ+Ô-àˆñ	 :ùs   ‚A$BÁ&BÁ'2Bc              ƒ  ó¾   #   • U R                   (       a  g UR                  R                  S5      b  g SU R                  5       I S h  v•N  3UR                  S'   g  N7fr¹   r»   r¼   s     r5   r¾   Ú*AsyncAnthropicGoogleCloud._prepare_request@  sL   é € à�?�?Øà�?‰?×Ñ˜Ó/Ñ;ð à-4¸4¿?¹?Ó;L×5LÐ4MÐ+Nˆ�‰˜Ò(Ñ5Lùs   ‚AAÁAÁArÀ   c               ó  • Ub  Ub  [        S5      eUb  Ub  [        S5      eU R                  nUb  [        UU5      nOUb  UnU R                  nUb  0 UEUEnOUb  UnUb  UOU R                  n[        U5      =(       d    [        U5      nSnSnU(       a)  [        U5      (       a  UOSn[        U5      (       a  UOSnO)U(       d"  U R                  nU R                  R                  nUc  U R                  (       d  SnOUb  UOU R                  nU R                  " SUb  UOU R                  Ub  UOU R                  [        U5      (       a  UOU R                  UUUU[        U[         5      (       a  U R"                  OUU	=(       d    U R$                  [        U5      (       a  UOU R&                  UU[        U
[         5      (       a  U R(                  OU
U R*                  S.UD6nU(       d  U(       d  U R                  Ul        U$ )zˆCreate a new client re-using the current options, with optional overrides.

See `AnthropicGoogleCloud.copy` for the override semantics.
NrÅ   rÆ   rÇ   rK   rÈ   rÍ   s                            r5   rÕ   ÚAsyncAnthropicGoogleCloud.copyM  sø  € ð0 Ñ&Ð+>Ñ+JÜÐoÓpÐpàÑ$Ð):Ñ)FÜÐkÓlÐlà×&Ñ&ˆØÑ&Ü# G¨_Ó=‰GØ Ñ,Ø)ˆGà×#Ñ#ˆØÑ$Ø0˜Ð0 -Ð0‰FØÑ*Ø&ˆFà*3Ñ*?™YÀTÇ_Á_ÐÜ (¨Ó 8× Q¼HÀ[Ó<QÐØ8<ÐØ48ˆÞ Ü3;¸N×3KÑ3K¡ÐQUÐÜ-5°k×-BÑ-B™kÈ‰OÞ#Ø!%×!5Ñ!5ÐØ"×/Ñ/×;Ñ;ˆOàÑ D×$=×$=ð 59‰Là'/Ñ';™8ÀÇÁˆLà—’ð 
Ø&Ñ2‘G¸¿¹Ø!)Ñ!5‘X¸4¿>¹>Ü)1°,×)?Ñ)?™ÀT×EVÑEVØ-Ø'Ø(Ø!Ü$.¨w¼×$AÑ$A�D—L’LÀwØ#×3 t§|¡|Ü'/°×'<Ñ'<™À$×BRÑBRØ#Ø Ü+5°jÄ(×+KÑ+K�t×'Ò'ÐQ[Ø(,×(HÑ(Hñ
ð ñ
ˆö" %Ö-?ð #'×"3Ñ"3ˆFÔØˆr8   r×   )rf   rO   rg   rO   rP   rO   rw   zAsyncTokenProvider | Noner2   rA   rv   rT   rZ   rØ   r…   rÙ   r†   rÚ   r‡   rÛ   rˆ   rÜ   r‰   úhttpx2.AsyncClient | NonerŠ   rÞ   r‹   rT   rB   rC   rß   rà   rD   rá   râ   )"rf   rO   rg   rO   rP   rã   rw   z$AsyncTokenProvider | None | NotGivenr2   rä   rv   rå   rZ   rØ   r…   rÙ   r‰   rþ   rŠ   ræ   r†   rç   r‡   rÛ   rÁ   rÛ   rˆ   rÜ   rÂ   rÜ   rÃ   rè   rB   r   ré   rì   s   @r5   rî   rî   ¾  sO  ø‡ ñð ÓØÓð
 #Ø#Ø#'Ø48Ø04ØØ,0Ø5>Ø.Ø48Ø59Ø15Ø7;Ø,1ñ!Qð ðQð ð	Qð
 !ðQð 2ðQð .ðQð ðQð *ðQð 3ðQð ðQð 2ðQð 3ðQð /ðQð 5ðQð  &*ð!Qð" 
÷#Qð Qðf Øóó ó ðð óó ðô9ð" ó
ó ð
ð ó
Oó ð
Oð #Ø#Ø.7Ø?HØ;DØ!%Ø,0Ø5>Ø15ØBKØ&/Ø48Ø8<Ø59Ø9=Ø+-ñ%Qð ðQð ð	Qð
 ,ðQð =ðQð 9ðQð ðQð *ðQð 3ðQð /ðQð @ðQð $ðQð 2ðQð 6ðQð  3ð!Qð" 7ð#Qð$ )ð%Qð& 
õ'Qðf †Lr8   rî   )rZ   rØ   rf   rO   rg   r?   rP   rO   rr   rT   rB   rØ   )rv   rT   rw   úobject | Noner2   rÿ   rB   rC   )r2   ÚGoogleCredentialsrB   rO   )DÚ
__future__r   r—   r¬   r/   Útypingr   r   r   r   r   r	   r
   r   r   Ú	functoolsr   Útyping_extensionsr   r   r^   Ú_typesr   r   r   Ú_utilsr   r   rË   r   r   Ú_modelsr   Ú
_streamingr   r   Ú_exceptionsr   rÌ   r   Ú_base_clientr   r   r   Ú_extras._google_authr!   r"   r:   r=   Úgoogle.auth.credentialsr%   r   rh   rš   r?   ÚTokenProviderÚAsyncTokenProviderÚClientÚAsyncClientr'   r)   r+   rM   rs   rx   r   r�   rî   rK   r8   r5   Ú<module>r     s¾  ðÝ "ã 	Û Û ß c× cÕ cÝ ß ,ã ç 2Ñ 2ß (ß 0Ý *ß -Ý )Ý *ß JÑ Jß Pñ  Ð 8ÀÑOÐ ÙÐ2¸.ÑIÐ æÝHð
 uð ð Ð à˜˜S˜Ñ!€Ø˜bÐ"8Ð8Ñ9Ð á˜¨u°V·]±]ÀF×DVÑDVÐ5VÑ/WÑX€ÙÐ+°5¸À¹ÀkÐRUÑFVÐ9VÑ3WÑX€÷ñ ô>4(˜J }°oÐ'EÑFô 4(ðnfà%ðfð ðfð ð	fð
 ðfð !ðfð ôfð<

àð

ð "ð

ð ð	

ð
 
ô

ôôAÐ0°·±ÀÀsÁÐ1KÑLÈiô AôHbÐ 5°f×6HÑ6HÈ+ÐVYÑJZÐ6ZÑ [Ð]kõ br8   