+
    Q?j-S                       ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIHtH	t	H
t
 ^ RIHtHt ^ RIt^ RIt^RIHt ^RIHtHtHt ^RIHtHtHtHt ^RIHtHtHt ^R	IH t H!t!H"t"H#t# R
t$Rt%Rt&^t'Rt(Rt)0 R<mt*]PV                  ! R4      t,RR/R R llt-R R lt.R R lt/R R lt0 ! R R]Pb                  4      t2 ! R R]Pf                  4      t4RRRR/R  R! llt5RRRR/R" R# llt6R$ R% lt7R& R' lt8R( R) lt9R* R+ lt:R, R- lt;R. R/ lt<R0 R1 lt=R2 R3 lt>R4 R5 lt? ! R6 R7]],          4      t@ ! R8 R9]@4      tA ! R: R;]@4      tBR# )=    )annotationsN)AnyNoReturncast)TypeIsoverride)is_dict)timeout_exceptionsnormalize_httpx_url_loaded_legacy_httpx)TOKEN_EXCHANGE_GRANT_TYPEWorkloadIdentityX509WorkloadIdentity_WorkloadIdentityAuth)MAX_RETRY_DELAYINITIAL_RETRY_DELAYMAX_RETRY_AFTER_DELAY)
OAuthErrorOpenAIErrorAPITimeoutErrorAPIConnectionErrorzhttps://mtls.api.openai.com/v1z(https://mtls.auth.openai.com/oauth/tokenz'urn:openai:params:oauth:token-type:x509openai_x509_replay_position!openai_x509_replay_file_positionsz[A-Za-z0-9._~+/-]+=*expected_originc               $    V ^8  d   QhRRRRRR/# )   urlzhttpx2.URL | strr   zhttpx2.URL | NonereturnNone )formats   "z/home/vela/workspace/domain/tn-silver/web/tn-site/.runtime/imagegen-venv/lib/python3.14/site-packages/openai/auth/_x509.py__annotate__r#   "   s)     a a/ aEV abf a    c               ^   \        V 4      pVP                  R 8w  g   VP                  '       g   \        R4      hVP                  '       g   VP
                  '       d   \        R4      hVeA   VP                  VP                  3VP                  VP                  38w  d   \        R4      hR# R# )httpsz:X.509 workload identity requires an absolute HTTPS API URLz@X.509 workload identity API URLs cannot contain user credentialsNzCX.509 workload identity requests must use the configured API origin)r   schemehostr   usernamepasswordport)r   r   normalized_urls   &$ r"   validate_x509_api_urlr-   "   s    (-N'~/B/B/BVWW."9"9"9\]]"(;(;^=P=P'QV ( _``	("r$   c                    V ^8  d   QhRRRR/# r   requesthttpx2.Requestr   r   r    )r!   s   "r"   r#   r#   1   s     j j> jd jr$   c                    \         ;QJ d&    R  V P                   4       F  '       g   K   RM	  RM! R  V P                   4       4      '       d   \        R4      hR# )c              3  h   "   T F(  pVP                  4       P                  R R4      R9   x  K*  	  R# 5i)_-N)api-key	x-api-keyproxy-authorizationlowerreplace.0headers   & r"   	<genexpr>0validate_x509_api_credentials.<locals>.<genexpr>2   s0      %F 	sC(,[[%   02TFzLX.509 workload identity requests cannot include API-key or proxy credentialsN)anyheadersr   r0   s   &r"   validate_x509_api_credentialsrE   1   sL    
s oosss oo   hii	r$   c                    V ^8  d   QhRRRR/# r/   r    )r!   s   "r"   r#   r#   9   s     _ _^ _ _r$   c                z  a V P                   P                  R 4      o\        S4      ^8w  g   \        ;QJ d    V3R lR 4       F  '       g   K   RM	  RM! V3R lR 4       4      '       gO   \        ;QJ d&    R V P                    4       F  '       g   K   RM	  RM! R V P                    4       4      '       d   \	        R4      h \
        P                  ! RS^ ,           24      pTP                  '       g   TP                  '       g}   TP                  R
8w  gl   TP                  '       gZ   TP                  '       gH   TP                  TP                  3T P                  P                  T P                  P                  38w  d   \	        R4      hR	#   \
        P                   d   p\	        R4      ThR	p?ii ; i)r(   c              3  :   <"   T F  qS^ ,          9   x  K  	  R# 5i)r   Nr    )r=   	delimiterhost_headerss   & r"   r?   2validate_x509_request_authority.<locals>.<genexpr>=   s     FX	LO+Xs   z/?#@\TFc              3  B   "   T F  qP                  R 4      x  K  	  R# 5i):N)
startswithr<   s   & r"   r?   rK   >   s     DO&  %%Os   zIX.509 workload identity requests require exactly one valid Host authorityzhttps://z?X.509 workload identity requests require a valid Host authorityN/zAX.509 workload identity Host authority must match the request URL)rC   get_listlenrB   r   httpx2URL
InvalidURLr)   r*   pathqueryfragmentr(   r+   r   )r0   host_urlerrorrJ   s   &  @r"   validate_x509_request_authorityrZ   9   s>   ??++F3LLQ3FXF333FXFFF3DGOOD333DGOODDDeffh::a(9:;
 	==C>>>MM8==)gkk.>.>@P@P-QQ]^^ R  h[\bgghs    F F:)F55F:c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r   r0   r1   r   
