RX9ic %SrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r SSK J r J r JrJrJrJrJr SSKrSSKJrJr SSKJr SSKJr SS KJr S S KJr S S KJrJ r J!r!J"r"J#r#J$r$J%r% S SKJ&r& S SK'J(r( S SK)J*r* S SK+J,r, \&RZ"\.5r/Sr0Sr1\Rd"S\RfS9r4"SS\5r5"SS\5r6S\Rn4Sjr8\ /\Rn4r9\8q:\9\;S'\84S\9SS4Sjjr\S!\?S"\?S\Rn4S#j5r@S$S S%\R\R\RR4S&S'.S(\,S)\ES*\?S+\FS,\FS-\\\G\\\GS.44S/\\?\\?S.44S\4S0jjrHS)\ES1\\ES\E4S2jrIS@S3\S4\\ESS4S5jjrJS6\\#S7\ES3\S\#4S8jrKS9\R2S\E4S:jrL\Rd"S;\R5rNS<\\ES=\?S\\E4S>jrOg)Az>Contains utilities to handle HTTP requests in Huggingface Hub.N) lru_cache)quote)AnyCallableListOptionalTupleTypeUnion) HTTPErrorResponse) HTTPAdapter)PreparedRequest)OfflineModeIsEnabled) constants)BadRequestErrorDisabledRepoErrorEntryNotFoundErrorGatedRepoErrorHfHubHTTPErrorRepositoryNotFoundErrorRevisionNotFoundError)logging)JSONDecodeError) SliceFileObj) HTTP_METHOD_TX-Amzn-Trace-Idz x-request-ida  # staging or production endpoint ^https://[^/]+ ( # on /api/repo_type/repo_id /api/(models|datasets|spaces)/(.+) | # or /repo_id/resolve/revision/... /(.+)/resolve/(.+) ) )flagscD^\rSrSrSrU4SjrS\S\4U4SjjrSr U=r $)UniqueRequestIdAdapterJrc >[TU]"U40UD6 [UR;aUURR [ 5=(d [ [R"55UR['[[ URR SS555S:n[RSUR[SURSURSUS3 5 g) N authorizationrzRequest z:  z (authenticated: ))super add_headersX_AMZN_TRACE_IDheadersget X_REQUEST_IDstruuiduuid4lenloggerdebugmethodurl)selfrequestkwargs has_token __class__s [/var/www/html/land-doc-ocr/venv/lib/python3.13/site-packages/huggingface_hub/utils/_http.pyr*"UniqueRequestIdAdapter.add_headersMs G.v. '// 1/6/B/B

