IThlSSKJr SSKJr SSKJrJr SSKrSSKJ r SSKJ r J r J r "S S \ \5r\"S S 9"S S55r\"S S 9"SS55rS\R"S\\4SjrS\\ \ 4S\\4Sjr\ S\S\\ \ 4S\4Sj5r\ SSSS.S\S\ S\ S\\ S\\ \ 4S\\ S\\\ \ 4S\4Sjj5r\ S"S \ S\\ \ 4S\\\ \ 4S\4S!jj5rg)#) dataclass)Enum)DictOptionalN) constants) get_sessionhf_raise_for_statusvalidate_hf_hub_argsc\rSrSrSrSrSrg) XetTokenType readwriteN)__name__ __module__ __qualname____firstlineno__READWRITE__static_attributes__rR/var/www/auris/envauris/lib/python3.13/site-packages/huggingface_hub/utils/_xet.pyrr s D ErrT)frozenc*\rSrSr%\\S'\\S'Srg) XetFileData file_hash refresh_routerN)rrrrstr__annotations__rrrrrrs Nrrc4\rSrSr%\\S'\\S'\\S'Srg)XetConnectionInfo access_tokenexpiration_unix_epochendpointrN)rrrrr"r#intrrrrr%r%sMrr%responsereturnc4UcgUR[Rn[RUR;a!UR[RSnOUR[R n[UUS9$![ a gf=f)a5 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 (`requests.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_ROUTEKeyErrorr)r+r r!s r!parse_xet_file_data_from_responser5s$$Y%L%LM  9 9X^^ K$NN9+Y+YZ[`aM$,,Y-]-]^M #  sAB "B BBr/cU[RnU[Rn[U[R5n[UUUS9$![ [ [4a gf=f)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)r)r'r() r!HUGGINGFACE_HEADER_X_XET_ENDPOINT%HUGGINGFACE_HEADER_X_XET_ACCESS_TOKENr*#HUGGINGFACE_HEADER_X_XET_EXPIRATIONr4 ValueError TypeErrorr%)r/r)r'r(s r&parse_xet_connection_info_from_headersr<>sp9FFGyNNO #GI,Y,Y$Z [ !3  j) ,sAAA'&A' file_datac^URc [S5e[URU5$)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!r:#_fetch_xet_connection_info_with_url)r=r/s rrefresh_xet_connection_infor@Ws/.&YZZ .y/F/F PPr)revisionr)params token_typerepo_id repo_typerAr)rBc xUbUO[RnUSUSUSURSU3 n[XtU5$)aa Uses the repo info to request a xet access token from Hub. 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 to upload to: `"model"`, `"dataset"` or `"space"`. revision (`str`, `optional`): The revision of the repo to get the token for. headers (`Dict[str, str]`): Headers to use for the request, including authorization headers and user agent. endpoint (`str`, `optional`): The endpoint to use for the request. Defaults to the Hub endpoint. params (`Dict[str, str]`, `optional`): Additional parameters to pass with the request. 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/api/zs/z/xet-z-token/)rENDPOINTvaluer?)rCrDrErAr/r)rBr.s r(fetch_xet_connection_info_from_repo_inforIssNJ$/xY5G5GH JeI;b z7G7G6HPXz ZC .sV DDrr.c[5RXUS9n[U5 [UR5nUc [ S5eU$)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. Args: url: (`str`): The access token endpoint URL. headers (`Dict[str, str]`): Headers to use for the request, including authorization headers and user agent. params (`Dict[str, str]`, `optional`): Additional parameters to pass with the request. 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. )r/r.rBz6Xet headers have not been correctly set by the server.)r getr r<r/r:)r.r/rBrespmetadatas rr?r?sH2 =  Wf  ED5dllCHQRR Or)N) dataclassesrenumrtypingrrrequestsrr r r r"rrr%Responser5r<r@rIr?rrrrTs!!DD3  $  $ 0A0Ah{F[BDcNxPaGb2QQ#s(^Q QQ6 #"'+&E&E&E &E sm &E #s(^ &Esm&E T#s(^ $&E&E&ER(,  #s(^ T#s(^ $ r