httpx2.URLexpected_authorization
str | Nonetoken_exchangeboolr   r   r    )r!   s   "r"   r#   r#   R   sC     o oo  o '	o
 o 
or$   c                  \        V P                  VR 7       \        V 4       V'       d   \        V P                  4      \        8w  d   \        R4      h\        ;QJ d&    R V P                   4       F  '       g   K   RM	  RM! R V P                   4       4      '       d   \        R4      hR# \        V 4       V P                  P                  R4      V8w  d   \        R4      hR# )	)r   zDX.509 token exchange requests must use the pinned authentication URLc              3  h   "   T F(  pVP                  4       P                  R R4      R9   x  K*  	  R# 5i)r4   r5   N)authorizationr8   cookier7   r6   r9   r<   s   & r"   r?   ._validate_transport_request.<locals>.<genexpr>_   s5      
 * LLN""3,YZ)rA   TFz<X.509 token exchange requests cannot include API credentialsAuthorizationzMX.509 workload identity authorization cannot be changed by HTTP request hooksN)
r-   r   rZ   str_X509_TOKEN_EXCHANGE_URLr   rB   rC   rE   get)r0   r   r]   r_   s   &$$$r"   _validate_transport_requestrj   R   s     '++G#G,w{{77dee3 
 "//
333 
 "//
 
 

 \]]
 	&g.??/3IImnn Jr$   c                  N    ] tR t^ktR R lt]R R l4       t]R R l4       tRtR# )	_SyncX509ForwardingTransportc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r   http_clienthttpx2.Clientr   r\   r]   r^   r_   r`   r   r   r    )r!   s   "r"   r#   )_SyncX509ForwardingTransport.__annotate__l   s>     . . #. $	.
 !+. . 
.r$   c               	6    Wn         W n        W0n        W@n        R # N_http_client_expected_origin_expected_authorization_token_exchangeselfrn   r   r]   r_   s   &$$$$r"   __init__%_SyncX509ForwardingTransport.__init__l        ( /'=$-r$   c                    V ^8  d   QhRRRR/# r   r0   r1   r   httpx2.Responser    )r!   s   "r"   r#   rp   z   s     	Y 	Yn 	Y 	Yr$   c                	   \        VV P                  V P                  V P                  R 7       V P                  P
                  '       d   \        R4      hV P                  P                  VP                  4      P                  V4      # )r   r]   r_   5Cannot send a request, as the client has been closed.)
