pyir%SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r J r J r SSK Jr SSKJr SSKJr SSKJrJr SSKJr SSKrSS KJr S S KJr S S KJrJrJ r J!r!J"r"J#r#J$r$J%r% S SKJ&r& S SK'J(r( S SK)J*r* \&RV"\,5r-\"SS9"SS55r.\R^"S5r0\R^"S5r1S\ \2\24S\.S-4Sjr3Sr4Sr5Sr6\R^"S\RnS9r8\R^"S\RnS9r9\R^"S 5r:\R^"S!5r;1S"krS#\2S\2S-4S%jr?S&\RSS4S'jrAS&\RSS4S(jrBS)\RSS4S*jrDS\R4S+jrFS\R4S,jrH\ /\R4rI\ /\R4rJ\R"5rL\FqM\I\NS-'\HqO\J\NS.'SqP\RS-\NS/'S0\ISS4S1jrQS2\JSS4S3jrRS\R4S4jrSS\R4S5jrTS_S6jrU\R"\U5 \W"\S75(a\R"\US89 \R\R4r[\=\\\]S94\NS:'S;r^\=\_S94\NS<'S=S S>\[\^S?S@.SA\*S#\2SB\_SC\`SD\`SE\\\]\=\\\]S94-SF\_\=\_S94-SG\aS\ \RSS44SHjjrbS=S S>\[\^SI.SA\*S#\2SB\_SC\`SD\`SE\\\]\=\\\]S94-SF\_\=\_S94-S\R4SJjjrc\S=S S>\[\^SI.SA\*S#\2SB\_SC\`SD\`SE\\\]\=\\\]S94-SF\_\=\_S94-S\ \RSS44SKjj5rdS?SL.SA\*S#\2SM\aS\R4SNjjreS#\2SO\2S-S\24SPjrfS`S)\RSQ\2S-SS4SRjjrg\h"5riS)\RSS4SSjrj\"ST\"SU9rkSV\\\kSW\2S)\RSX\S\k4 SYjrlS&\RS\24SZjrm\R^"S[\R5roS\\2S-S]\_S\2S-4S^jrpg)az>Contains utilities to handle HTTP requests in huggingface_hub.N)Callable GeneratorMapping)contextmanager) dataclass)quote)AnyTypeVar)urlparse)OfflineModeIsEnabled) constants)BadRequestErrorBucketNotFoundErrorDisabledRepoErrorGatedRepoErrorHfHubHTTPErrorRemoteEntryNotFoundErrorRepositoryNotFoundErrorRevisionNotFoundError)logging) SliceFileObj) HTTP_METHOD_TT)frozenc`\rSrSr%Sr\\S'\\S'\\S'Sr\S-\S'Sr \S-\S'S r g) RateLimitInfo6a 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____firstlineno____doc__str__annotations__intr"r#__static_attributes__r$X/home/mande/repo/quber/.venv/lib/python3.13/site-packages/huggingface_hub/utils/_http.pyrr6s6 NE3:!%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+)headersreturncSnSnUH+nUR5nUS:XaXnMUS:XdM'XnM- U(dg[RU5nU(dgURS5n[ URS55n[ URS55nSn Sn U(aP[ RU5n U (a4[ U RS55n [ U RS55n [ UUUU U S 9$) aParse 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) r0r3policykey lower_keymatchrr r!r"r# policy_matchs r/parse_ratelimit_headersrBRs*!IFIIK  # I , ,\F    # #I .E KK0MEKK$%I5;;s+,E!%N .55f=  **3/0E !3!3C!89N #)%  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/ zA^https?://[^/]+/api/(models|datasets|spaces)/([^/]+)(?:/([^/]+))?z)^https?://[^/]+/api/buckets/([^/]+/[^/]+)> rawblobrefstreecommitresolverevisionsettings discussionsurlc[RU5nU(dg[RR UR S55nUR S5UR S5pCU(aU[ ;a USU3nX%4$UnX%4$)aExtract (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_REGEXr:rREPO_TYPES_MAPPINGgetr;_REPO_URL_SUBPATHS)rMr@ repo_typefirstsecondrepo_ids r/_parse_repo_info_from_urlrZs $ * *3 /E ,,00Q@IKKNEKKN6 & 22G1VH%    r.c`[RU5nU(aURS5$S$)z9Extract bucket_id (namespace/name) from a bucket API URL.rN)_BUCKET_ID_FROM_URL_REGEXr:r;)rMr@s r/_parse_bucket_id_from_urlr]s' % , ,S 1E"5;;q>,,r.requestc t[R"5(a[SURS35e[UR ;aUUR R [5=(d [[R"55UR ['UR R [5n[RSUURURUR R S5SL5 [R(a[RS[U55 U$)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 rMX_AMZN_TRACE_IDr0rT X_REQUEST_IDr*uuiduuid4loggerdebugmethodHF_DEBUG_curlify)r^ request_ids r/hf_request_event_hookrls  """GKK=)J K  goo-+2??+>+>|+L+aPSTXT^T^T`Pa($$_5J LL/ O,D8  Z'!23 r.c # [U5$7f)z+ Async version of `hf_request_event_hook`. )rl)r^s r/async_hf_request_event_hookrns ! ))s responsec# URS:aJSUR;a9[URS5nUS:aUR 5IShvN gggg![a gf=fN7f)NzContent-lengthi@B) status_coder0r, ValueErroraread)rolengths r/async_hf_response_event_hookrvss" x// / X--.>?@ !nn&&&" 0#   's3!A0AA0A.A0 A+(A0*A++A0c<[R"S[/0SSS9$)zI Factory function to create a `httpx.Client` with the default transport. r^TN event_hooksfollow_redirectstimeout)httpxClientrlr$r.r/default_client_factoryr~ s' <<!6 78 r.cH[R"[/[/S.SSS9$)zN Factory function to create a `httpx.AsyncClient` with the default transport. )r^roTNrx)r| AsyncClientrnrvr$r.r/default_async_client_factoryrs,   !< =LhKij r._GLOBAL_CLIENT_FACTORY_GLOBAL_ASYNC_CLIENT_FACTORY_GLOBAL_CLIENTclient_factoryc\[ [5 UqSSS5 g!,(df  g=f)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_factoryr+s !/ s  +async_client_factorycUqg)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_factoryr<s $8 r.c[c[ [5qSSS5 [$[$!,(df  [$=f)z 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_sessionrOs3 35N >\ s - Ac[5$)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_sessionr^s  ( ))r.c[nSqUbUR5 gg![a"n[R SU35 SnAgSnAff=f)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 Exceptionrfwarning)clientes r/rrnsTFN 9 LLN 9 NN3A37 8 8 9s A AA register_at_fork)after_in_child._DEFAULT_RETRY_ON_EXCEPTIONS)iiii_DEFAULT_RETRY_ON_STATUS_CODESF) max_retriesbase_wait_time max_wait_timeretry_on_exceptionsretry_on_status_codesstreamrhrrrrrrc +N^^^^^^# [U[5(aU4n[T[5(aT4mSmUn SmSn SU;a;[US[R[ 45(aUSR 5n [5n TS- mSmU bUSRU 5 S[RS[4UUUUUU4Sjjn U(a;U R"STTS.UD6n U "U 5(dU v SSS5 gSSS5 O(U R"STTS.UD6n U "U 5(dU v gTb.[%T5S-n[RS US TSTS35 O!U n[RSUSTSTS35 [&R("U5 [+XIS-5n GM%!,(df  N=f!UaYn[RS US TS T35 [U[R 5(a [#5 TT:aUeSnANSnAff=f7f)zfInternal implementation of HTTP backoff logic shared between `http_backoff` and `http_stream_backoff`.rNdatarror1c>URT;ag[RSURSTST35 TT:a [U5 gURS:Xa$[ UR 5nUb UR mg)zNHandle response and return True if should retry, False if should return/yield.Fz HTTP Error z thrown while requesting  rT)rrrfrhf_raise_for_statusrBr0r!)roratelimit_inforrhnb_triesratelimit_resetrrMs r/ _should_retry)_http_backoff_base.._should_retrys''/DD X-A-A,BB[\b[ccdehdijkk)'1!''3.%>KSKFK$X.."N/  & 1A5L NN3L>AWX`Waabcnbooqr s%L NN\,y !K=XZ[ \ < Q7  DED#  NNQse#=fXQseL M#u1122+% &  soB H%AG+F2>GH%GH%&G7A;H%2 G<G?H%GH" AHH%H""H%)rrrrrc <[[SUUUUUUUSS.UD65$)ax 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` and `httpx.NetworkError`. 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). FrhrMrrrrrrr$)nextrrhrMrrrrrrs r/ http_backoffrsAB  #)' 3"7    r.c +H# [SUUUUUUUSS.UD6ShvN gN7f)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` and `httpx.NetworkError`. 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_backoffr>sAL"  %#/3     s " ")retry_on_errorsrc PU(a0OSSS.n[SUUS.UDSS0DUD6n[U5 SURs=::aS::a_O U$[URS5nUR S :Xa2[U5R URS 9R5nMU$) aPerform 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$)rrrrzFi,iLocation)path) rrrrr r0netloc_replacergeturl)rhrMr httpx_kwargsno_retry_kwargsro parsed_targets r/-_httpx_follow_relative_redirects_with_backoffrs02XZ#[    #     H% (&& -# -  O%X%5%5j%ABM##r)sm,,-2D2D,ELLN  Or.endpointcU(aURS5O[RnU[R[R4;a@UR [RU5nUR [RU5nU$)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. rQ)rstriprENDPOINT_HF_DEFAULT_ENDPOINT_HF_DEFAULT_STAGING_ENDPOINTreplace)rMrs r/fix_hf_endpoint_in_urlrsf (0xs#Y5G5GH 66 8^8^__kk)88(Ckk)@@(K Jr. endpoint_namec  [U5 UR 5 g![a [RSSS9 N2f=f![ R Ga.nURS-S:XaSnAgURRS5nURRS5nURb6URRb[URR5OSnU(a [U5OS upgUS :Xa3URS 3S -S URS3-n[[XXgS9UeUS:Xa3URS 3S -SURS3-n[[ XXgS9UeUS:Xa3URS 3S -SURS3-n[["XXgS9UeUS:Xa:URS 3S -SURS3-S-S-n[[$X5UeUS:Xa[UbX[&R)U5bBURS 3S -SURS3-S-S-n[[*X[-U5S9UeUS:Xd/URS:XaXUS:waRUbO[.R)U5b9URS 3S -SURS3-S-S -n[[0XXgS9UeURS!:XaUbS"US#3OS$n[[2X5UeURS%:Xa8S URS&US3S'URS3-S(-n[[4X5UeURS):Xa[7UR5n U bS*U R8S+3nUS,U R:S-3- nU R<b;U R>b.US.U R@S/U R<S0U R>S13- nOUS- nUS2URS3- nOS3URS3n[[4X5UeURS4:XaZURRRS55n US6U S7URRS85S3n[[4X5Ue[[4[U5U5UeSnAff=f)9ad 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_infodrPNz X-Error-CodeX-Error-MessagerORevisionNotFoundz Client Error. zRevision Not Found for url: .)rVrY 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_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/authenticationrqz 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 (rQz 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_headersrrfrgraise_for_statusr|HTTPStatusErrorrrr0rTr^rMr*rZ_formatrrrrBUCKET_API_REGEXr:rr]REPO_API_REGEXrrrrBrr!r"r#r ) rorr error_code error_message request_urlrVrYmessager range_headers r/rrsnBG * u?!!# G 6 FG  s?   3 &! + %%)).9  ((,,->? *2)9)9)E(JZJZJ^J^JjC  $$ %pt HS6{CXd + +!--.n=FKghphthtguuvIwwG/iiop p ? *!--.n=FKdemeqeqdrrsIttG2GQZlrs s ; &''(7&@EfgogsgsfttuCvv .'ybhi i D D''(75hll^1EF9 9 +W?Q F . (' '' 4@''(7.x||nA>?]]} } #WB[\gBh > )  C '!NN'%%k2>''(728<<.BC`` g g 17PYkqr r  ! !S (DQD]&}oZ@cu /7=1 D  ! !S (x++,LqI0a@AGH  .'gs?s, AAARR0PRRcFURRS5nUHnSU;aURSS5OSU4up4UR5nU[;dM=UR5nU(dMV[R U5 [ RU5 M g)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)r0get_listsplitstrip_WARNED_TOPICSaddrfr)roserver_warningsserver_warningtopicrs r/rrss&&//?O)9<9N--c15UWYgTh   &mmoGw""5)w'*r._HfHubHTTPErrorT)bound error_typecustom_messageattrsc /nURRS5nUbURU5 UR5nURS5nUb8[U[5(aURU5 OURU5 URS5nUb%UHnSU;dM URUS5 M! UV s/sH<n [U 5R5(dM#[U 5R5PM> nn [[ R#U55nSR%U5n Un U (a9U R5UR5;aS U;a U SU -- n OU S U -- n Sn Sn[&S 4[(S 4[*S 44H>unnURRU5nU(dM*[U5n S USUS3n O U (aLU R5U R5;a*SU ;a U R-S5nU SUU-U US-n OX- n U"U R5X+=(d SS9nUR/5Hunn[1UUU5 M U$![R a9 UR 5 UR5nGNn![a 0nGN~f=ff=f![Ra` URRSS5n UR(a/SU R5;aURUR5 GNtf=fs sn f)Nrerrorerrorsrz Content-Typerhtmlrrz Request IDz Amzn Trace IDz Amz CF IDr: ))roserver_message)r0rTappendjsonr|ResponseNotReadread RuntimeErrorrlistextendJSONDecodeErrortextr8r*rdictfromkeysjoinrcrb X_AMZ_CF_IDindexitemssetattr)rrror server_errors from_headersrr r  content_typelinerfinal_error_messagerkrequest_id_messageheaderlabelvalue newline_indexrkvs r/rrs)M##''(9:L\*$0 ==?D!  %&&$$U+$$U+(#  %!((y)9: 4AV=4CIOODU&SY__&=MV}56MYY}-N)...08L8L8NN ^ # 4.#8 8  6N#: : J |$ /* k"    $$V, 5UJ#%eWBugQ!7  j&&(0C0I0I0KK & &/55d;M#N]36HHK^_l_mKnn  5  (..08Tjfj kC 1Q Ja$$   }}     8   0''++NB? ==V<+=+=+??   / 0WsaI:A)K 1K "M3M:K J2/K 2 K>K?K KKK A0L>=L>cSSUR4/n[URR55H(up#UR 5S:XaSnUSUSU34/- nM* SnUR b1UR R SS S 9n[U5S :aUSS S 3nUbUSURSS54/- nUSUR4/- n/nUH[up#U(a#UR[[U555 U(dM8UR[[U555 M] SRU5$![Ra S nNf=f)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-Xr`zz-Hr Nzutf-8ignore)r iz ... [truncated]zz-drrr)rhsortedr0rr8contentdecodelenr|RequestNotReadrrMrrr*r)r^partsr)r*body flat_partss r/rjrjsd  w~~$E w,,./ 779 'A 4A3b%&&0 D" ?? &??))'()CD4y4u+&67  4dB/011 tW[[! ""EJ   eCFm , 1   eCFm ,  88J    "!"s#>EEEz%^\s*bytes\s*=\s*(\d*)\s*-\s*(\d*)\s*$original_range resume_sizecU(dSUS3$SU;a[SU<S35e[RU5nU(d[SU<S35eUR 5up4U(dBU(d[SU<S35e[ U5U- nSU3nUS ::a[S U<S35eU$[ U5nX1-nU(a*[ U5nSUSU3nXt:a[S U<S35eU$SUS3$) z: Adjust HTTP Range header to account for resume position. zbytes=-,zMultiple ranges detected - z, not supported yet.zInvalid range format - rzbytes=-rzEmpty new range - )rs RANGE_REGEXr@rgroupsr,)r6r7r@startend new_suffix new_range new_starts r/_adjust_range_headerrBs!  }A&& n6~6HH\]^^   n -E 4^4FaHIIJE !88J!LM MX + j\* ?!3I=BC C JE#I #hYKq. ?!3I=BC C I;a  r.)r1N)N)qr)atexitrrosre threadingrrdcollections.abcrrr contextlibr dataclassesrshlexrtypingr r urllib.parser r|huggingface_hub.errorsr rrr rrrrrrrrr_lfsr_typingr get_loggerr%rfrcompiler9r<r*rBrcrbrVERBOSErrrRr\rUtuplerZr]Requestrlrnrrvr}r~rrCLIENT_FACTORY_TASYNC_CLIENT_FACTORY_TLockrrr+rrrrrrrregisterhasattrrTimeoutException NetworkErrorrrrrr,rrrrrrrrsetrrrrrj IGNORECASEr;rBr$r.r/r^s2E  88%!! 7   "   H % $&&&,::mn**%OP8WS#X%68=4;O8z #   ** :: ****%ijJJ'STq35tS4Z1G+H2-3-3:- 5==TB*u}}** ' 'D ' e&7&7B ,-!"e&7&7"78~~ +A(A7S4S&* t#*0'70D0"83I8d8& U\\  *5,, * 9,  2!""}5>C=S=SUZUgUg