5pjk SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKJrJr SSKJr SSKJr SSKJr SSKrSSKJr SS KJr S S KJrJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r& S S K'J(r(J)r)J*r*J+r+J,r,J-r- S S K.J/r/J0r0 S SK1J2r2 \(a S SK3J4r4 S SK5J6r6 \2"S5r7Sr8"SS5r9"SS\95r:Sr;\RxSS.S!Sjj5r=S"Sjr>S#Sjr?S$Sjr@S%S&SjjrA"SS 5rBg)'aInternal file download implementation. Supports single-file and whole-repo (snapshot) downloads with: - HTTP Range-based resume - SHA256 integrity verification - tqdm progress display - Parallel downloads via ThreadPoolExecutor - Parallel range download (split large files into parts) - Per-file download retry with backoff - File lock for multiprocess safety - User-agent / snapshot headers - Intra-cloud acceleration - Local-files-only (offline) mode - Custom progress callbacks - Local snapshot cache directory management ) annotationsN)ThreadPoolExecutor as_completed)Path) TYPE_CHECKING)urlparse)tqdm)Retry) DOWNLOAD_CHUNK_SIZEDOWNLOAD_PARALLEL_THRESHOLDDOWNLOAD_PARALLELSDOWNLOAD_PART_SIZEDOWNLOAD_RETRY_TIMESDOWNLOAD_TIMEOUT ENV_FILE_LOCKENV_INTER_CLOUD_REGIONSENV_INTRA_CLOUD_ACCELERATIONENV_INTRA_CLOUD_REGION) CacheNotFoundFileIntegrityError NetworkError NotExistErrorPermissionDeniedErrorRequestTimeoutError) compute_hash ensure_dir) get_logger) LegacyClient) HubConfigdownloadc6\rSrSrSrSSjrS SjrS SjrSrg) ProgressCallbackKzBase class for download progress callbacks. Subclass and override :meth:`update` / :meth:`end` to track download progress. Instances are created per-file by ``callback_cls(filename, file_size)``. cXlX lgN)filename file_size)selfr(r)s T/var/www/html/pdf-tiff/venv/lib/python3.13/site-packages/modelscope_hub/_download.py__init__ProgressCallback.__init__Ss  "cgr'r*sizes r+updateProgressCallback.updateW r.cgr'r0r*s r+endProgressCallback.endZr5r.)r)r(Nr(strr)intr2r<returnNoner>r?) __name__ __module__ __qualname____firstlineno____doc__r,r3r8__static_attributes__r0r.r+r$r$Ks#  r.r$cD^\rSrSrSrSU4SjjrSSjrS SjrSrU=r $) TqdmCallback^z!Progress callback backed by tqdm.c x>[TU]X5 [SSSUS:aUOSSSURS3SS9Ulg) NBTirr z Downloading [])unit unit_scale unit_divisortotalinitialdescleave)superr,r r(progress)r*r(r) __class__s r+r,TqdmCallback.__init__asF -(1})! q1  r.c:URRU5 gr')rUr3r1s r+r3TqdmCallback.updatems T"r.c8URR5 gr')rUcloser7s r+r8TqdmCallback.endps r.)rUr:r=r@) rArBrCrDrEr,r3r8rF __classcell__)rVs@r+rHrH^s+  #r.rHi Tenabledc ## U(aUcSv gSSKJnJnJn URR SSS9 SnU"[ U5US9nSnSnURUS9 Uv UR-5 g!Ua X- nU(aU[:a[R"5UR5R- n O![a Sn Of=fU [:a=[RS U U5 URSS 9 O![a Of=fSnM[R!S U5 O["aDn S [ U 5;a/[RS U5 U"[ U5US9nSnSn A GM.eSn A f[a~n U R$[$R&[$R([+[$SS54;a:[RSU R$U5 U"[ U5US9nSnSn A GMeSn A ff=fGM![a% UR5 g![a gf=ff=f!UR-5 f![a% UR5 f![a ff=ff=f=f7f)z4Acquire a file lock when *enabled*, otherwise no-op.Nr)FileLock SoftFileLockTimeoutTparentsexist_ok<timeoutFz4Removing possibly stale SoftFileLock (age=%.0fs): %s missing_okz#Still waiting to acquire lock on %szuse SoftFileLock insteadzFFilesystem does not support flock, falling back to SoftFileLock for %s EREMOTEIOz7OSError (errno=%d) on %s, falling back to SoftFileLock.)filelockrarbrcparentmkdirr;acquire_STALE_LOCK_SECONDStimestatst_mtimeOSErrorloggerwarningunlinkinfoNotImplementedErrorerrnoESTALEENOENTgetattrrelease) lock_pathr_rarbrcdefault_intervallockis_softwaitedageexcs r+_optional_file_lockrzsk i' 88 4$7 C N,< =DG F /  LL!1L 2\     LLNg   &F6%88))+ (8(A(AACC--NNN! !((D(9"F KK5 # )SX5\$C N$H 4J5H0CH CHC$H6DH DHDHJH1J3 H<7E;3J:E;; HA1H9JHHJ H;H)'J) H73H;4J6H77H;;J>JIJ JI.,J. I< 8J9J;I< <JJJc(SSKJn U"[S5$)z6Check whether file locking is enabled via environment.r  _env_boolT) constantsrrrs r+_file_lock_enabledrs$ ]D ))r.cU(dgUHWn[R"X5(a gSU;dM(URSS5n[R"X5(dMW g g)zCheck if path matches any of the glob patterns. Also accepts legacy regex-style patterns (e.g. ``.*\.bin``) by converting ``.*`` to ``*`` before matching. FTz.**)fnmatchreplace)pathpatternspatglob_pats r+_matches_patternsrsT  ??4 % % 3;{{4-Ht..  r.c Uupp4pVpxUc0O[R"U5n [R"5RU S'[ [ SS/S9n USUSU3n Sn [RRU 5(aO[U S 5n U RS[R5n UHnURU 5 M SSS5 X<-nX:agS US U3U S '[U S 5n [R "USU U["S9nUR%5 UR'[(S9H@nU(dM U R+U5 UHnUR[-U55 M MB SSS5 g!,(df  N=f!,(df  N =f![.aBnU R1SUUS9n [2R5SX4U5 U R75 SnAOSnAff=fGM)z4Download a byte range with retry and resume support.N X-Request-IDr GETrPbackoff_factorallowed_methods_Trrbbytes=-Rangezab+)streamheaderscookiesri chunk_sizeerrorz-Downloading part %s-%s failed: %s, will retry)copydeepcopyuuiduuid4hexr rosrexistsopenseekioSEEK_ENDr3requestsgetrraise_for_status iter_contentr writelen Exception incrementrwrxsleep)params file_pathprogress_callbacksstartr8url file_namerr get_headersretrypart_file_namepartial_lengthfcbdownload_startrchunkrs r+_download_part_with_retryrsRXOI5sw"T]]7-CK"&**,"2"2K " E "{!E7!C51N  Nww~~n--.$/1%&VVAr{{%;N0 .110#3N#%+N+;1SE#BK ne,LL'#, ""$^^7J^KEu"4BIIc%j1#5L- -0/-, OOE3cO:E NNJEX[ \ KKMM 7 sU!2F&;FF& F&7AF8F;F& FF& F#F&& G208G--G2c XU=(d /n[n/n[U5n URRSSS9 X'-n [ U 5H1n X-n U S-U-S- n UR XXXR X445 M3 X-nX:a"UR XXS- XR X445 [[S5n[USS9n[UR[U55 SSS5 UHnUR5 M [R"5nUR!UR"S-5n[%US 5nUHnUS S US S US 3n[%US5nUR'S[(-5nU(dO$UR+U5 UR-U5 MDSSS5 [.R0"U5 M SSS5 UR3U5 UR55$!,(df  GN=f!,(df  Nc=f!,(df  NR=f)zkSplit a large file into parts and download in parallel. Returns the SHA256 hex digest of the merged file. Trdr r!) max_workersthread_name_prefixNz .parallel_tmpwbrrr"r)rr;rorprangeappendnameminrrlistmaprr8hashlibsha256 with_suffixsuffixrreadr rr3rremover hexdigest)rtargetr)rrr callbacks part_sizetasksrnum_full_partsidxrr8remainder_start parallelsexecutorr hash_sha256 tmp_target output_filetaskr part_filers r+_parallel_downloadrs#(bI"IEF I MMt4+N^$Qw)#a' iE[['[\%%0O" iO]CQ\Q\^eop&+I  j QU] X\\3U ;< R .."K##FMMO$CDJ j$ ;D $Qy$q'!DG9=Nnd+y%NN20C+CDE %%e,&&u- , IIn % v  "") R Q,+ s1 G8%H'AH -"H8 H H H H)cX\rSrSrSrSSjrSSSjjrSSjr\R"S5r \ SSj5r \ SSS jj5r SS jrS S!S jjrSS"S jjrS#S$S jjrS%S&SjjrS'Sjr\ S(Sj5rSS)SjjrSS*SjjrS S+SjjrSSSS.S,SjjrS-SjrSrg).DownloadManageriHzoInternal file download implementation. Dependencies are injected via constructor to keep this class testable. clXlX lSUl0Ul[R "5Ulgr')_client_config_cached_region_inter_region_cache threadingLock_inter_region_lock)r* legacy_clientconfigs r+r,DownloadManager.__init__Ns/$  *.SU "+.."2r.NcLSSKJn U"URR5US9$)Nr )build_user_agent) session_idextra)utilsrrget_session_id)r* user_agentrs r+_build_user_agent!DownloadManager._build_user_agentZs%+||224  r.cTURb UR$URRnUS3nSSjnSnU"US5nUbZUR5nSnSU;aUSR SS5nU(a&U"US5nUbUR R 5nX@lU$)z._getjsD ||C9%%' &&77  s%(A A g?DataInternalRegionQueryAddress)rr;rifloat)rrendpointjsonrtextstrip) r*r internal_urlr  region_idr data query_addr domain_resps r+_detect_regionDownloadManager._detect_regionbs    *&& &<<(("#IJ   L#&  99;DJ~!&\--.JBO ":s3 * + 0 0 6 6 8I'r.z".*\.oss.*-internal\.aliyuncs\.com$c[U5R=(d Sn[[R R U55$![a gf=f)zCheck if a URL points to an OSS internal (intranet) endpoint. Matches hostnames like: modelhub-cn-hangzhou.oss-cn-hangzhou-internal.aliyuncs.com r F)rhostnamerboolr_OSS_INTERNAL_REmatch)rhosts r+_is_oss_internal_url$DownloadManager._is_oss_internal_urlsM C=))/RDO44::4@AA  sA AAc[R"UUUSUS9nURS;aURR SS5$g![R R a gf=f)zHSend a HEAD request without following redirects to get the 302 Location.F)rrallow_redirectsri)i-i.i/i3i4Locationr )rhead status_coderrrr)rrrrirs r+_probe_redirect_url#DownloadManager._probe_redirect_urlsu   % A}} 99yy}}Z44:""33   sAAA)(A)cSSKJn U"[S5=(d SnURS5Vs/sH7o3R 5(dMUR 5R 5PM9 sn$s snf)z;Read the inter-cloud peer region list from the environment.r )_env INTER_CLOUD_ACCELERATION_REGIONSr ,)rr+rsplitrlower)r*r+rawrs r+_get_inter_cloud_regions(DownloadManager._get_inter_cloud_regionssO#*,NOUSU+.99S>G>aWWY! !>GGGs A1 "A1cUcUR5nU(dUS4$URSS5R5nURXU5nUR U5(a[ R S5 US4$UHVnXu:XaM 0UESU0EnURXU5nUR U5(dM<[ R SU5 US4s $ [ R S5 US4$) uProbe peer regions and return headers with the best region for OSS internal download. Steps: 1. Probe with current (local) region — if already OSS internal, return as-is. 2. Try each peer region in order (skip duplicates of local) — first OSS internal hit wins. 3. If all miss, fall back to original headers (default path). Returns: (headers, source) where source is "local", "peer", or "default". defaultx-aliyun-region-idr zEInter-region: local region already yields OSS internal URL, skipping.localzAInter-region acceleration: using peer region "%s" (OSS internal).peerzIInter-region: no peer region yields OSS internal URL, using default path.)r1rr/r(r!rwdebug) r*rrr peer_regionscurrent_region redirect_url peer_region probe_headerss r+_resolve_inter_region_headers-DownloadManager._resolve_inter_region_headerss"  88:LI% % %92>DDF//gF  $ $\ 2 2 LL` aG# #(K,JwJ( = v}} % !:;**')'9+ ' $$V=#<>J * !:Q!>>M%#aK5    6 3> =J s8F-:AF-E F- AF*%F-(F**F-- F<c Ub[[U55n OSURXU5n U b[R SU 5 U n U nO#UR XU5n[US- U- 5n U (aI[ U R55(a[RSU5 U $[S[U 5S9eUS;aURUUUU S9$US ;aURRUUS 9nOURRUUUS S 9n/nUGHHnURS 5=(d2 URS5=(d URS5=(d SnURS5=(d URS5=(d SnUS:XaMU(dMU(a[!UU5(dMU(a[!UU5(aMURS5=(d URS5=(d SnURS5=(d URS5nU(a [#U5OSnUR%UUU45 GMK U(d[R SX5 U $[R S['U5X5 /n[)US9nUVVVs0sH+unnnUR+UR,UUUUUUUUU U S9 U_M- nnnn[/['U5SSS9n5H*nUUnUR35 UR9S"5 M, SSS5 SSS5 U(a[RS#['U55 U $s snnnf![4a7nUR%US U35 [R7S!UU5 SnANSnAff=f!UR9S"5 f=f!,(df  N=f!,(df  N=f)$adDownload an entire repository (snapshot download). Parameters ---------- repo_id: Repository identifier (``owner/name``). repo_type: One of the :class:`~.constants.RepoType` values. revision: Branch, tag, or commit hash. cache_dir: Override for the default cache directory. local_dir: When set, download directly into this directory instead of cache. allow_patterns: Only files matching these globs will be downloaded. ignore_patterns: Files matching these globs will be skipped. max_workers: Number of parallel download threads. local_files_only: When ``True``, return the cached snapshot path without network. user_agent: Custom user-agent info for download headers. progress_callbacks: List of :class:`ProgressCallback` *classes* (not instances). Returns ------- Path Absolute path to the snapshot/local directory. Nz"Found legacy cache at %s, reusing.rFz2Cannot confirm the cached file is for revision: %srGrH)skillskills)rRrSrT output_dir)datasetdatasets)rRrTT)rRrSrT recursiverrNamer TypetypeblobtreeSha256rSizer2zNo files to download for %s@%szDownloading %d files from %s@%s)r) rRrSrrTrIrUrWr)rr Downloadingfile)rPrRrM: zFailed to download %s: %sr z%d file(s) failed to download)rrrKrwrzrLanyiterdirrxrr;_download_archiverlist_dataset_files_paginatedlist_repo_filesrrr<rrrsubmitr]r rresultrrr3)r*rRrSrTrIrUallow_patternsignore_patternsrrXrrrbrYrZfilesdownload_itemsrrftyperraw_sizer2errorsrfpfuturespbarfuturers r+ download_repoDownloadManager.download_repors\  #DO4J//INF! 8$ " ++G J'{(:X(EF :%%'((SU]^!!<j/   + +))#!% *  / /LL==!>E LL00#! 1EDFA55=HAEE&MHQUU6]HbDEE&M7JG^ K 8H)7)7$B&&#' %''$*")'9  )7 "C/m&QUY*73F B'   A4R%9:  NN:CK H?,%K Bsen5 %@"cJJK ARQ%9 8sl,O!32M/ %O!=OM6"O7O!/O!6 N7 -N2 -N:2N7 7N::O O O O!! O/cSSKnSSKnSSKnSnURR UUUS9n UR SSS9n [ U R5nU R[S9Hn U (dM U RU 5 M SSS5 URUS5n U RU5 SSS5 UR5V s/sHoPM nn [U5S :XauUSR5(a]USnUR5H4nUR![#U5[#UUR- 55 M6 UR%5 UbUR'S S 9 [(R+S X5 U$!,(df  GN=f!,(df  N=fs sn f!UbUR'S S 9 ff=f) zDownload a repo via its zip archive endpoint and extract. Skill repos do not support per-file ``/repo?FilePath=...`` download. The old SDK uses ``/archive/zip/{revision}`` for these. rN)rRrSrTz.zipF)rdeleterrr TrjzExtracted archive for %s to %s)shutiltempfilezipfilerdownload_archiveNamedTemporaryFilerrrr rZipFile extractallrqris_dirmover;rmdirryrwrz)r*rRrSrTrbrrrtmp_pathr tmprzfeentriesnesteditems r+rr!DownloadManager._download_archive s  $ 1<<00#!1D ,,F5,IS>!..:M.NEu %(OJ 3/2 j)0#-"4"4"67"6Qq"6G77|q WQZ%6%6%8%8 "NN,DKKD 3zDII/E+FG- #40 4gJ+JI 0/8#40$sM+F.1F0FF.F1F. F)BF. FF. F&" F..GcUR5(dgU(a?[US5nX!:wa[RSU5 g[RSU5 g[RSU5 g)z>Return True if *target* exists and passes optional hash check.FrzCache stale (hash mismatch): %szCache hit (hash verified): %sz Cache hit: %sT)rrrwr8)rrWactuals r+rMDownloadManager._cache_hit?s`}} !&(3F( >G LL8& A LL& 1r.cU=(d URRnURS5(dUS3OUnURSS5n[ XE- U- 5$)z-Compute the cache directory for a given repo.s/z--)rrIendswithrr)r*rRrSrIbasesegmentsafe_ids r+rLDownloadManager._repo_cache_dirNsW2DLL22)2););C)@)@YKq/i//#t,$.7233r.cU=(d URRnURS5(dUS3OUnURSS5n[ U5S:wagUupxUR SS5n XE- U- U - US- U- U- U - 4n U H=n U R 5(dM[U R55(aU s $M? g![a MOf=f) aCheck for old SDK (<=1.37) cache layout and return it if non-empty. Old SDKs encoded dots in the repo name as ``___`` and, when no ``MODELSCOPE_CACHE`` was set, stored everything under a ``hub/`` sub-directory of the cache root. Both historical layouts are probed, in priority order:: {base}/{type}s/{owner}/{name___} # MODELSCOPE_CACHE explicitly set {base}/hub/{type}s/{owner}/{name___} # default cache (~/.cache/modelscope/hub) e.g. ~/.cache/modelscope/hub/models/Qwen/Qwen3___5-0___8B/ Returns the first existing, non-empty candidate, or ``None`` when the cache is clean (so the caller falls back to the new layout). rrr rN.___hub) rrIrr.rrrrprqrv) r*rRrSrIrrpartsownerr safe_name candidates legacy_paths r+rK%DownloadManager._find_legacy_repo_dirZs*2DLL22)2););C)@)@YKq/i c1% u:? LLe, NU "Y . 5L7 "U *Y 6 &K%%'' {**,--&&. &  s*C CCcU=(d URRnURSS5nUb3URSS5RSS5nUS- USUSUS3- $US- USUS3- $)z4Compute the lock file path for a given repo or file.rrrrz.lock)rrIr)r*rRrSrIrrr safe_files r+rNDownloadManager._lock_paths2DLL22//#u-  !))#u5==c3GI'>yk7)1YKu$MM Mg~9+Qwiu ===r.rJc | USL=(a U[:=(a [S:n URU5n Sn UR5n U (aX4n UR UR R U 5nUcURRUUUU5nSnURR(aSURR0nURUU UU S9un nU R S5nUU4UR U 'SSS5 WcUR R U 5nUbUunnUbUU S'S S S S .Un U (aUceURRUUUU5nSnURR(aSURR0n/nU(aUVs/sH nU"X65PM nn[UUUU UUS 9 U$[U=(d /5nUVs/sHnU"X6=(d S5PM nn[!["SS/S9nUR%UR&S-5nSnUR)5(a4UR+5R,nUHnUR/U5 M [0R2"U 5n[4R6"5R8US'US:aSUS3US'[R;SU5 URR=UUUUUS9nURJR S5nU(a [MU5OSnURNS:Hn U (a U(aUU- nU (aSOS n!U (dSn[QUUS!SU [SU5RT3S"S#9n"[WUU!5n#URY[ZS$9HZn$U$(dM U#R]U$5 U"R/[_U$55 UHnUR/[_U$55 M M\ SSS5 SSS5 URaU5 UHnURc5 M [R;S%U5 U$![a2n[RSU5 SUR U 'SnSnAGNSnAff=f!,(df  GN=fs snfs snf![>R@an[CSUSU35UeSnAf[>RDan[GSUSU35UeSnAf[>RHan[GSUSU35UeSnAff=f!,(df  GN4=f!,(df  GN>=f![d[f4a e[aBnURiSUUS&9n[RS'UU5 URk5 SnAOSnAff=fGM)(z9Download a file with HTTP Range resume support and retry.Nr r  m_session_id)r9r5zIFailed to resolve inter-region acceleration: %s. Falling back to default.)Nr4u⚡ u⇄ z )r6r7r4)rrr)rrrrrrz .incompleteTrrrrzResuming download from byte %d)rRrSrrTrzDownload timed out for rozDownload connection failed for zDownload failed for zContent-LengthabrrKF)rPrQrMrNrRrSrzDownloaded: %srz&Download failed for %s: %s, will retry)6r rrCr1rrrrget_download_urltokenr>rrwrxrrr rrrrrtst_sizer3rrrrrr8download_streamrrcrConnectionErrorrrrr<r'r rrrrr rrrr8rrrr)%r*rRrSrrTrr)rr use_paralleldownload_headers source_prefixr9 cache_keycached probe_urlrsourceresolved_regionrr cb_instancescls cb_classesrr existing_sizer extra_headersr content_length total_size is_resumedmoderfhrs% r+rP%DownloadManager._download_with_resumes!,s=X1Xs]ors]s 77 C  446  ,I((1155i@>3$(LL$A$A#%%$ % #'<<--'5t||7I7I&JG373U3U%,#)5 4V40(& +;*>*>?S*T?NPV>W00;-)>~1155i@!*0'".=L$%9:&%#! ! ( ((,,// C G||!!)4<<+=+=>L!EWXEWcI 9EW X #(#/  M,23 BLM*3I~A6* M&"G  %%fmmm&CDB  ! ??$$$,MMO$;$;M* -0+15 >N0O 04 0@0@ n- 1$/5m_A-FM'*LL!A=Q [<<77 '"+"+!) - 8D"&!1!12B!C4BS0 !--4 *-/J)tt!$%M$)#)?4 ?+?+?*@A h-%)%6%6BU%6%VE$u " $ CJ 7*6B$&IIc%j$9+7 &W.   (&BFFH' -v6 m%3g?P00;!2 3/)(t YN> ''e-0G {RTUXTY.Z[add//f&)H SUVYUZ'[\bee00[&)=i[3%'PQWZZ[,.-,"#89  yDGTWX  AsR>B Q3R./R3r?r')rdict | str | Noner>r;)r>r;)rr;r>r)Ng@) rr;rdict[str, str]r dict | Nonerirr>r;)r>z list[str])NN) rr;rrrrr9list[str] | Noner>ztuple[dict[str, str], str])rrr>r) masterNNFNFNNN)rRr;rSr;rr;rTr;rI Path | NonerUrrVrrW str | NonerXrr) int | Nonerrr#list[type[ProgressCallback]] | Noner>r) rNNNNFNN)rRr;rSr;rTr;rIrrUrrwrrxrrr<rXrrrrrr>r) rRr;rSr;rTr;rbrr>r)rrrWrr>r)rRr;rSr;rIrr>r)rRr;rSr;rIrr>r) rRr;rSr;rIrrrr>r)rRr;rSr;rr;rTr;rrr)rrrrrr>r)rrrWr;r>r)rArBrCrDrEr,rrrecompiler staticmethodr!r(r1r>rCr]rrrrMrLrKrNrPrQrFr0r.r+rrHs 3 Dzz"GH B B $    *H $)- -" -" -" -" ' -" $ -"b)-% :!!%!%&*!& $(,BFyyy y  y  yyy$yyy&y@y y~!!%!%+/,0!&(,BFVVV V  V  V)V*VVV&V@V Vv--- -  -  -d  $"& 4 4 4 4  4 "& ((( (  (\"& $ > > > >  >  >.!%(,BFmmm m  m  mm&m@m m^ r.r)rrr_r)r>r)rr;rrr>r)rtupler>r?r')rr;rrr)r<rzdict[str, str] | Nonerrrzlist[ProgressCallback] | Noner>r;)CrE __future__r contextlibrr|rrrrrrrsrconcurrent.futuresrrpathlibrtypingr urllib.parserr tqdm.autor urllib3.util.retryr rr r rrrrrrrrr}rrrrrrutils.file_utilsrr utils.loggerr _legacy_apirrr rwrOr$rHrrcontextmanagerrrrrrrr0r.r+rs'"#   ? !$   7$)! J    &#2 CGIIX**)d9= 0# 0# 0#0## 0#  0# 6 0# 0#lD D r.