rj   ru   rv   rw   rt   	is_closedRuntimeError_transport_for_urlr   handle_requestry   r0   s   &&r"   r   +_SyncX509ForwardingTransport.handle_requesty   so    # 11#'#?#?//		
 &&&VWW  33GKK@OOPWXXr$   c                   V ^8  d   QhRR/# r   r   r   r    )r!   s   "r"   r#   rp      s      t r$   c                	    R # rr   r    ry   s   &r"   close"_SyncX509ForwardingTransport.close   s     r$   rv   ru   rt   rw   N)	__name__
__module____qualname____firstlineno__rz   r   r   r   __static_attributes__r    r$   r"   rl   rl   k   s1    . 	Y 	Y  r$   rl   c                  N    ] tR t^tR R lt]R R l4       t]R R l4       tRtR# )	_AsyncX509ForwardingTransportc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r   rn   httpx2.AsyncClientr   r\   r]   r^   r_   r`   r   r   r    )r!   s   "r"   r#   *_AsyncX509ForwardingTransport.__annotate__   s>     . . (. $	.
 !+. . 
.r$   c               	6    Wn         W n        W0n        W@n        R # rr   rs   rx   s   &$$$$r"   rz   &_AsyncX509ForwardingTransport.__init__   r|   r$   c                    V ^8  d   QhRRRR/# r~   r    )r!   s   "r"   r#   r      s     	e 	e. 	e_ 	er$   c                	.  "   \        VV P                  V P                  V P                  R 7       V P                  P
                  '       d   \        R4      hV P                  P                  VP                  4      P                  V4      G Rj  xL
 #  L5i)r   r   N)
rj   ru   rv   rw   rt   r   r   r   r   handle_async_requestr   s   &&r"   r   2_AsyncX509ForwardingTransport.handle_async_request   sx     # 11#'#?#?//		
 &&&VWW&&99'++F[[\cdddds   BBBBc                   V ^8  d   QhRR/# r   r    )r!   s   "r"   r#   r      s      d r$   c                	   "   R # 5irr   r    r   s   &r"   aclose$_AsyncX509ForwardingTransport.aclose   s
      s   r   N)	r   r   r   r   rz   r   r   r   r   r    r$   r"   r   r      s1    . 	e 	e  r$   r   r]   r_   Fc          
     ,    V ^8  d   QhRRRRRRRRR	R/# )
r   rn   ro   r   r\   r]   r^   r_   r`   r   r    )r!   s   "r"   r#   r#      s<         '	
  r$   c               Z   \        V VVVR 7      p\        4       p\        P                  pVe;   \	        \        \        V 4      \        P                  4      '       g   VP                  pT! TV P                  V'       d   RMV P                  RR7      pV'       g   V P                  Vn
        V# )rn   r   r]   r_   NF)	transporttimeoutevent_hooks	trust_env)rl   r   rR   Client
isinstancer   objectr   r   cookies_cookiesrn   r   r]   r_   r   legacy_httpxclient_typescoped_clients   &$$$    r"   _scoped_sync_clientr      s     -'5%	I ()L--K
43Lfmm(\(\"))##*D0G0G	M !,!4!4r$   c          
     ,    V ^8  d   QhRRRRRRRRR	R/# )
r   rn   r   r   r\   r]   r^   r_   r`   r   r    )r!   s   "r"   r#   r#      s<      #   '	
  r$   c               Z   \        V VVVR 7      p\        4       p\        P                  pVe;   \	        \        \        V 4      \        P                  4      '       g   VP                  pT! TV P                  V'       d   RMV P                  RR7      pV'       g   V P                  Vn
        V# r   )r   r   rR   AsyncClientr   r   r   r   r   r   r   r   s   &$$$    r"   _scoped_async_clientr      s     .'5%	I ()L$$K