>:J!GKK=Xijsittu v r8returncL>[R(a![RS[ U535 [ TU]"U/UQ70UD6$![RaBnURR[5nUb/URQSUS3P7Ul eSnAff=f)zSCatch any RequestException to append request id to the error message for debugging.zSend: Nz (Request ID: r() rHF_DEBUGr3r4_curlifyr)sendrequestsRequestExceptionr,r-r+args)r7r8rFr9e request_idr;s r<rCUniqueRequestIdAdapter.sendZs    LL6(7"3!45 6 7<9$9&9 9((  ,,_=J%A166A]:,a#@A   sA B#!=BB#) __name__ __module__ __qualname____firstlineno__r+r*rr rC__static_attributes__ __classcell__)r;s@r<r"r"Js%'O   O   r>r"c&\rSrSrS\S\4SjrSrg)OfflineAdapterhr8r?c4[SURS35e)Nz Cannot reach za: offline mode is enabled. To disable it, please unset the `HF_HUB_OFFLINE` environment variable.)rr6)r7r8rFr9s r<rCOfflineAdapter.sendis&"GKK=)J K  r>rJN)rKrLrMrNrr rCrOrJr>r<rRrRhs O  r>rRr?c.[R"5n[R(a6UR S[ 55 UR S[ 55 U$UR S[ 55 UR S[ 55 U$)Nzhttp://zhttps://)rDSessionrHF_HUB_OFFLINEmountrRr")sessions r<_default_backend_factoryr[osm G i!12 j."23 N  i!7!9: j"8":; Nr>_GLOBAL_BACKEND_FACTORYbackend_factorycUq[5 g)ao Configure the HTTP backend by providing a `backend_factory`. Any HTTP calls made by `huggingface_hub` will use a Session object instantiated by this factory. 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 configured Session. Since `requests.Session` is not guaranteed to be thread-safe, `huggingface_hub` creates 1 Session instance per thread. They are all instantiated using the same `backend_factory` set in [`configure_http_backend`]. A LRU cache is used to cache the created sessions (and connections) between calls. Max size is 128 to avoid memory leaks if thousands of threads are spawned. See [this issue](https://github.com/psf/requests/issues/2766) to know more about thread-safety in `requests`. Example: ```py import requests from huggingface_hub import configure_http_backend, get_session # Create a factory function that returns a Session with configured proxies def backend_factory() -> requests.Session: session = requests.Session() session.proxies = {"http": "http://10.10.1.10:3128", "https": "https://10.10.1.11:1080"} return session # Set it as the default session factory configure_http_backend(backend_factory=backend_factory) # In practice, this is mostly done internally in `huggingface_hub` session = get_session() ``` N)r\reset_sessions)r]s r<configure_http_backendr`~s@.r>cb[[R"5[R"5S9$)a Get a `requests.Session` object, using the session factory from the user. Use [`get_session`] to get a configured Session. Since `requests.Session` is not guaranteed to be thread-safe, `huggingface_hub` creates 1 Session instance per thread. They are all instantiated using the same `backend_factory` set in [`configure_http_backend`]. A LRU cache is used to cache the created sessions (and connections) between calls. Max size is 128 to avoid memory leaks if thousands of threads are spawned. See [this issue](https://github.com/psf/requests/issues/2766) to know more about thread-safety in `requests`. Example: ```py import requests from huggingface_hub import configure_http_backend, get_session # Create a factory function that returns a Session with configured proxies def backend_factory() -> requests.Session: session = requests.Session() session.proxies = {"http": "http://10.10.1.10:3128", "https": "https://10.10.1.11:1080"} return session # Set it as the default session factory configure_http_backend(backend_factory=backend_factory) # In practice, this is mostly done internally in `huggingface_hub` session = get_session() ```  process_id thread_id)_get_session_from_cacheosgetpid threading get_identrJr>r< get_sessionrjs : #biikYEXEXEZ [[r>c,[R5 g)zReset the cache of sessions. Mostly used internally when sessions are reconfigured or an SSLError is raised. See [`configure_http_backend`] for more details. N)re cache_clearrJr>r<r_r_s '')r>rcrdc[5$)z Create a new session per thread using global factory. Using LRU cache (maxsize 128) to avoid memory leaks when using thousands of threads. Cache is cleared when `configure_http_backend` is called. )r\rbs r<reres # $$r>)iiii) max_retriesbase_wait_time max_wait_timeretry_on_exceptionsretry_on_status_codesr5r6rprqrrrs.rtc X[U[5(aU4n[U[5(aU4nSnUn Sn SU;a;[US[R[ 45(aUSR 5n [5n US- nU bUSRU 5 U R"SXS.UD6n U RU;aU $[RSU RSUSU35 X:aU R5 U $[RS U S US US35 ["R$"U 5 ['XIS-5n M!UaXn [RS U S USU35 [U [R5(a [!5 X:aU eSn A NSn A ff=f)a Wrapper around requests 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 `requests.Timeout`, `requests.ConnectionError` and `requests.exceptions.ChunkedEncodingError`. retry_on_status_codes (`int` or `Tuple[int]`, *optional*, defaults to `(500, 502, 503, 504)`): Define on which status codes the request must be retried. By default, 5xx errors are retried. **kwargs (`dict`, *optional*): kwargs to pass to `requests.request`. Example: ``` >>> from huggingface_hub.utils import http_backoff # Same usage as "requests.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). rNdatar)r5r6z HTTP Error z thrown while requesting r''z' thrown while requesting z Retrying in z s [Retry /z].rrJ) isinstancetypeintioIOBasertellrjseekr8 status_coder3warningraise_for_statusrDConnectionErrorr_timesleepmin)r5r6rprqrrrsrtr9nb_tries sleep_timeio_obj_initial_posrZresponseerrs r< http_backoffrsH%t,,24'--!6 8HJ  Jvf~ <7PQQ#F^002mG A  "-v##$67HfHHH##+@@ NN[)=)=(>>WX^W__`ad`ef g%))+  & j\8*Ak]RTUV :Q7 G *#  NNQse#=fXQseL M#x7788 % &  s E F)AF$$F)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. rx)rstriprENDPOINT_HF_DEFAULT_ENDPOINT_HF_DEFAULT_STAGING_ENDPOINTreplace)r6rs r<fix_hf_endpoint_in_urlrOsf (0xs#Y5G5GH 66 8^8^__kk)88(Ckk)@@(K Jr>r endpoint_namecUR5 g![GanURRS5nURRS5nUS:Xa4URS3S-SUR S3-n[ [XP5UeUS:Xa4URS3S-S UR S3-n[ [XP5UeUS :Xa4URS3S-S UR S3-n[ [XP5UeUS :Xa:URS3S-S UR S3-S-S -n[ [XP5UeUS:XddURS:XaUS:waURbxURR ba[RURR 5b7URS3S-SUR S3-S-n[ [XP5UeURS:XaUbSUS3OSn[ [XP5UeURS:Xa8SURSUS3SUR S3-S-n[ [ XP5UeURS:XaZURRRS5nUSUS URRS!5S3n[ [ XP5Ue[ [ [#U5U5UeSnAff=f)"a( Internal version of `response.raise_for_status()` that will refine a potential HTTPError. Raised exception will be an instance of `HfHubHTTPError`. This helper is meant to be the unique method to raise_for_status when making a call to the Hugging Face Hub. Example: ```py import requests from huggingface_hub.utils import get_session, hf_raise_for_status, HfHubHTTPError response = get_session().post(...) try: hf_raise_for_status(response) except HfHubHTTPError as e: print(str(e)) # formatted message e.request_id, e.server_message # details returned by server # Complete the error message with additional information once it's raised e.append_to_message(" `create_commit` expects the repository to exist.") raise ``` 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 find. > - [`~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. z X-Error-CodeX-Error-MessageRevisionNotFoundz Client Error. zRevision Not Found for url: . 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  RepoNotFoundiz+Invalid credentials in Authorization headerNzRepository 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. For more details, see https://huggingface.co/docs/huggingface_hub/authenticationiz Bad request for z endpoint:z Bad request:iz Forbidden: z Cannot access content at: z2 Make sure your token has the correct permissions.iRangez. Requested range: z. Content-Range: z Content-Range)rr r,r-rr6_formatrrrrr8REPO_API_REGEXsearchrrrr/)rrrG error_code error_messagemessage range_headers r<hf_raise_for_statusr\sVjJ?!!# H?%%)).9  ((,,->? + +!--.n=FKghphthtguuvIwwG/C J ? *!--.n=FKdemeqeqdrrsIttG,g@a G ; &''(7&@EfgogsgsfttuCvv .' )  C '!NN  ,  $$0%%h&6&6&:&:;G''(728<<.BCNN 17E1 L  ! !S (DQD]&}oZ@cu /7=1 D  ! !S (x++,LqI0a@AGH  .'QH?s K!J>KK! error_typecustom_messagec/nURRS5nUbURU5 UR5nURS5nUb8[ U[ 5(aUR U5 OURU5 URS5nUb%UHnSU;dM URUS5 M! UV s/sH<n [U 5R5(dM#[U 5R5PM> nn [ [RU55nSRU5n Un U (a9U R5UR5;aS U;a U SU -- n OU S U -- n [URR[S55n U (aS U S 3n O6[URR[ S55n U (aS U S 3n U (aLU R5U R5;a*SU ;aU R#S5nU SUW -XS-n OU W - n U"U R5X*=(d SS 9$![a` URRSS5nUR(a/SUR5;aURUR5 GNf=fs sn f)Nrerrorerrorsrz Content-Typer&htmlrrz (Request ID: r(z (Amzn Trace ID: )rserver_message)r,r-appendjsonrylistextendrtextlowerr/stripdictfromkeysjoinr.r+index)rrr server_errors from_headersrvrr content_typelinerfinal_error_messagerHrequest_id_message newline_indexs r<rrsM##''(9:L\*0}}!  %&&$$U+$$U+(#  %!((y)9: 4AV=4CIOODU&SY__&=MV}56MYY}-N)...08L8L8NN ^ # 4.#8 8  6N#: : X%%)),;z-Hz{0}: {1}zutf-8ignore)rreadziNz ... [truncated]z-drr&r')r5sortedr,itemsrformatbodyrybytesdecodehasattrr2rr6rrr)r8partskvr flat_partss r<rBrB(sK  w~~$E w,,./ 779 'A 4**101220 |||| dE " ";;wx;8D T6 " "'D t9t ;!33D 4dB/011 tW[[! ""EJ   eAh ' 1   eAh '  88J r>z%^\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 - ) ValueError RANGE_REGEXmatch RuntimeErrorgroupsr{)rrrstartend new_suffix new_range new_starts r<_adjust_range_headerrTs!  }A&& n6~6HH\]^^   n -E 4^4FaHIIJE !88J!LM MX + j\* ?!3I=BC C JE#I #hYKq. ?!3I=BC C I;a  r>)r?N)N)P__doc__r|rfrerhrr0 functoolsrshlexrtypingrrrrr r r rDr r requests.adaptersrrequests.modelsrhuggingface_hub.errorsrr&rrrrrrrrrr_fixesr_lfsr_typingr get_loggerrKr3r+r.compileVERBOSErr"rRrWr[BACKEND_FACTORY_Tr\__annotations__r`rjr_r{reTimeoutr exceptionsChunkedEncodingErrorr/float ExceptionrrrrrB IGNORECASErrrJr>r<rsE  DDD()+7#"   H % $   **  [< [ ("2"2R!1!112-E*EAY!,=!]a!H\X%%\@* %%%@P@P% %  00P :Nx8 x8 x8 x8  x8  x8tId9os6J0KKLx8!eCHo!56x8x8v  x}  ?(?8C=?TX?DGm^,GmcGmXGmZhGmT% h..% 3% RjjA2==Q "!#"!S"!XVY]"!r>