+ j04aR,t-0t^RIt^RIt^RIt^RIt^RIHt^RIHt^RI H t ^RI H t ^RI t ^RIHt^RIHtHtHt]P&!R4t^\\PV44#)zLReturn whether `xet_hash` looks like a real Xet content hash (64 hex chars).)r_REGEX_XET_HASH fullmatch)r s&ris_valid_xet_hashrs ))(3 44rc]tRt^tRtRtRtR#) XetTokenTypereadwriteN)__name__ __module__ __qualname____firstlineno__READWRITE__static_attributes__rrrrrs D ErrT)frozenc,a]tRt^#toV3RltRtVtR#) XetFileDatac2<V^8dQh/S[;R&S[;R&#)r file_hash refresh_route)r)r __classdict__s"rrXetFileData.__annotate__#sNrrNrrr r!__annotate_func__r$__classdictcell__r+s@rr'r'#rr'c,a]tRt^)toV3RltRtVtR#)XetConnectionInfoc><V^8dQh/S[;R&S[;R&S[;R&#)r access_tokenexpiration_unix_epochendpoint)rint)rr+s"rrXetConnectionInfo.__annotate__)s)M rrNr-r0s@rr3r3)r1rr3clV^8dQhR\PR\R,R\R,/#)r responser7Nr)httpxResponserr')rs"rrr0s1   #PT* `knr`r rcVVfR#VP\P,p\PVP9d*VP\P,R,pM"VP\P ,pVeTM\PpVP\P4'd?VP\PPR4VPR44p\VVR7# \ dR#i;i)a2 Parse XET file metadata from an HTTP response. This function extracts XET file metadata from the HTTP headers or HTTP links of a given response object. If the required metadata is not found, it returns `None`. Args: response (`httpx.Response`): The HTTP response object containing headers dict and links dict to extract the XET metadata from. Returns: `Optional[XetFileData]`: An instance of `XetFileData` containing the file hash and refresh route if the metadata is found. Returns `None` if the required metadata is missing. Nurl/)r)r*) headersrHUGGINGFACE_HEADER_X_XET_HASH$HUGGINGFACE_HEADER_LINK_XET_AUTH_KEYlinks&HUGGINGFACE_HEADER_X_XET_REFRESH_ROUTEKeyErrorENDPOINT startswithHUGGINGFACE_CO_URL_HOMEreplacerstripr')r;r7r)r*s&& r!parse_xet_file_data_from_responserL0s$$Y%L%LM  9 9X^^ K$NN9+Y+YZ[`aM$,,Y-]-]^M$/xY5G5GH A ABB%--i.O.O.V.VWZ.[]e]l]lmp]qr #  sA(D1!D D('D(c`V^8dQhR\\\3,R\R,/#)r rArN)rrr3)rs"rrrSs*GCH4EJ[^bJbrcV\P,pV\P,p\V\P,4p\TTTR7# \ \ \3dR#i;i)a` Parse XET connection info from the HTTP headers or return None if not found. Args: headers (`dict`): HTTP headers to extract the XET metadata from. Returns: `XetConnectionInfo` or `None`: The information needed to connect to the XET storage service. Returns `None` if the headers do not contain the XET connection info. N)r7r5r6) r!HUGGINGFACE_HEADER_X_XET_ENDPOINT%HUGGINGFACE_HEADER_X_XET_ACCESS_TOKENr8#HUGGINGFACE_HEADER_X_XET_EXPIRATIONrF ValueError TypeErrorr3)rAr7r5r6s& r&parse_xet_connection_info_from_headersrTSsp9FFGyNNO #GI,Y,Y$Z [ !3  j) ,sAAA87A8c^V^8dQhR\R\\\3,R\/#)r file_datarAr)r'dictrr3)rs"rrrms5QQQ#s(^Q Qrc`VPf \R4h\VPV4#)a Utilizes the information in the parsed metadata to request the Hub xet connection information. This includes the access token, expiration, and XET service URL. Args: file_data: (`XetFileData`): The file data needed to refresh the xet connection information. headers (`dict[str, str]`): Headers to use for the request, including authorization headers and user agent. Returns: `XetConnectionInfo`: The connection information needed to make the request to the xet storage service. Raises: [`~utils.HfHubHTTPError`] If the Hub API returned an error. [`ValueError`](https://docs.python.org/3/library/exceptions.html#ValueError) If the Hub API response is improperly formatted. z>The provided xet metadata does not contain a refresh endpoint.)r*rR#_fetch_xet_connection_info_with_url)rVrAs$$rrefresh_xet_connection_inforZls/.&YZZ .y/F/F PPrc^V^8dQhR\R\\\3,R\/#r r?rAr)rrWr3)rs"rrrs.;; ; #s(^;;rc F\W4p\PV4pVe\V4'gV#\ V4;_uu_4\PV4pVe\V4'g VuuRRR4#\ RWR7p\ V4\VP4pVf \R4h\;_uu_4\\P44F.wrg\V4'gK\PVR4K0 \\4\8d,\P\!\#\444V\V&RRR4VuuRRR4# +'giL;i +'giR#;i)a Requests the xet connection info from the supplied URL. This includes the access token, expiration time, and endpoint to use for the xet storage service. Result is cached to avoid redundant requests. Args: url: (`str`): The access token endpoint URL. headers (`dict[str, str]`): Headers to use for the request, including authorization headers and user agent. Returns: `XetConnectionInfo`: The connection information needed to make the request to the xet storage service. Raises: [`~utils.HfHubHTTPError`] If the Hub API returned an error. [`ValueError`](https://docs.python.org/3/library/exceptions.html#ValueError) If the Hub API response is improperly formatted. NGET)rAz6Xet headers have not been correctly set by the server.) _cache_keyXET_CONNECTION_INFO_CACHEget _is_expired _key_lockr rrTrArR_XET_CONNECTION_INFO_LOCKlistitemspoplenXET_CONNECTION_INFO_CACHE_SIZEnextiter)r?rA cache_key cached_inforespmetadatakvs&& rrYrYs<43(I+// :K;''  9  /33I>  ";{+C+C   E38D!9$,,G  UV V & &6<<>?q>>-11!T:@ ,-1OO)--d48Q3R.ST4< %i 0'5  ' &   s2 ,FA F 1E< A&E< ( F< F F F c^V^8dQhR\R\\\3,R\/#r\)rrW)rs"rrrs)""C"$sCx."S"rcVP4UUu/uFwr#VP4VbK pppVPRR4pV RV 2#uuppi)z;Return a unique cache key for the given request parameters. authorization|)rflowerra)r?rArprq lower_headers auth_headers&& rr_r_sP.5mmo>odaQWWY\oM>##OR8KU!K= !!?sA cDV^8dQhR\R\P/#)r rlr)r threadingLock)rs"rrrs"VVVVrc\;_uu_4\PV\P!44uuRRR4# +'giR#;i)zNReturn the lock guarding token fetches for `cache_key`, creating it if needed.N)rd_XET_CONNECTION_INFO_KEY_LOCKS setdefaultr{r|)rls&rrcrcs. " "-88INNDTU # " " "s )A A c0V^8dQhR\R\/#)r connection_infor)r3r)rs"rrrsii!2itircnVP\\P!44\,8*#)z2Check if the given XET connection info is expired.)r6r8time!XET_CONNECTION_INFO_SAFETY_PERIOD)rs&rrbrbs$  0 0C 4DGh4h hhrrevisionr7c |V^8dQhR\R\R\R\R,R\R,R\/#)r token_typerepo_id repo_typerNr7r)rr)rs"rrrsN!!!! ! Dj ! Dj ! !rcVeTM\PpV RV RV RVP R2pVR8wgVe VRV 2, pV#)a Build the URL used to fetch or refresh a Xet access token for a given repo. Args: token_type (`XetTokenType`): Type of the token to request: `"read"` or `"write"`. repo_id (`str`): A namespace (user or an organization) and a repo name separated by a `/`. repo_type (`str`): Type of the repo (e.g. `"model"`, `"dataset"`, `"space"`, `"bucket"`). revision (`str`, `optional`): The revision of the repo to get the token for. endpoint (`str`, `optional`): The endpoint to use for the request. Defaults to the Hub endpoint. Returns: `str`: The fully-qualified URL of the token refresh endpoint. z/api/zs/z/xet-z-tokenbucketr@)rrGvalue)rrrrr7r?s$$$$$ rxet_connection_info_refresh_urlrs_4$/xY5G5GH JeI;b z7G7G6H OCH 4 8*~ JrcBa]tRt^toRtV3RlRltRtRtRtVt R#)XetSessionHoldera'Holds an optional XetSession; supports safe re-creation after sigint_abort or fork. Thread-safe: a ``threading.Lock`` guards all state mutations, which matters for free-threaded Python (3.14t) where multiple threads can race on ``get()`` or ``sigint_abort()`` without the GIL serialising them. c<V^8dQhRR/#)r rNr)rr+s"rrXetSessionHolder.__annotate__s--$-rcV\P!4VnRVnRVnR#N)r{r|_lock_session _session_pidselfs&r__init__XetSessionHolder.__init__s^^% ! (,rc BVP;_uu_4\P!4pVPeVPV8wdRVnVPf^RIHpV!4VnWnVPuuRRR4# +'giR#;i)zReturn the current session, creating one if needed. Fork-safe: if the current process PID differs from the PID that created the session (i.e. we are in a forked child), the old session is discarded and a fresh session is created for this process. N) XetSession)rosgetpidrrhf_xetr)r current_pidrs& rraXetSessionHolder.get sgZZZ))+K}}(T->->+-M!% }}$- *  $/!==ZZZs A-B  B c VP;_uu_4VPe*VPP4RVnRVnRRR4R# \dL%i;i +'giR#;i)zMAbort the current session and clear it so the next get() creates a fresh one.N)rr sigint_abort Exceptionrrs&rrXetSessionHolder.sigint_abort#s` ZZZ}}(MM..0!% $(!Z! ZZs-A(AA( A%"A($A%%A(( A9 )rrrN) rrr r!__doc__rrarr$r/r0s@rrrs#-- !0 ) )rrc*\P4#)aReturn the global :class:`hf_xet.XetSession`, creating it on first call. The session is shared across all calls within a process, just as the HTTP client returned by :func:`~huggingface_hub.utils._http.get_session` is shared. It is created lazily and is fork-safe and thread-safe. )_GLOBAL_XET_HOLDERrarrrget_xet_sessionr2s  ! ! ##rctV^8dQhR\\\3,R\\\3,/#)r rAr)rWr)rs"rrr<s.\\d38n\c3h\rcVP4UUu/uFwrVP4R8wgKWbK upp#uuppi)zReturn a copy of headers with the authorization header removed. Xet storage requests use a short-lived xet access token for auth, so the Hub authorization header must not be forwarded to xet storage endpoints. rt)rfrw)rAkeyrs& rxet_headers_without_authr<s5 *1 [:3CIIK?4%8 89>' *?>S)..%8 9>+ rr).rrrer{rcollections.abcr dataclassesrenumrtypingrr<rurrr r compilerrrir`r|rdr~rrrr'r3rLrTrZrYr_rcrbrrrrrrr)rs@rrsM  #! EE**12$&!!&<>>%NN,<>>5 3  $  $ F2QQ6;;|"V i !  !  !!H.).)b&'$\&r