43LfN`N`(a(a"..##*D0G0G	M !,!4!4r$   c                    V ^8  d   QhRRRR/# )r   valuer   r   float | Noner    )r!   s   "r"   r#   r#      s     3 3F 3| 3r$   c                    \        V \        4      '       g   \        V \        \        34      '       g   R #  \        V 4      p \
        P                  ! T 4      '       d   T # R #   \         d     R # i ; irr   )r   r`   intfloatOverflowErrormathisfinite)r   s   &r"   _as_finite_floatr      s_    %je&E&Ee MM%((52d2  s   A! !A0/A0c                    V ^8  d   QhRRRR/# )r   identityz.WorkloadIdentity | X509WorkloadIdentity | Noner   zTypeIs[X509WorkloadIdentity]r    )r!   s   "r"   r#   r#      s      C C<C!Cr$   c                B    V R J;'       d    V P                  R4      R8H  # )Ntypex509)ri   r   s   &r"   is_x509_workload_identityr      s%     4BBHLL$8F$BBr$   c                    V ^8  d   QhRRRR/# )r   r   r   r   r   r    )r!   s   "r"   r#   r#      s     h h!5 h$ hr$   c                   R V 9   g   RV 9   d   \        R4      h\        V 4      \        ,
          '       d   \        R4      hV P                  R4      '       d   V P                  R4      '       g   \        R4      h\	        \
        V P                  R4      4      pVe$   \        V4      pVe   V^ 8  d   \        R	4      hR# R# )
provider	client_idzMX.509 workload identity does not accept a subject-token provider or client IDzPX.509 workload identity accepts only identity IDs and an optional refresh bufferidentity_provider_idservice_account_idzJX.509 workload identity requires identity-provider and service-account IDsrefresh_buffer_secondsNzFX.509 workload identity requires a finite, non-negative refresh buffer)r   set_ALLOWED_IDENTITY_FIELDSri   r   r   r   )r   refresh_bufferrefresh_buffer_values   &  r"   _validate_identityr      s    X!8ijj
8}///lmm<<.//x||DX7Y7Yfgg&(,,/G"HIN!/?'+?!+Cfgg ,D "r$   c                    V ^8  d   QhRRRR/# )r   r   r   r   zdict[str, str]r    )r!   s   "r"   r#   r#     s       4  r$   c           	     B    R \         R\        RV R,          RV R,          /# )
grant_typesubject_token_typer   r   )r   _X509_SUBJECT_TOKEN_TYPEr   s   &r"   _exchange_payloadr     s.    /6)? @h';<	 r$   c               $    V ^8  d   QhRRRRRR/# )r   r   r   rn   z"httpx2.Client | httpx2.AsyncClientr   r1   r    )r!   s   "r"   r#   r#     s(      " 4 	r$   c          	        \         P                  p\        4       pVe|   \        \	        \
        V4      \         P                  \         P                  34      '       g>   \	        \        \         P                  ,          \	        \        V4      P                  4      pV! R\        \        V 4      R\         P                  ! R4      P                  4       /R7      # )NPOSTr   g      $@)json
extensions)rR   Requestr   r   r   r   r   r   r   r   rh   r   Timeoutas_dict)r   rn   request_typer   s   &$  r"   _token_exchange_requestr     s    
 >>L')L
43Lv}}^d^p^pNq(r(rD0$sL2I2Q2QR x(v~~d3;;=>	 r$   c               $    V ^8  d   QhRRRRRR/# )r   responsezhttpx2.Response | Noneattemptr   r   r   r    )r!   s   "r"   r#   r#     s'     I I1 IC IL Ir$   c                   V e   V P                   R9  d   V P                   R8  d   R # V P                  P                  R4      pVeM    \        V4      p\        P                  ! T4      '       d   ^ Tu;8:  d   \        8:  d    T#  T\        8  d   R # \        \        \         ^V,          ,          \"        4      4      #   \         d     \
        P                  P                  T4      pTeC   \        \
        P                  P                  T4      \        P                  ! 4       ,
          4      MRp L  \        \        \        3 d    Rp  Li ; ii ; i)Ni  zretry-after)i  i  i  )status_coderC   ri   r   
