gj^UdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z ddl mZddlmZddlmZddlmZmZddlmZddlZdd lmZd d lmZd d lmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&d dlm'Z'd dl(m)Z)d dl*m+Z+e'j,e-Z.edGddZ/ej0dZ1ej0dZ2de e3e3fde/dzfdZ4dZ5dZ6dZ7ej0dej8Z9ej0dej8Z:ej0d Z;ej0d!Z<ej0d"Z=hd#Z>d$e3de?e3dze3dzffd%Z@d$e3de3dzfd&ZAd$e3de3dzfd'ZBd(ejCddfd)ZDd(ejCddfd*ZEd+ejFddfd,ZGdejHfd-ZIdejJfd.ZKe gejHfZLe gejJfZMejNZOeIaPeLeQd/<eKaReMeQd0<daSejHdzeQd1<d2eLddfd3ZTd4eMddfd5ZUdejHfd6ZVdejJfd7ZWded8ZXejYeXeZed9rej[eX:ej\ej]ej^fZ_e?e`ead;feQd<<d=Zbe?ecd;feQd><d?d d@e_ebdAdBdCe+d$e3dDecdEeddFeddGe`eae?e`ead;fzdHece?ecd;fzdIeede ejFddffdJZfd?d d@e_ebdKdCe+d$e3dDecdEeddFeddGe`eae?e`ead;fzdHece?ecd;fzdejFfdLZged?d d@e_ebdKdCe+d$e3dDecdEeddFeddGe`eae?e`ead;fzdHece?ecd;fzde ejFddffdMZhdAdNdCe+d$e3dOeedejFfdPZid$e3dQe3dzde3fdRZjdfd+ejFdSe3dzddfdTZkelZmd+ejFddfdUZnedVe"WZodXe`eodYe3d+ejFdZedeof d[Zpd\Zqd]eqDZrd^e3de3fd_Zsd(ejCde3fd`Ztej0daejuZvdbe3dzdcecde3dzfddZwdS)gz>Contains utilities to handle HTTP requests in huggingface_hub.N)Callable GeneratorMapping)contextmanager) dataclass)quote)AnyTypeVar)urlparse)OfflineModeIsEnabled) constants) BadRequestErrorBucketNotFoundErrorDisabledRepoErrorGatedRepoErrorHfHubHTTPErrorJobNotFoundErrorRemoteEntryNotFoundErrorRepositoryNotFoundErrorRevisionNotFoundError)logging) SliceFileObj) HTTP_METHOD_TT)frozencZeZdZUdZeed<eed<eed<dZedzed<dZedzed<dS) 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#_/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/huggingface_hub/utils/_http.pyrr7sg  NNNE3:!%NC$J%%%%%r,rzL\"(?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+)headersreturnc`d}d}|D]3}|}|dkr ||}%|dkr||}4|sdSt|}|sdS|d}t |d}t |d}d} d} |r`t |} | rDt | d} t | d} 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-policyrrtqw)rr r!r"r#)lower_RATELIMIT_REGEXsearchgroupr*_RATELIMIT_POLICY_REGEXr) r.r1policykey lower_keymatchrr r!r"r# policy_matchs r-parse_ratelimit_headersr@SsP*!IF""IIKK  # # II , , ,S\F t  # #I . .E tKK00MEKK$$%%I5;;s++,,E!%N :.55f==  : **3//00E !3!3C!8!899N #)%    r,z 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)/[^/]+/([^/?]+)zA^https?://[^/]+/api/(models|datasets|spaces)/([^/]+)(?:/([^/]+))?z)^https?://[^/]+/api/buckets/([^/]+/[^/]+)> rawblobrefstreecommitresolverevisionsettings discussionsurlc(t|}|sdStj|d}|d|d}}|r|t vr|d|}n|}||fS)a,Extract (repo_type, repo_id) from an API 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") NNrr /)_REPO_ID_FROM_URL_REGEXr8rREPO_TYPES_MAPPINGgetr9_REPO_URL_SUBPATHS)rKr> repo_typefirstsecondrepo_ids r-_parse_repo_info_from_urlrXs $ * *3 / /E z,00Q@@IKKNNEKKNN6E & 222%%V%% g r,cht|}|r|dndS)z9Extract bucket_id (namespace/name) from a bucket API URL.rN)_BUCKET_ID_FROM_URL_REGEXr8r9rKr>s r-_parse_bucket_id_from_urlr\s. % , ,S 1 1E" ,5;;q>>>,r,cht|}|r|dndS)z>Extract the job_id from a (scheduled) job API URL, if present.rN)_JOB_ID_FROM_URL_REGEXr8r9r[s r-_parse_job_id_from_urlr_s. " ) )# . .E" ,5;;q>>>,r,requestc :tjrtd|jdt|jvrL|jtpttj |jt<|jt}t d||j |j|jddutjr(t dt||S)z 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 - 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.z%Request %s: %s %s (authenticated: %s) authorizationNzSend: %s)ris_offline_moder rKX_AMZN_TRACE_IDr.rR X_REQUEST_IDr(uuiduuid4loggerdebugmethodHF_DEBUG_curlify)r` request_ids r-hf_request_event_hookrns  "" " KGK K K K   go--+2?+>+>|+L+L+aPSTXT^T`T`PaPa($$_55J LL/ O,,D8 4 Z'!2!2333 r,c$Kt|S)z3 Async version of `hf_request_event_hook`. )rn)r`s r-async_hf_request_event_hookrps ! ) ))r,responsecK|jdkrXd|jvrQ t|jd}n#t$rYdSwxYw|dkr |d{VdSdSdSdS)NzContent-lengthi@B) status_coder.r* ValueErroraread)rqlengths r-async_hf_response_event_hookrx ss"" x/ / / X-.>?@@     !!nn&&&&&&&&&&&#" 0 / "!s3 AAc@tjdtgiddS)zQ Factory function to create a `httpx.Client` with the default transport. r`TN event_hooksfollow_redirectstimeout)httpxClientrnr+r,r-default_client_factoryrs/ <!6 78   r,cNtjtgtgdddS)zV Factory function to create a `httpx.AsyncClient` with the default transport. )r`rqTNrz)r~ AsyncClientrprxr+r,r-default_async_client_factoryr"s6  !< =LhKijj   r,_GLOBAL_CLIENT_FACTORY_GLOBAL_ASYNC_CLIENT_FACTORY_GLOBAL_CLIENTclient_factorycft5t|addddS#1swxYwYdS)a Set the HTTP client factory to be used by `huggingface_hub`. The client factory is a method that returns a `httpx.Client` object. On the first call to [`get_session`] the client factory will be used to create a new `httpx.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 `httpx.Client`. N) _CLIENT_LOCK close_sessionr)rs r-set_client_factoryr6s} 00!/000000000000000000s &**async_client_factoryc |adS)a Set the HTTP async client factory to be used by `huggingface_hub`. The async client factory is a method that returns a `httpx.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_client`] to get a correctly configured `httpx.AsyncClient`. Contrary to the `httpx.Client` that is shared between all calls made by `huggingface_hub`, the `httpx.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 r-set_async_client_factoryrGs $8   r,cxt-t5tadddn #1swxYwYtS)a Get a `httpx.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 `httpx.Client`. N)rrrr+r,r- get_sessionrZsv  6 6355N 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 s *..ctS)a Return a `httpx.AsyncClient` object, using the transport factory from the user. Use [`set_async_client_factory`] to customize the `httpx.AsyncClient`. Contrary to the `httpx.Client` that is shared between all calls made by `huggingface_hub`, the `httpx.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. rr+r,r-get_async_sessionris ( ) ))r,ct}da|L |dS#t$r(}td|Yd}~dSd}~wwxYwdS)z Close the global `httpx.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 Exceptionrhwarning)clientes r-rrysFN 9 LLNNNNN 9 9 9 NN7A77 8 8 8 8 8 8 8 8 8 9s# AAAregister_at_fork)after_in_child._DEFAULT_RETRY_ON_EXCEPTIONS)iiiii_DEFAULT_RETRY_ON_STATUS_CODESF) max_retriesbase_wait_time max_wait_timeretry_on_exceptionsretry_on_status_codesstreamrjrrrrrrc +`Kt|tr|f}ttrfd|} dd} d|vrAt|dtjt fr|d} t} dz d | |d| dtj dtffd } |rG| j dd |5} | | s| V ddddS dddn #1swxYwYn!| j dd |} | | s| VdSne#|$r]}td |d d t|tjrt#kr|Yd}~nd}~wwxYw7t%dz}td |dddn&| }td|dddt'j|t+|| dz} )zfInternal implementation of HTTP backoff logic shared between `http_backoff` and `http_stream_backoff`.rNdataTrrqr/c|jvrdStd|jddkrt|dS|jdkrt |j}||jdS)zNHandle response and return True if should retry, False if should return/yield.Fz HTTP Error z thrown while requesting  rNT)rtrhrhf_raise_for_statusr@r.r!)rqratelimit_inforrjnb_triesratelimit_resetrrKs r- _should_retryz)_http_backoff_base.._should_retrys'/DDD 5jX-Ajj\bjjehjjkkkk))'111!5'3..%KSKKFKK$}X.."NNNF"    NNLsLLfLLsLL M M M#u122 +%% &%%%%    & 11A5L NNrLrrX`rrcnrrr s s s s%L NN[,[[[[[[ \ \ \ <    Q77 ?8sDA E*D; E EDED#EF%AF  F%)rrrrrc Fttd|||||||dd|S)aM Wrapper around httpx 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 (no 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 `httpx.TimeoutException`, `httpx.NetworkError` and `httpx.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 `httpx.request`. Example: ``` >>> from huggingface_hub.utils import http_backoff # Same usage as "httpx.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). FrjrKrrrrrrr+)nextrrjrKrrrrrrs r- http_backoffrsPB  #)' 3"7     r,c +@Ktd|||||||dd|Ed{VdS)a Wrapper around httpx 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 (no 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 `httpx.TimeoutException`, `httpx.NetworkError` and `httpx.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 `httpx.request`. Example: ``` >>> from huggingface_hub.utils import http_stream_backoff # Same usage as "httpx.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() ``` When using `httpx` 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). TrNr+)rrs r-http_stream_backoffrMsoL"  %#/3              r,)retry_on_errorsrc N|rinddd} td||d|ddi|}t|d|jcxkrdkrcnn`t|jd }|jd kr;t||j } |S) aFPerform an HTTP request with backoff and follow relative redirects only. Used to fetch HEAD /resolve on repo or bucket files. This is useful to follow a redirection to a renamed repository without following redirection to a CDN. 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). **httpx_kwargs (`dict`, *optional*): Params to pass to `httpx.request`. r+)rrTrr|Fi,iLocation)path) rrrtr r.netloc_replacergeturl)rjrKr httpx_kwargsno_retry_kwargsrq parsed_targets r--_httpx_follow_relative_redirects_with_backoffrs0[2XZ#[#[     #       H%%% (& - - - -# - - - - -$X%5j%ABBM#r))smm,,-2D,EELLNN  Or,endpointc|r|dn tj}|tjtjfvr@|tj|}|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. rO)rstriprENDPOINT_HF_DEFAULT_ENDPOINT_HF_DEFAULT_STAGING_ENDPOINTreplace)rKrs r-fix_hf_endpoint_in_urlrsi (0Gxs###Y5GH 6 8^___kk)8(CCkk)@(KK Jr, endpoint_namec , t|n,#t$rtddYnwxYw |dS#t j$r.}|jdzdkrYd}~dS|j d}|j d}|j %|j j t|j j nd}|rt|nd \}}|d kr3|jd d zd |j dz}tt||||||dkr3|jd d zd|j dz}tt ||||||dkr3|jd d zd|j dz}tt"||||||dkr6|jd d zd|j dzdzdz}tt$||||dkra|_t&|E|jd d zd|j dzdzdz}tt*||t-|||jdkrH|Ft/|x} 5|jd d zd|j dzdz}tt0||| ||dks-|jd kr[|d!krU|St2|9|jd d zd"|j dzd#zd$z}tt4||||||jd%kr!|d&|d'nd(}tt6||||jd)kr4d |jd*|dd+|j dzd,z}tt8||||jd-krt;|j} | Zd.| jd/}|d0| jd1z }| j &| j!|d2| j"d3| j d4| j!d5z }n|dz }|d6|j dz }n d7|j d}tt8||||jd8krY|j j d9} |d:| d;|j d<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_infodrNNz X-Error-CodeX-Error-MessagerMRevisionNotFoundz Client Error. zRevision Not Found for url: .)rTrW 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/authenticationrsz Bad request for z endpoint:z Bad request:iz Forbidden: z Cannot access content at: z2 Make sure your token has the correct permissions.rz0 429 Too Many Requests: you have reached your 'z ' rate limit.z Retry after z seconds (rOz 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_headersrrhriraise_for_statusr~HTTPStatusErrorrtr.rRr`rKr(rX_formatrrrrBUCKET_API_REGEXr8rr\r_rREPO_API_REGEXrrrr@rr!r"r#r ) rqrr error_code error_message request_urlrTrWmessagerr range_headers r-rrsBG **** GGG 6 FFFFFGB?!!#####  @?@?@?  3 &! + + FFFFF%)).99  (,,->?? *2)9)E(JZJ^JjC $ % % %pt HSd6{CCCXd 7 + + +!-===FIwhphtIwIwIwwG/(iahiiiop p ? * *!-===FItemeqItItIttG2GXQZdklllrs s ; & &'777&@CvgogsCvCvCvv .'8yZabbbhi i D D D'777EhlEEEF9 9 +Wh??Q F . ( (' '' 44@'777>x|>>>?]]} } #WhB[\gBhBh   C ' ''1+>>>K'777;HL;;;<WW  *GXfMMMST T > ) )  C ' '!NNN'%%k22>'777B8<BBBC`` g g 17HPYcjkkkqr r  !S ( (DQD]@}@@@@cu /7H==1 D  !S ( (Ix+IIIII@@@@AGH  .'8<A@?s*&;;AR%R9PRRcT|jd}|D]}d|vr|ddnd|f\}}|}|tvrJ|}|r4t|t |dS)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 (`httpx.Response`): The HTTP response to check for warning headers. z X-HF-Warning;rrN)r.get_listsplitstrip_WARNED_TOPICSaddrhr)rqserver_warningsserver_warningtopicrs r-rrs&//??O)((9<9N9N--c1555UWYgThw   & &mmooG (""5)))w'''((r,_HfHubHTTPErrorT)bound error_typecustom_messageattrsc g}|jd}||| |}nQ#tj$r? ||}n#t$ri}YnwxYwYnwxYw|d}|d}|^t|tr| |nJ|||d|n-||n||||d} | $| D]!}d|vr||d"ng#tj $rU|jdd} |j r0d | vr||j YnwxYwd |D}tt|}d |} |} | r=| | vrd |vr | d | zz } n| d | zz } d} d}t"d ft$dft&dffD];\}}|j|}|rt)|} d|d|d}n<| r_| | vr7d | vr.| d }| d||z| |dz} n| |z } || || pd}|D]\}}t1||||S)Nrerrorerror_description: errorsrz Content-Typerhtmlcg|]D}t|#t|ESr+)r(r).0lines r- z_format..s=VVV4CIIOODUDUVSYY__&&VVVr,rrz Request IDz Amzn Trace IDz Amz CF IDr))rqserver_message)r.rRappendjsonr~ResponseNotReadread RuntimeErrorrlistextendJSONDecodeErrortextr6dictfromkeysjoinrerd X_AMZ_CF_IDr(indexritemssetattr)rrrqr  server_errors from_headersrr r r content_typerfinal_error_messagermrequest_id_messageheaderlabelvalue newline_indexrkvs r-rrs>M#''(9::L\***+0 ==??DD$     }}       !! HH%899  %&& ,$$U++++".$$%D%D1B%D%DEEEE$$U++++  *  !2 3 3 3(##   ; ;%%!((y)9:::  000'++NB?? = 0V<+=+=+?+???   / / / 0WV=VVVM}5566MYY}--N);...008L8L8N8NNN ^ # # 4.#8 8   6N#: : J |$ /* k"     $$V,,  UJ!7e!7!7u!7!7!7  E  6j&&((0C0I0I0K0KKK & & &/55d;;M#N]N36HHK^_l_m_mKnn  #5 5  *(..008TbTjfj k k kC 1Q JsUA E9 B(BB BBBBE9BCE99A!GG) subject_token access_token refresh_token client_secret device_codecg|];}tjd|ddftjd|ddffD]}|\2z(^|&)(z=)[^&]*z\1\2)recompile)rr<patterns r-rrs 1#111 2 24EF *c*** + +->?  r,bodycLtD]\}}|||}|S)zRRedact OAuth credential values from a JSON or form-urlencoded request body string.)_SENSITIVE_BODY_PATTERNSsub)r:r9 replacements r-_redact_sensitive_bodyr?s0 8..{{;-- Kr,cdd|jfg}t|jD],\}}|dkrd}|d|d|fgz }-d} |jK|jdd }t|d kr |dd d }t|}n#tj $rd }YnwxYw||d| ddfgz }|d|j fgz }g}|D]g\}}|r/| tt||r/| tt|hd|S)zConvert a `httpx.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-Xrbzz-Hr Nzutf-8ignore)riz ... [truncated]zz-drrr)rjsortedr.r$r6contentdecodelenr?r~RequestNotReadrrKrrr(r!)r`partsr/r0r: flat_partss r-rlrl&s  w~$E w,,..//''1 7799 ' 'A 4A%&&D" ? &?))'()CCD4yy4uu+777)$//D  """!"  4dB//011 tW[! ""EJ--1  -   eCFFmm , , ,  -   eCFFmm , , , 88J  s"AB55C C z%^\s*bytes\s*=\s*(\d*)\s*-\s*(\d*)\s*$original_range resume_sizec|sd|dSd|vrtd|dt|}|std|d|\}}|sG|std|dt ||z }d|}|d krtd |d|St |}||z}|r2t |}d|d|}||krtd |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 - )ru RANGE_REGEXr>rgroupsr*)rJrKr>startend new_suffix new_range new_starts r-_adjust_range_headerrVTsq '& &&&& n]~]]]^^^   n - -E JH^HHHIIIJE3  NLLLLMM MXX + *j** ??BIBBBCC C JJE #I #hh.Y.... s??BIBBBCC C I  r,)r/N)N)xr'atexitrrosr7 threadingrrfcollections.abcrrr contextlibr dataclassesrshlexrtypingr r urllib.parser r~huggingface_hub.errorsr rrrrrrrrrrrrr_lfsr_typingr get_loggerr$rhrr8r7r:r(r@rerdr"VERBOSErrr^rPrZrStuplerXr\r_RequestrnrprrxrrrrCLIENT_FACTORY_TASYNC_CLIENT_FACTORY_TLockrrr)rrrrrrrregisterhasattrrTimeoutException NetworkErrorRemoteProtocolErrorrrrrr*rrrrrrrrsetrrrr_SENSITIVE_BODY_KEYSr<r?rl IGNORECASErOrVr+r,r-rrs EDD  8888888888%%%%%%!!!!!!!!!!!! 777777                      """"""  H % % $&&&&&&&&,2:mnn$"*%OPP8WS#X%68=4;O8888z #   *   2: *$$abb%"*%ijj'BJ'STTqpp35tS4Z1G+H2-3-3:---- --d ---- 5=TB*u}***** ' 'D ' ' ' ' e&7B ,-!"e&7"78y~ +A(AAA7S4SSS&* t#***0'70D0000"83I8d8888& U\     *5, * * * * 9999,  72!""6B}5555   =eDOS$89 3Qc3hPPPIe3Q^8^8^8 ^8 ^8 ^8  ^8  ^8i5i#1E+FF^8sCx0^8 ^8u~tT)*^8^8^8^8JIe3QMMM M M M  M  Mi5i#1E+FFMsCx0M ^MMMM` Ie3QOOO O O O  O  Oi5i#1E+FFOsCx0Ou~tT)*OOOOfAF000 0 #09=0 ^0000f  sTz c    i?i?%.i?ti?W[i?i?i?i?X(u~($((((07-^DDDf%&f8;fGL~f`cfffffTj#' em' ' ' ' ' VbjA2=QQ "!t"!#"!#PT*"!"!"!"!"!"!r,