/jo UdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z ddl mZddlmZddlmZddlmZddlmZdd lmZmZdd lmZmZddlZdd lmZd d l m!Z!d dl"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ddl m,Z,ddl-m.Z.ddl/m0Z0m1Z1e,jde3Z4edGddZ5ejldZ7ejldZ8de e9e9fde5dzfdZ:de e9e9fde;dzfdZdZ?ejld ej!ZAejld"ej!ZBejld#ZCejld$ZDejld%ZEejld&ZFhd'ZGd(e9deHe9dze9dzffd)ZId(e9de9dzfd*ZJd(e9de9dzfd+ZKed,d-.ZLeeMeNd,<d/e1de1fd0ZOd1ejde9dzfd2ZQd1ejde9dzfd3ZRd4ejddfd5ZTdejfd6ZVdejfd7ZXe gejfZYe gejfZZejZ\eVa]eYeNd8<eXa^eZeNd9<da_ejdzeNd:<d;eYddfd<Z`d=eZddfd>Zadejfd?Zbdejfd@Zcd{dAZdejedefedBrejedCejejejfZkeHelemdDfeNdE<dFZneHe;dDfeNdG<dHddIekend-dJdKe0d(e9dLe;dMeodNeodOelemeHelemdDfzdPe;eHe;dDfzdQeMde ejddffdRZpdHddIekendSdKe0d(e9dLe;dMeodNeodOelemeHelemdDfzdPe;eHe;dDfzdejfdTZqedHddIekendSdKe0d(e9dLe;dMeodNeodOelemeHelemdDfzdPe;eHe;dDfzde ejddffdUZrdVZsd-dWdKe0d(e9dXeMdejfdYZtdZd[d\Zud(e9deHe9e9e;ffd]Zvewd^e!je!je!jd_fDZ{d(e9d`e9deMfdaZ|d(e9dbe9dzde9fdcZ}d|d4ejdde9dzddfdeZ~eZd4ejddfdfZedge'hZdieledje9d4ejdkedef dlZdmZeDcgc]9}ejldn|dodpfejldq|drdsffD]}|;c}}Zdte9de9fduZd1ejde9fdvZejldwejZdxe9dzdye;de9dzfdzZycc}}w)}z>Contains utilities to handle HTTP requests in huggingface_hub.N)Callable GeneratorMapping)contextmanager) ContextVar) dataclasswraps)quote)AnyTypeVar)urljoinurlparse)OfflineModeIsEnabled) constants) BadRequestErrorBucketNotFoundErrorDisabledRepoErrorGatedRepoErrorHfHubHTTPErrorJobNotFoundErrorRemoteEntryNotFoundErrorRepositoryNotFoundErrorRevisionNotFoundError)logging) SliceFileObj) HTTP_METHOD_T CallableTT)frozencXeZdZUdZeed<eed<eed<dZedzed<dZedzed<y) RateLimitInfoa Parsed rate limit information from HTTP response headers. Attributes: resource_type (`str`): The type of resource being rate limited. remaining (`int`): The number of requests remaining in the current window. reset_in_seconds (`int`): The number of seconds until the rate limit resets. limit (`int`, *optional*): The maximum number of requests allowed in the current window. window_seconds (`int`, *optional*): The number of seconds in the current window. resource_type remainingreset_in_secondsNlimitwindow_seconds) __name__ __module__ __qualname____doc__str__annotations__intr'r(^/root/repos/pocs/video-evals/.venv/lib/python3.12/site-packages/huggingface_hub/utils/_http.pyr#r#9s6 NE3:!%NC$J%r1r#zL\"(?P\w+)\"\s*;\s*r\s*=\s*(?P\d+)\s*;\s*t\s*=\s*(?P\d+)z'q\s*=\s*(?P\d+).*?w\s*=\s*(?P\d+)headersreturncd}d}|D](}|j}|dk(r||}|dk(s$||}*|sytj|}|sy|jd}t |jd}t |jd}d} d} |rKt j|} | r4t | jd} t | jd} t |||| | S) a*Parse rate limit information from HTTP response headers. Follows IETF draft: https://www.ietf.org/archive/id/draft-ietf-httpapi-ratelimit-headers-09.html Only a subset is implemented. Example: ```python >>> from huggingface_hub.utils import parse_ratelimit_headers >>> headers = { ... "ratelimit": '"api";r=0;t=55', ... "ratelimit-policy": '"fixed window";"api";q=500;w=300', ... } >>> info = parse_ratelimit_headers(headers) >>> info.remaining 0 >>> info.reset_in_seconds 55 ``` N ratelimitzratelimit-policyr$rtqw)r$r%r&r'r()lower_RATELIMIT_REGEXsearchgroupr/_RATELIMIT_POLICY_REGEXr#) r3r6policykey lower_keymatchr$r%r&r'r( policy_matchs r2parse_ratelimit_headersrEUs*!IF"IIK  # I , ,S\F "   # #I .E KK0MEKK$%I5;;s+,E!%N .55f=  **3/0E !3!3C!89N #)%  r1cd}|D]}|jdk(s||}n|y|j}|sy|jr t|Sy)a[Parse the standard `Retry-After` HTTP header into a number of seconds to wait. The `Retry-After` header can be either a non-negative number of seconds (delay-seconds) or an HTTP-date after which to retry. We handle only the delay-seconds case. See https://developer.mozilla.org/en-US/docs/Web/HTTP/Reference/Headers/Retry-After. Nz retry-after)r;stripisdigitr/)r3valuerAs r2_parse_retry_afterrJscE 99;- 'CLE   } KKME  }}5z r1z x-request-idzX-Amzn-Trace-Idz x-amz-cf-ida  # staging or production endpoint ^https://[^/]+ ( # on /api/repo_type/repo_id /api/(models|datasets|spaces)/(.+) | # or /repo_id/resolve/revision/... /(.+)/resolve/(.+) ) )flagszz # staging or production endpoint ^https?://[^/]+ # on /api/buckets/... /api/buckets/ z:^https?://[^/]+/api/(?:scheduled-jobs|jobs)/[^/]+/([^/?]+)zC^https?://[^/]+/api/(models|datasets|spaces)/([^/?]+)(?:/([^/?]+))?zL^https?://[^/]+/(?:(datasets|spaces|kernels)/)?([^/?]+(?:/[^/?]+)?)/resolve/z+^https?://[^/]+/api/buckets/([^/?]+/[^/?]+)> rawblobrefstreecommitresolverevisionsettings discussionsurlctj|x}r7tj|j dxsd|j dfSt j|}|sytjj |j d}|j d|j d}}|r|tvr |d|}||fS|}||fS)aExtract (repo_type, repo_id) from an API URL or a download URL. Returns canonical repo_type values: "model", "dataset", "space" (or None). Examples: >>> _parse_repo_info_from_url("https://huggingface.co/api/models/user/repo") ("model", "user/repo") >>> _parse_repo_info_from_url("https://huggingface.co/api/datasets/user/repo/resolve/main/data.csv") ("dataset", "user/repo") >>> _parse_repo_info_from_url("https://huggingface.co/api/models/bert-base-cased/resolve/main/config.json") ("model", "bert-base-cased") >>> _parse_repo_info_from_url("https://huggingface.co/datasets/user/repo/resolve/main/data.csv") ("dataset", "user/repo") rmodelsrNN/)_REPO_ID_FROM_RESOLVE_URL_REGEXr=rREPO_TYPES_MAPPINGr>_REPO_ID_FROM_URL_REGEXget_REPO_URL_SUBPATHS)rUrC repo_typefirstsecondrepo_ids r2_parse_repo_info_from_urlrds066s;;u;++EKKN,FhGUVWW # * *3 /E ,,00Q@IKKNEKKN6E & 22G1VH% g  g r1cVtj|}|r|jdSdS)z9Extract bucket_id (namespace/name) from a bucket API URL.rN)_BUCKET_ID_FROM_URL_REGEXr=r>rUrCs r2_parse_bucket_id_from_urlrhs' % , ,S 1E"5;;q>,,r1cVtj|}|r|jdSdS)z>Extract the job_id from a (scheduled) job API URL, if present.rN)_JOB_ID_FROM_URL_REGEXr=r>rgs r2_parse_job_id_from_urlrks' " ) )# .E"5;;q>,,r1_IS_DOWNLOAD_CALLF)defaultfnc.tfd}|S)a#Decorator to tag all HTTP calls made by `fn` with the `X-HF-Download-Counter` header. Applied on `hf_hub_download`, `snapshot_download`, etc. so that every call they make through [`get_session`] is flagged as part of a download, no matter how deep in the call stack it happens. ctjd} |i|tj|S#tj|wxYw)NT)rlsetreset)argskwargstokenrns r2_innerz%flag_as_download_call.._innersC!%%d+ +t&v&  # #E *  # #E *s 5A r )rnrvs` r2flag_as_download_callrw s" 2Y++ Mr1requestc tjrtd|jdtj rd|j tj<t|j vrO|j j txsttj|j t<|j j t}tjd||j|j|j j ddutj rtjdt#||S)a1 Event hook that will be used to make HTTP requests to the Hugging Face Hub. What it does: - Block requests if offline mode is enabled - Add a request ID to the request headers - Flag the request as part of a download, if applicable - Log the request if debug mode is enabled z Cannot reach za: offline mode is enabled. To disable it, please unset the `HF_HUB_OFFLINE` environment variable.1z%Request %s: %s %s (authenticated: %s) authorizationNzSend: %s)ris_offline_moderrUrlr^r3X_HF_DOWNLOAD_COUNTERX_AMZN_TRACE_ID X_REQUEST_IDr-uuiduuid4loggerdebugmethodHF_DEBUG_curlify)rx request_ids r2hf_request_event_hookrs  ""GKK=)J K  ;> 778goo-+2??+>+>|+L+aPSTXT^T^T`Pa($$_5J LL/ O,D8  Z'!23 r1c Kt|Sw)z3 Async version of `hf_request_event_hook`. )r)rxs r2async_hf_request_event_hookr@s ! ))s responsecK|jdk\rGd|jvr8 t|jd}|dkr|j d{yyyy#t$rYywxYw7w)NzContent-lengthi@B) status_coder3r/ ValueErroraread)rlengths r2async_hf_response_event_hookrGss" x// / X--.>?@ !nn&&&" 0#   's3A+AA+A)A+ A&#A+%A&&A+c@tjdtgiddS)zR Factory function to create a `httpx2.Client` with the default transport. rxTN event_hooksfollow_redirectstimeout)httpx2Clientrr0r1r2default_client_factoryrUs' ==!6 78 r1cLtjtgtgdddS)zW Factory function to create a `httpx2.AsyncClient` with the default transport. )rxrTNr)r AsyncClientrrr0r1r2default_async_client_factoryr`s,   !< =LhKij r1_GLOBAL_CLIENT_FACTORY_GLOBAL_ASYNC_CLIENT_FACTORY_GLOBAL_CLIENTclient_factorycRt5t|adddy#1swYyxYw)a" Set the HTTP client factory to be used by `huggingface_hub`. The client factory is a method that returns a `httpx2.Client` object. On the first call to [`get_session`] the client factory will be used to create a new `httpx2.Client` object that will be shared between all calls made by `huggingface_hub`. This can be useful if you are running your scripts in a specific environment requiring custom configuration (e.g. custom proxy or certifications). Use [`get_session`] to get a correctly configured `httpx2.Client`. N) _CLIENT_LOCK close_sessionr)rs r2set_client_factoryrts' 0!/000s &async_client_factoryc|ay)a Set the HTTP async client factory to be used by `huggingface_hub`. The async client factory is a method that returns a `httpx2.AsyncClient` object. This can be useful if you are running your scripts in a specific environment requiring custom configuration (e.g. custom proxy or certifications). Use [`get_async_session`] to get a correctly configured `httpx2.AsyncClient`. > [!WARNING] > Contrary to the `httpx2.Client` that is shared between all calls made by `huggingface_hub`, the `httpx2.AsyncClient` is not shared. > It is recommended to use an async context manager to ensure the client is properly closed when the context is exited. Nr)rs r2set_async_client_factoryrs $8 r1ct%t5t tadddtStS#1swYtSxYw)a Get a `httpx2.Client` object, using the transport factory from the user. This client is shared between all calls made by `huggingface_hub`. Therefore you should not close it manually. Use [`set_client_factory`] to customize the `httpx2.Client`. N)rrrr0r1r2 get_sessionrs@  :%!7!9 : > : s 2ActS)a Return a `httpx2.AsyncClient` object, using the transport factory from the user. Use [`set_async_client_factory`] to customize the `httpx2.AsyncClient`. > [!WARNING] > Contrary to the `httpx2.Client` that is shared between all calls made by `huggingface_hub`, the `httpx2.AsyncClient` is not shared. > It is recommended to use an async context manager to ensure the client is properly closed when the context is exited. rr0r1r2get_async_sessionrs  ( ))r1ct}da| |jyy#t$r"}tj d|Yd}~yd}~wwxYw)z Close the global `httpx2.Client` used by `huggingface_hub`. If a Client is closed, it will be recreated on the next call to [`get_session`]. Can be useful if e.g. an SSL certificate has been updated. NzError closing client: )rclose Exceptionrwarning)clientes r2rrsTFN 9 LLN 9 NN3A37 8 8 9s A AA register_at_fork)after_in_child._DEFAULT_RETRY_ON_EXCEPTIONS)iiiii_DEFAULT_RETRY_ON_STATUS_CODES) max_retriesbase_wait_time max_wait_timeretry_on_exceptionsretry_on_status_codesstreamrrrrrrrc +Kt|tr|f}ttrfd|} dd} d|vr6t|dtjt fr|dj } dz dt} | |dj| dtjdtffd } |r6| jdd|5} | | s|  dddy dddn"| jdd|} | | s| y.t%dz}tjd |d ddn!| }tjd|dddt'j(|t+|| dz} #1swYxYw#|$rS}tjd |d d t|tj r t#kDr|Yd}~d}~wwxYww)zfInternal implementation of HTTP backoff logic shared between `http_backoff` and `http_stream_backoff`.rNdatarrr4cL|jvrytjd|jddkDr t|y|jdk(r3t |j x}|j dk(r |jyt|j x}|y)zNHandle response and return True if should retry, False if should return/yield.Fz HTTP Error z thrown while requesting  rrT) rrrhf_raise_for_statusrEr3r%r&rJ) rratelimit_info retry_afterrrnb_triesratelimit_resetrrUs r2 _should_retryz)_http_backoff_base.._should_retrys''/DD X-A-A,BB[\b[ccdehdijkk)'1!((C/+B8CSCS+TTa&00A5&4&E&EO&88H8H%IIkV&1Or1rrU'z' thrown while requesting rzRate limited. Waiting zs before retry [Retry rZz].z Retrying in z s [Retry rr0) isinstancetyper/ioIOBasertellrseekrResponseboolrrxrr ConnectErrorrfloattimesleepmin)rrUrrrrrrrt sleep_timeio_obj_initial_posrrrerr actual_sleeprrs``` ` @@r2_http_backoff_basers4%t,24'-!6 8HJ"&O  Jvf~ <7PQ#F^002 A 4 "-v##$67  D  6"V]]D&cDVD(2&2 *6>>KSKFK$X."N  & 1A5L NN3L>AWX`Waabcnbooqr s%L NN\,y !K=XZ[ \ <  Q7 M R#  NNQse#=fXQseL M#v223+% &  sWA;G3AFF  F(G3**FA8G3 FFG0A G+&G3+G00G3)rrrrrc <ttd|||||||dd|S)ae Wrapper around httpx2 to retry calls on an endpoint, with exponential backoff. Endpoint call is retried on exceptions (ex: connection timeout, proxy error,...) and/or on specific status codes (ex: service unavailable). If the call failed more than `max_retries`, the exception is thrown or `raise_for_status` is called on the response object. Re-implement mechanisms from the `backoff` library to avoid adding an external dependencies to `hugging_face_hub`. See https://github.com/litl/backoff. Args: method (`Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"]`): HTTP method to perform. url (`str`): The URL of the resource to fetch. max_retries (`int`, *optional*, defaults to `5`): Maximum number of retries, defaults to 5. Set to `0` to disable retries. base_wait_time (`float`, *optional*, defaults to `1`): Duration (in seconds) to wait before retrying the first time. Wait time between retries then grows exponentially, capped by `max_wait_time`. max_wait_time (`float`, *optional*, defaults to `8`): Maximum duration (in seconds) to wait before retrying. retry_on_exceptions (`type[Exception]` or `tuple[type[Exception]]`, *optional*): Define which exceptions must be caught to retry the request. Can be a single type or a tuple of types. By default, retry on `httpx2.TimeoutException`, `httpx2.NetworkError` and `httpx2.RemoteProtocolError`. retry_on_status_codes (`int` or `tuple[int]`, *optional*, defaults to `(429, 500, 502, 503, 504)`): Define on which status codes the request must be retried. By default, retries on rate limit (429) and server errors (5xx). **kwargs (`dict`, *optional*): kwargs to pass to `httpx2.request`. Example: ``` >>> from huggingface_hub.utils import http_backoff # Same usage as "httpx2.request". >>> response = http_backoff("GET", "https://www.google.com") >>> response.raise_for_status() # If you expect a Gateway Timeout from time to time >>> http_backoff("PUT", upload_url, data=data, retry_on_status_codes=504) >>> response.raise_for_status() ``` > [!WARNING] > When using `requests` it is possible to stream data by passing an iterator to the > `data` argument. On http backoff this is a problem as the iterator is not reset > after a failed call. This issue is mitigated for file objects or any IO streams > by saving the initial position of the cursor (with `data.tell()`) and resetting the > cursor between each call (with `data.seek()`). For arbitrary iterators, http backoff > will fail. If this is a hard constraint for you, please let us know by opening an > issue on [Github](https://github.com/huggingface/huggingface_hub). FrrUrrrrrrr0)nextrrrUrrrrrrts r2 http_backoffr<sAB  #)' 3"7    r1c +HKtd|||||||dd|Ed{y7w)a Wrapper around httpx2 to retry calls on an endpoint, with exponential backoff. Endpoint call is retried on exceptions (ex: connection timeout, proxy error,...) and/or on specific status codes (ex: service unavailable). If the call failed more than `max_retries`, the exception is thrown or `raise_for_status` is called on the response object. Re-implement mechanisms from the `backoff` library to avoid adding an external dependencies to `hugging_face_hub`. See https://github.com/litl/backoff. Args: method (`Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"]`): HTTP method to perform. url (`str`): The URL of the resource to fetch. max_retries (`int`, *optional*, defaults to `5`): Maximum number of retries, defaults to 5. Set to `0` to disable retries. base_wait_time (`float`, *optional*, defaults to `1`): Duration (in seconds) to wait before retrying the first time. Wait time between retries then grows exponentially, capped by `max_wait_time`. max_wait_time (`float`, *optional*, defaults to `8`): Maximum duration (in seconds) to wait before retrying. retry_on_exceptions (`type[Exception]` or `tuple[type[Exception]]`, *optional*): Define which exceptions must be caught to retry the request. Can be a single type or a tuple of types. By default, retry on `httpx2.TimeoutException`, `httpx2.NetworkError` and `httpx2.RemoteProtocolError`. retry_on_status_codes (`int` or `tuple[int]`, *optional*, defaults to `(429, 500, 502, 503, 504)`): Define on which status codes the request must be retried. By default, retries on rate limit (429) and server errors (5xx). **kwargs (`dict`, *optional*): kwargs to pass to `httpx2.request`. Example: ``` >>> from huggingface_hub.utils import http_stream_backoff # Same usage as "httpx2.stream". >>> with http_stream_backoff("GET", "https://www.google.com") as response: ... for chunk in response.iter_bytes(): ... print(chunk) # If you expect a Gateway Timeout from time to time >>> with http_stream_backoff("PUT", upload_url, data=data, retry_on_status_codes=504) as response: ... response.raise_for_status() ``` > [!WARNING] > When using `httpx2` it is possible to stream data by passing an iterator to the > `data` argument. On http backoff this is a problem as the iterator is not reset > after a failed call. This issue is mitigated for file objects or any IO streams > by saving the initial position of the cursor (with `data.tell()`) and resetting the > cursor between each call (with `data.seek()`). For arbitrary iterators, http backoff > will fail. If this is a hard constraint for you, please let us know by opening an > issue on [Github](https://github.com/huggingface/huggingface_hub). TrNr0)rrs r2http_stream_backoffrsBF"  %#/3     s " ")retry_on_errorsrc 0|rinddd}ttD]\}td||d|ddi|}t||js|cSt ||j d}t||s|cS|}^tjdtd|d ) aPerform an HTTP request with backoff, following redirects that stay on the Hub. Used to fetch HEAD /resolve on repo or bucket files. Redirects to the same host or another Hub host are followed. Redirects to any other host (CDN, storage bucket) are not: the file metadata is on the redirect response itself and the auth header must not leave the Hub. A backoff mechanism retries the HTTP call on errors (429, 5xx, timeout, network errors). Args: method (`str`): HTTP method, such as 'GET' or 'HEAD'. url (`str`): The URL of the resource to fetch. retry_on_errors (`bool`, *optional*, defaults to `False`): Whether to retry on errors. If False, no retry is performed (fast fallback to local cache). If True, uses default retry behavior (429, 5xx, timeout, network errors). **httpx2_kwargs (`dict`, *optional*): Params to pass to `httpx2.request`. r0)rrrrFLocationz Exceeded z redirects while resolving 'z'.) range_MAX_REDIRECTSrrhas_redirect_locationrr3_is_same_or_hub_hostrTooManyRedirects)rrUr httpx2_kwargsno_retry_kwargs_rtargets r2)_httpx2_follow_hub_redirects_with_backoffrs22XZ#[> "   #     H%--Oh..z:;#C0O'*  ! !In-==YZ]Y^^`"a bbr1Pi)httphttpsct|}|j|jxsdj|jxs t j |jdfS)zZOrigin of a url: (scheme, hostname, port), with the scheme's default port if not explicit.r)rschemehostnamer;port_DEFAULT_PORTSr^)rUparseds r2 _url_originrsL c]F MMFOO1r88:FKKK]K]^d^k^kmnKo ppr1c#2K|]}t|ywN)r).0endpoints r2 rssz https://hf.corc<t|t|htvS)zQWhether `target` is served by the same origin as `url`, or by a known Hub origin.)r _HUB_ORIGINS)rUrs r2rr(s v ;s#3"Cl"C CCr1rc|r|jdntj}|tjtjfvr@|j tj|}|j tj|}|S)zReplace the default endpoint in a URL by a custom one. This is useful when using a proxy and the Hugging Face Hub returns a URL with the default endpoint. rZ)rstriprENDPOINT_HF_DEFAULT_ENDPOINT_HF_DEFAULT_STAGING_ENDPOINTreplace)rUrs r2fix_hf_endpoint_in_urlr -sf (0xs#Y5G5GH 66 8^8^__kk)88(Ckk)@@(K Jr1 endpoint_namec  t| |j y#t$rtjddY4wxYw#t j $r}|jdzdk(rYd}~y|jjd}|jjd}|j5|jjt|jjnd}|r t|nd \}}|d k(r8|jd d zd |jdz}tt||||||dk(r8|jd d zd|jdz}tt ||||||dk(r8|jd d zd|jdz}tt"||||||dk(r;|jd d zd|jdzdzdz}tt$||||dk(r]|[t&j)|F|jd d zd|jdzdzdz}tt*||t-|||jdk(rI|Gt/|x} :|jd d zd|jdzdz}tt0||| ||dk(s+|jd k(rZ|d!k7rU|St2j)|>|jd d zd"|jdzd#zd$z}tt4||||||jd%k(r|d&|d'nd(}tt6||||jd)k(r9d |jd*|dd+|jdzd,z}tt8||||jd-k(rt;|j} | | j<d.k(rd/| j>d0}|d1| j@d2z }| jB:| jD.|d3| j<d4| jBd5| jDd6z }n|dz }|d7|jdz }nd8|jd}tt8||||jd9k(r[|jjjd:} |d;| d<|jjd=d}tt8|||tt8t|||d}~wwxYw)>a Internal version of `response.raise_for_status()` that will refine a potential HTTPError. Raised exception will be an instance of [`~errors.HfHubHTTPError`]. This helper is meant to be the unique method to raise_for_status when making a call to the Hugging Face Hub. Args: response (`Response`): Response from the server. endpoint_name (`str`, *optional*): Name of the endpoint that has been called. If provided, the error message will be more complete. > [!WARNING] > Raises when the request has failed: > > - [`~utils.RepositoryNotFoundError`] > If the repository to download from cannot be found. This may be because it > doesn't exist, because `repo_type` is not set correctly, or because the repo > is `private` and you do not have access. > - [`~utils.GatedRepoError`] > If the repository exists but is gated and the user is not on the authorized > list. > - [`~utils.RevisionNotFoundError`] > If the repository exists but the revision couldn't be found. > - [`~utils.EntryNotFoundError`] > If the repository exists but the entry (e.g. the requested file) couldn't be > find. > - [`~utils.BadRequestError`] > If request failed with a HTTP 400 BadRequest error. > - [`~utils.HfHubHTTPError`] > If request failed for a reason not listed above. zFailed to parse warning headersT)exc_infodrYNz X-Error-CodeX-Error-MessagerXRevisionNotFoundz Client Error. zRevision Not Found for url: .)r`rc EntryNotFoundzEntry Not Found for url: GatedRepoz!Cannot access gated repo for url z$Access to this resource is disabled.z!Cannot access repository for url  RepoNotFoundzBucket Not Found for url: zG Please make sure you specified the correct bucket id (namespace/name).zg If the bucket is private, make sure you are authenticated and your token has the required permissions.) bucket_idizJob Not Found for url: zA Please make sure you specified the correct job ID and namespace.)job_idiz+Invalid credentials in Authorization headerzRepository Not Found for url: z Please make sure you specified the correct `repo_id` and `repo_type`. If you are trying to access a private or gated repo, make sure you are authenticated and your token has the required permissions.zQ For more details, see https://huggingface.co/docs/huggingface_hub/authenticationrz Bad request for z endpoint:z Bad request:iz Forbidden: z Cannot access content at: z2 Make sure your token has the correct permissions.rrz0 429 Too Many Requests: you have reached your 'z ' rate limit.z Retry after z seconds (rZz requests remaining in current z s window).z Url: z! 429 Too Many Requests for url: iRangez. Requested range: z. Content-Range: z Content-Range)#_warn_on_warning_headersrrrraise_for_statusrHTTPStatusErrorrr3r^rxrUr-rd_formatrrrrBUCKET_API_REGEXr=rrhrkrREPO_API_REGEXrrrrEr%r$r&r'r() rr r error_code error_message request_urlr`rcmessagerr range_headers r2rr:sBG * C?!!# G 6 FG  ! !A?   3 &! + %%)).9  ((,,->? *2)9)9)E(JZJZJ^J^JjC  $$ %pt HS6{CXd 7 + +!--.n=FKghphthtguuvIwwG/(iahiop p ? *!--.n=FKdemeqeqdrrsIttG2GXQZdklrs s ; &''(7&@EfgogsgsfttuCvv .'8yZabhi i D D''(75hll^1EF9 9 +Wh?Q F . (' '' 4@''(7.x||nA>?]]} } #WhB[\gBh   C ''1+>>K''(7+HLL>;<WW  *GXfMST T > )  C '!NN'%%k2>''(728<<.BC`` g g 17HPYcjkqr r  ! !S (DQD]&}oZ@cu /7H=1 D  ! !S (x++,LqI0a@AGH  .'8CA?s- A AAS0S+0Q;S++S0c.|jjd}|D]u}d|vr|jddnd|f\}}|j}|tvs9|j}|sLtj |t j|wy)a Emit warnings if warning headers are present in the HTTP response. Expected header format: 'X-HF-Warning: topic; message' Only the first warning for each topic will be shown. Topic is optional and can be empty. Note that several warning headers can be present in a single response. Args: response (`httpx2.Response`): The HTTP response to check for warning headers. z X-HF-Warning;rrN)r3get_listsplitrG_WARNED_TOPICSaddrr)rserver_warningsserver_warningtopicr&s r2rrs&&//?O)(9<9N--c15UWYgThw   &mmoG""5)w'(r1_HfHubHTTPErrorT)bound error_typecustom_messageattrsc g}|jjd}||j| |j}|jd}|jd}|Mt|tr|j|n>||j|d|n%|j|n||j||jd} | | D]}d|vs|j|d|D cgc]5} t| jst| j7}} tt j#|}d j%|} |} | r5| j|jvrd |vr | d | zz } n| d | zz } d}d}t&d ft(d ft*dffD]8\}}|jj|}|s$t|}d|d|d}n|rI|j| jvr)d | vr | j-d }| d||z| |dz} n| |z } || j|| xsd}|j/D]\}}t1||||S#tj $r7 |j |j}n#t$ri}YnwxYwYwxYw#tj$rY|jjdd} |jr-d | jvr|j|jYEwxYwcc} w)Nrerrorerror_description: errorsr&z Content-Typerhtmlrrz Request IDz Amzn Trace IDz Amz CF IDr))rserver_message)r3r^appendjsonrResponseNotReadread RuntimeErrorrlistextendJSONDecodeErrortextr;r-rGdictfromkeysjoinrr~ X_AMZ_CF_IDindexitemssetattr)r3r4rr5 server_errors from_headersrr7r8r: content_typeliner=final_error_messagerrequest_id_messageheaderlabelrI newline_indexrkvs r2r r s|M##''(9:L\*+0 ==?D! HH%89  %&$$U+".$$wb1B0C%DE$$U+  *  !2 3(#   ;%!((y)9: ;4AV4CIOODUSY__&VMV}56MYY}-N)...08L8L8NN ^ # 4.#8 8  6N#: : J |$ /* k"     $$V, UJ#%eWBugQ!7   j&&(0C0I0I0KK & &/55d;M#N]36HHK^_l_mKnn  #5 5  (..08TbTjfj kC 1Q Jo%%   }}     F   0''++NB? ==V<+=+=+??   / 0WsgJB K$K>MMK J<;K< K K K  K KKKA(M?M) subject_token access_token refresh_token client_secret device_codez("z"\s*:\s*")[^"]*(")z\1\2z(^|&)(z=)[^&]*z\1\2bodycFtD]\}}|j||}|S)zRRedact OAuth credential values from a JSON or form-urlencoded request body string.)_SENSITIVE_BODY_PATTERNSsub)r^pattern replacements r2_redact_sensitive_bodyrdzs+ 8.{{;-. Kr1cdd|jfg}t|jjD]'\}}|j dk(rd}|d|d|fgz })d} |j >|j j dd }t|d kDr|dd d }t|}||d|jddfgz }|d|jfgz }g}|D]P\}}|r#|jtt||s.|jtt|Rdj!|S#tj$rd }YwxYw)zConvert a `httpx2.Request` into a curl command (str). Used for debug purposes only. Implementation vendored from https://github.com/ofw/curlify/blob/master/curlify.py. MIT License Copyright (c) 2016 Egor. )curlNz-Xr{zz-Hr9Nzutf-8ignore)r:iz ... [truncated]zz-drrr)rsortedr3rLr;contentdecodelenrdrRequestNotReadr rUr>r r-rI)rxpartsrWrXr^ flat_partss r2rrsz  w~~$E w,,./'1 779 'A 4A3b%&&' D" ?? &??))'()CD4y4u+&67)$/D  4dB/011 tW[[! ""EJ-1   eCFm ,   eCFm , - 88J   "!"s!A D??EEz#\s*bytes\s*=\s*(\d*)\s*-\s*(\d*)\s*original_range resume_sizec|sd|dSd|vrtd|dtj|}|std|d|j \}}|s:|std|dt ||z }d|}|d krtd |d|St |}||z}|r)t |}d|d|}||kDrtd |d|Sd|dS) zB Adjust HTTP Range header to account for resume position. zbytes=-,zMultiple ranges detected - z, not supported yet.zInvalid range format - rzbytes=-rzEmpty new range - )r RANGE_REGEX fullmatchrBgroupsr/)rorprCstartend new_suffix new_range new_starts r2_adjust_range_headerr|s'  }A&& n6~6HH\]^^  ! !. 1E 4^4FaHIIJE3 !88J!LM MX + j\* ?!3I=BC C JE #I #hYKq. s?!3I=BC C I;a  r1)r4Nr)r,atexitrr?osre threadingrrcollections.abcrrr contextlibr contextvarsr dataclassesr functoolsr shlexr typingr r urllib.parserrrhuggingface_hub.errorsrrrr:rrrrrrrrrr_lfsr_typingrr get_loggerr)rr#compiler<r?r-rEr/rJrr~rJVERBOSEr"r!rjr]r[rfr_tuplerdrhrkrlrr.rwRequestrrrrrrrrCLIENT_FACTORY_TASYNC_CLIENT_FACTORY_TLockrrrrrrrrrregisterhasattrrTimeoutException NetworkErrorRemoteProtocolErrorrrrrrrrrrrrr frozensetr r rrrr rrqr,rr1r _SENSITIVE_BODY_KEYSr`rdr IGNORECASErtr|)rArbs00r2rsE  88%"!* 7   -   H % $&&&,2::mn$"**%OP8WS#X%68=4;O8vS 1cDj6 #   ** 2:: **$$ab%"**%kl#-"**S# 'BJJ'UVq35tS4Z1G+H:-3-3:- --d - '11De&T:d#TiI$"6>>"cDj"J*v~~*#** ' 'T ' f&8&8B -.!"f&8&8"89y~~ +A(A7S4S'+ $+0'70D0" 83I 8d 8 V]]  *6-- *9,  2!"B}5   =eDOS$89 3Qc3hPIe3Qd8 d8 d8 d8  d8  d8i5i#1E+FFd8sCx0d8 d8vd*+d8VIe3QM M M M  M  Mi5i#1E+FFMsCx0M __M` Ie3QL L L L  L  Li5i#1E+FFLsCx0Lvd*+LL^AF1c 1c #1c9=1c __1chs+qSqU3S=1q &&..  DcD3D4D  sTz c j?&//j?#*j?X\j?Z(v(4(0-^Df%&f8;fGMfadffTj$ r#01 24EF vcU'* +->?   ' fnn' ' Vbjj?O "!t"!#"!#PT*"!s:>U