ValueErroremailutilsparsedate_tz	mktime_tztimer   OSErrorr   r   r   minr   r   )r   r   retry_afterdelayparseds   &&   r"   _retry_delayr     s   68;O;ORU;U&&**=9"k* }}U##U(K6K(K )L,,(1g:5GHH  "[[55kBFRXRdE%++"7"7"?$))+"MNjlE%w
; E	s+   	B? ?EA'D44EEEEc                    V ^8  d   QhRRRR/# r   r0   r1   r   r`   r    )r!   s   "r"   r#   r#   7  s      N t r$   c                   \        \        V R R4      \        4      '       d   R# V P                  p\        VRR4      p\        V\        4      '       Ed   . p\        \        \        ,          V4       F  p\        VRR4      pVe   \        V\        \        34      '       d   K2  \        VRR4      p\        VRR4      p\        VRR4      p\        V4      '       d0   V! 4       '       d#   \        V4      '       d   \        V4      '       g    R# V! 4       p	\        V	\        4      '       g    R# VP                  WY34       K  	  W0P                  \        &   R# \        VR	V4      p
\        V
RR4      p\        V
RR4      p\        V
RR4      p\        V4      '       d0   V! 4       '       d#   \        V4      '       d   \        V4      '       g   R# V! 4       V P                  \        &   R# )
_contentNTfieldsfileseekableseektellF_stream)r   getattrbytesstreamlistr   r   rg   callabler   appendr    _REPLAY_FILE_POSITIONS_EXTENSION_REPLAY_POSITION_EXTENSION)r0   r  r   file_positionsfieldr   r   r   r   positionsources   &          r"   _is_replayable_requestr  7  s   '':t4e<<^^FVXt,F&$35$v,/E5&$/D|z$e==tZ6H4.D4.DH%%XZZx~~U]^bUcUcvHh,,!!4"23 0 @N;<VY/Fvz40H664(D664(DHXZZx~~XVZ^^59VG12r$   c                   V ^8  d   QhRR/# )r   r   ztuple[type[Exception], ...]r    )r!   s   "r"   r#   r#   Y  s     ; ;6 ;r$   c                     \        4       p V f   \        P                  3# \        \        \
        ,          \        V R\        P                  4      4      p\        P                  V3# )NTransportError)r   rR   r  r   r   	Exceptionr  )r   legacy_transport_errors     r"   _transport_errorsr  Y  sS    ')L%%''!$y/7<IY[a[p[p3qr!!#9::r$   c                    V ^8  d   QhRRRR/# )r   rY   r  r   r   r    )r!   s   "r"   r#   r#   a  s     9 9) 9 9r$   c                    \        \        P                  R ,          \        V RR 4      4      pVf   \	        R4      V h\        V \        4       4      '       d   \        VR7      V h\        VR7      V h)Nr0   z&X.509 token exchange connection failedrD   )	r   rR   r   r  r   r   r
   r   r   )rY   r0   s   & r"   _raise_transport_errorr  a  s^    6>>D('%D*IJGBCN%+-..g.E9
W
-58r$   c                     a  ] tR tRtR V 3R llt]R V 3R ll4       t]R R l4       t]R R	 l4       t]R
 R l4       t	Rt
