ó
    ÷“,j~
  ã                   ó|   • S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKJr  S rS r	S r
S rS rS rSS	 jrS
 rg)é    N)Útqdmc           	      ó&  • [         R                  " SSSXSS/[         R                  [         R                  S9nUR                  S:w  a3  [        R
                  " SUR                  R                  S	5       35        g
[        R                  " S5        g)NÚawsÚs3Úsyncz	--excludez*epoch_latest.pt)ÚstdoutÚstderrr   z%Error: Failed to sync with S3 bucket zutf-8Fz"Successfully synced with S3 bucketT)	Ú
subprocessÚrunÚPIPEÚ
returncodeÚloggingÚerrorr	   ÚdecodeÚinfo)Ú	local_dirÚ
remote_dirÚresults      Ú¨C:\Users\johnn\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.13_qbz5n2kfra8p0\LocalCache\local-packages\Python313\site-packages\open_clip_train/file_utils.pyÚremote_sync_s3r   
   s�   € ä�^Š^˜U D¨&°)ÈÐVhÐiÔr|÷  sBñ  sBô  KU÷  KZñ  KZñ  [€FØ×Ñ˜AÓÜ�ŠÐ=¸f¿m¹m×>RÑ>RÐSZÓ>[Ð=\Ð]Ô^Øä‡L‚LÐ5Ô7Øó    c                 óÔ  • [         R                  " U 5      n[         R                  " U5      nU H‚  nSU;   a  M  [        R                  " SU 35        XC;   a8  [	        X$   5      [	        X4   5      :X  a  [        R
                  " SU S35        Ma   [        R                  " SU S35        X$   X4'   M„     g	! [         a'  n[        R                  " SU SU 35         S nA  gS nAff = f)
Nzepoch_latest.ptzAttempting to sync zSkipping remote sync for Ú.zSuccessful sync for zError during remote sync for z: FT)ÚfsspecÚ
get_mapperr   r   ÚlenÚdebugÚ	Exception)r   r   ÚaÚbÚkÚes         r   Úremote_sync_fsspecr#      sÔ   € ä×Ò˜)Ó$€AÜ×Ò˜*Ó%€Aãˆà Ó!Ùä�ŠÐ*¨1¨#Ð.Ô/Ø‹6”c˜!™$“i¤3 q¡t£9Ó,Ü�MŠMÐ5°a°S¸Ð:Ô;Ùð	Ü�LŠLÐ/°¨s°!Ð4Ô5Ø‘4ˆA‹Dñ ð" øô	 ó 	Ü�LŠLÐ8¸¸¸2¸a¸SÐAÔBÝûð	ús   Â B6Â6
C'Ã C"Ã"C'c                 ó    • [         R                  " S5        US:X  a  [        X5      $ US:X  a  [        X5      $ [         R                  " S5        g)NzStarting remote sync.r   r   zRemote protocol not knownF)r   r   r   r#   r   )r   r   Úprotocols      r   Úremote_syncr&   ,   sE   € Ü‡L‚LÐ(Ô)Ø�4ÓÜ˜iÓ4Ð4Ø	�XÓ	Ü! )Ó8Ð8ä�ŠÐ1Ô2Ør   c                 óL   •  [         R                  " U 5        [        XU5        M$  ©N)ÚtimeÚsleepr&   )Ú
sync_everyr   r   r%   s       r   Úkeep_running_remote_syncr,   6   s    € Ø
Ü�
Š
�:ÔÜ�I¨8Ô4ñ r   c                 ó<   • [         R                  " [        XX#4S9nU$ )N)ÚtargetÚargs)ÚmultiprocessingÚProcessr,   )r+   r   r   r%   Úps        r   Ústart_sync_processr3   ;   s    € Ü×ÒÔ'?ÀzÐ^hÐFsÑt€AØ€Hr   c                 ó–   • [         R                  " US5      nU n[        R                  " X5        S S S 5        g ! , (       d  f       g = f)NÚwb)r   ÚopenÚtorchÚsave)Úpt_objÚ	file_pathÚofÚfs       r   Úpt_saver=   @   s-   € Ü	�Š�Y Ó	%€BÙ	ˆqÜ�
Š
�6Ô%÷ 
�Žús	   š:º
Ac                 óî   • U R                  S5      (       a  [        R                  " S5        [        R                  " U S5      nU n[
        R                  " X1S9nS S S 5        U$ ! , (       d  f       W$ = f)Nr   z0Loading remote checkpoint, which may take a bit.Úrb)Úmap_location)Ú
startswithr   r   r   r6   r7   Úload)r:   r@   r;   r<   Úouts        r   Úpt_loadrD   E   sZ   € Ø×Ñ˜D×!Ñ!Ü�ŠÐGÔHÜ	�Š�Y Ó	%€BÙ	ˆqÜ�jŠj˜Ñ6ˆ÷ 
à€J÷ 
Œà€Jús   ÁA%Á%
A4c                 óˆ   •  [         R                  " U 5          S S S 5        g! , (       d  f       g= f! [         a     gf = f)NFT)r   r6   ÚFileNotFoundError)r:   s    r   Úcheck_existsrG   M   sA   € ðÜ�[Š[˜Õ#Ø÷ $ð ÷	 $Ô#ð ûô ó Ùðús#   ‚4 ˜#š4 £
1­4 ±4 ´
AÁ Ar(   )r   Úosr0   r
   r)   r   r7   r   r   r#   r&   r,   r3   r=   rD   rG   © r   r   Ú<module>rJ      sE   ðÛ Û 	Û Û Û Û Û Ý òòò0ò5ò
ò
&ô
ór   