V ;t# )_X509WorkloadIdentityAuthij  c               $    V ^8  d   QhRRRRRR/# )r   workload_identityr   max_retriesr   r   r   r    )r!   s   "r"   r#   &_X509WorkloadIdentityAuth.__annotate__k  s$     ' '-A 'PS 'X\ 'r$   c               	   < \        V4       \        SV `	  V\        R 7       \	        \        V^ 4      \        4      V n        RV n        R# ))r  token_exchange_urlFN)	r   superrz   rh   r   max_MAX_EXCHANGE_RETRIES_max_exchange_retries_follow_redirects)ry   r  r  	__class__s   &$$r"   rz   "_X509WorkloadIdentityAuth.__init__k  s?    ,-+<Qij%([!)<>S%T"!&r$   c                    V ^8  d   QhRRRR/# )r   r   r   r   dict[str, Any]r    )r!   s   "r"   r#   r  r  s     < < <> <r$   c                	^  < VP                   R	9  d   \        SV `	  V4      pVP                  4       pVP	                  R4      pRV9   d7   \        V\        4      '       d   VP                  4       R8w  d   \        R4      h\        P                  VR,          4      f   \        R4      hV#  VP                  '       d   VP                  4       MRp\        V4      '       d   VP	                  R4      MRp\        V\        4      '       d   RV/MRp\        WR7      h  \         d    Rp L[i ; i)
  
token_typebearerz<X.509 token exchange response must use the Bearer token typeaccess_tokenNzIX.509 token exchange response did not include a valid Bearer access_tokenrY   )r   body)r*  i  i  )r   r   _handle_token_responser   ri   r   rg   r:   r   _BEARER_ACCESS_TOKEN	fullmatchcontentr   r	   r   )ry   r   
token_dataresponse_bodyr+  oauth_error	safe_bodyr%  s   &&     r"   r/  0_X509WorkloadIdentityAuth._handle_token_responseq  s   67AJ$MMOM&**<8J},jS6Q6QU_UeUeUgksUs!"`aa#--j.HIQ!"mnn	!/7/?/?/?HMMOTM 5<M4J4Jm''0PT.8c.J.JWk*PT	(;;  	! M	!s   ,D >D D,+D,c                    V ^8  d   QhRRRR/# )r   
expires_inr   r   r   r    )r!   s   "r"   r#   r    s        v  %  r$   c                	H    \        V4      pVe   V^ 8:  d   \        R4      hV# )NzKX.509 token exchange response did not include a positive, finite expires_in)r   r   )ry   r9  expires_in_values   && r"   _validate_expires_in._X509WorkloadIdentityAuth._validate_expires_in  s-    +J7#'71'<kllr$   c                    V ^8  d   QhRRRR/# r   r    )r!   s   "r"   r#   r    s     / /. /T /r$   c                	    \        V4      # rr   )r  r   s   &&r"   _can_retry_request,_X509WorkloadIdentityAuth._can_retry_request  s    %g..r$   c                    V ^8  d   QhRRRR/# r/   r    )r!   s   "r"   r#   r    s      n  r$   c                	.   VP                   P                  \        4      p\        V\        4      '       d`   \        \        \        \        \        3,          ,          V4       F-  w  r4\        VR R4      p\        V4      '       g   K%  V! V4       K/  	  R# VP                   P                  \        4      p\        V\        4      '       g   R# \        VP                  RVP                  4      p\        VR R4      p\        V4      '       d   V! V4       R# R# )r   Nr  )r   ri   r  r   r  r   tupler   r   r  r  r	  r  )ry   r0   r
  r   file_positionr   r  r  s   &&      r"   _prepare_retry_request0_X509WorkloadIdentityAuth._prepare_retry_request  s     ++//0PQnd++'+Dvs{1C,Dn'U#tVT2D>>' (V %%))*DE(C((GNNCvvt,D>>N r$   )r$  r#  )r   r   r   r   rz   r   r/  r<  r@  rF  r   __classcell__r%  s   @r"   r  r  j  s]    ' ' < <(     / /  r$   r  c                  P   a  ] tR tRtR V 3R lltR R lt]R R l4       tRtV ;t	# )	SyncX509WorkloadIdentityAuthi  c               (    V ^8  d   QhRRRRRRRR/# )	r   r  r   rn   ro   r  r   r   r   r    )r!   s   "r"   r#   )SyncX509WorkloadIdentityAuth.__annotate__  s,     ( ($8(GT(cf(	(r$   c               	4   < \         SV `  WR 7       W n        R# )r  r  N)r   rz   rt   ry   r  rn   r  r%  s   &$$$r"   rz   %SyncX509WorkloadIdentityAuth.__init__  s     	+<V'r$   c               0    V ^8  d   QhRRRRRRRRR	R
RR/# r   r0   r1   r   r\   r]   r^   r  r`   kwargsr   r   r   r    )r!   s   "r"   r#   rM    sN     H HH $	H
 !+H H H 
Hr$   c               	    \        V P                  VVR 7      ;_uu_ 4       pVP                  ! V3RV/VB uuRRR4       #   + '       g   i     R# ; i)r   r]   r  N)r   rt   sendry   r0   r   r]   r  rT  r   s   &&$$$, r"   send_api_request-SyncX509WorkloadIdentityAuth.send_api_request  sR     !+#9
 
  %%gGfGG
 
 
 
s   AA	c                   V ^8  d   QhRR/# r   r   r(  r    )r!   s   "r"   r#   rM    s     W WN Wr$   c           
     	   \        V P                  ^,           4       F  p \        V P                  \        P
                  ! \        4      RR7      ;_uu_ 4       pVP                  \        V P                  V P                  R7      RRR7      pRRR4       \        XV4      pWP                  8  g   Vf   V P                  V4      u #  Vf   K  \        P                  ! V4       K  	  \!        R4      h  + '       g   i     Lo; i  \        4        d2   pYP                  8  d   \        T4       \        RT4      p Rp?LyRp?ii ; i)   Tr   r_   rn   NFauthfollow_redirects6X.509 token exchange retry loop exhausted unexpectedly)ranger#  r   rt   rR   rS   rh   rW  r   r  r   r/  r  r  r   sleepAssertionErrorry   r   r   r   r   rY   s   &     r"   _fetch_token_from_exchange7SyncX509WorkloadIdentityAuth._fetch_token_from_exchange  s   T77!;<GA(%%$*JJ/G$H#'  #,11/0F0FTXTeTef!).  2  H %Xw7888EM66x@@ =J  

5!- =0 UVV-  %& 4888*51$T734s/   8D4C4D4D?DE'EE)rt   )
r   r   r   r   rz   rY  r   ri  r   rH  rI  s   @r"   rK  rK    s)    ( (H  W Wr$   rK  c                  \   a  ] tR tRtR V 3R lltR R lt]R R l4       tR R	 ltR
t	V ;t
# )AsyncX509WorkloadIdentityAuthi  c               (    V ^8  d   QhRRRRRRRR/# )	r   r  r   rn   r   r  r   r   r   r    )r!   s   "r"   r#   *AsyncX509WorkloadIdentityAuth.__annotate__  s,     ( ($8(GY(hk(	(r$   c               	h   < \         SV `  WR 7       W n        \        P                  ! 4       V n        R# rO  )r   rz   rt   anyioLock_async_lockrP  s   &$$$r"   rz   &AsyncX509WorkloadIdentityAuth.__init__  s*     	+<V' ::<r$   c               0    V ^8  d   QhRRRRRRRRR	R
RR/# rS  r    )r!   s   "r"   r#   rn    sN     N NN $	N
 !+N N N 
Nr$   c               	   "   \        V P                  VVR 7      ;_uu_4       GRj  xL
 pVP                  ! V3RV/VB G Rj  xL
 uuRRR4      GRj  xL
  #  L3 L L	  + GRj  xL 
 '       g   i     R# ; i5i)rV  Nr  )r   rt   rW  rX  s   &&$$$, r"   rY  .AsyncX509WorkloadIdentityAuth.send_api_request  sq      (+#9
 
 
 &++GMFMfMM
 
 

 N
 
 
 
s\   %A>AA>A!AA!A>AA>A!A>!A;	'A*(
A;	3A;	5	A>c                   V ^8  d   QhRR/# )r   r   rg   r    )r!   s   "r"   r#   rn    s     	5 	5s 	5r$   c           	     	  "   V P                   ;_uu_4       GR j  xL
  V P                  ;_uu_ 4        V P                  4       '       gM   V P                  4       '       g7   \	        \
        V P                  4      uuR R R 4       uuR R R 4      GR j  xL
  # R R R 4       V P                  4       G R j  xL
 pV P                  V4       V P                  ;_uu_ 4        \	        \
        V P                  4      uuR R R 4       uuR R R 4      GR j  xL
  #  L L  + '       g   i     L; i Lw L  + '       g   i     M; iR R R 4      GR j  xL 
  R #   + GR j  xL 
 '       g   i     R # ; i5irr   )	rr  _lock_token_unusable_needs_refreshr   rg   _cached_token _fetch_token_from_exchange_async_store_token)ry   r3  s   & r"   get_token_async-AsyncX509WorkloadIdentityAuth.get_token_async  s     ####++--d6I6I6K6KT%7%78  $##  $DDFFJj)C!3!34  $## G $  $#####s   E1DE1E,D	!D	:
EE1DE1E2D*3)ED.	6
E E1D,E1E1D'"	E,E1.D>9EE1EE1E.	E
E.	&E.	(	E1c                   V ^8  d   QhRR/# r\  r    )r!   s   "r"   r#   rn    s     W W Wr$   c           
     	  "   \        V P                  ^,           4       F  p \        V P                  \        P
                  ! \        4      RR7      ;_uu_4       GRj  xL
 pVP                  \        V P                  V P                  R7      RRR7      G Rj  xL
 pRRR4      GRj  xL
  \        XV4      pWP                  8  g   Vf   V P                  V4      u #  Vf   K  \        P                  ! V4      G Rj  xL
  K  	  \!        R4      h L L} Lo  + GRj  xL 
 '       g   i     L; i  \        4        d2   pYP                  8  d   \        T4       \        RT4      p Rp?LRp?ii ; i Lx5i)r^  Tr_  Nr`  Fra  rd  )re  r#  r   rt   rR   rS   rh   rW  r   r  r   r/  r  r  rp  rf  rg  rh  s   &     r"   r}  >AsyncX509WorkloadIdentityAuth._fetch_token_from_exchange_async  sK    T77!;<GA/%%$*JJ/G$H#'   #%2%7%7/0F0FTXTeTef!). &8 &  H  %Xw7888EM66x@@ =J  kk%(((- =0 UVV-
     %& 4888*51$T734 )s    E=<D8D
 D8#7DD
DD8*D+D8/5E=)E=E;E=D8DD8D5"D%#
D5.D50D88E8'E3.E=3E88E=)rr  rt   )r   r   r   r   rz   rY  r   r  r}  r   rH  rI  s   @r"   rl  rl    s3    ( (N  	5 	5W Wr$   rl  >   r   r   r   r   )C
__future__r   rer   r   email.utilsr   typingr   r   r   typing_extensionsr   r   rp  rR   _utilsr	   _httpx2r
   r   r   	_workloadr   r   r   r   
_constantsr   r   r   _exceptionsr   r   r   r   MTLS_API_BASE_URLrh   r   r"  r	  r  r   compiler0  r-   rE   rZ   rj   BaseTransportrl   AsyncBaseTransportr   r   r   r   r   r   r   r   r   r  r  r  r  rK  rl  r    r$   r"   <module>r     s\   " 	    & & .    S S  U T V V4 E D  : #F  k zz"9: aY] aj_2o26#7#7 @F$=$= @ *.	
 !8 *.	
 !83Ch"$I0D;97 56J K 7t1W#< 1Wh=W$= =Wr$   