8hSSKrSSKrSSKJrJr SSKJr SSKJr SSK J r J r J r SSK Jr SSKJr SSKJrJrJrJr \ (aSS KJr S S /r"S S \5r"SS \5r"SS \5rg)N) GeneratorSequence)contextmanager)Path)Optional TYPE_CHECKINGUnion) url_to_fs)StreamTransformExtension)FileSystemBaseFileSystemReaderFileSystemWriterSerializationFormat)AbstractFileSystem FsspecWriter FsspecReaderc n\rSrSrSSjr\S\\\R4S\S\ \ RSS44Sj5r S\\\R4S\S\\\R44S jrS\\\R4S\\\R44S jrS\\\R4S \\\R4SS4S jrS\\\R4SS4S jr\S\\\R4S\4Sj5rS\\\R4S\4SjrS\\\R4SS4SjrS\\\R4S\\4SjrSrg) FileSystem returnNcSUlgNfs)selfs i/var/www/fran/franai/venv/lib/python3.13/site-packages/torch/distributed/checkpoint/_fsspec_filesystem.py__init__FileSystem.__init__!s 04pathmodec#D^# URce[R"U5nURRUT5nUv SSS5 g! [ U4SjS55(aUR U5 e! e=fe=f!,(df  g=f7f)Nc3,># UH oT;v M g7fr).0chr!s r +FileSystem.create_stream..2s2EbTzEszw+a)rosfspathopenanyrm_file)rr r!streams ` r create_streamFileSystem.create_stream$sww"""yy WW\\$ %  & % 2E222 T*& %sHAB BA B B 2BB BB  B BB suffixc@[RRX5$r)r)r join)rr r1s r concat_pathFileSystem.concat_path9sww||D))rc .[U40UD6uUlnU$r)r r)rr kwargs_s r init_pathFileSystem.init_path>st.v.  rnew_pathc:URRX5 gr)rrename)rr r;s rr=FileSystem.renameDs t&rc8URRUSS9 g)NT)exist_ok)rmakedirsrr s rmkdirFileSystem.mkdirIs -r checkpoint_idch[U[5(ag[U5 g![a gf=f)NFT) isinstancerr ValueErrorclsrEs rvalidate_checkpoint_id!FileSystem.validate_checkpoint_idLs8 mT * *  m $  s $ 11c8URRU5$r)rexistsrBs rrNFileSystem.existsXsww~~d##rc:URRU5 gr)rrmrBs rr-FileSystem.rm_file[s  4rc6URRUSS9$)NF)detail)rlsrBs rrU FileSystem.ls^swwzz$uz--rr)rN)__name__ __module__ __qualname____firstlineno__rrr strr)PathLikerioIOBaser/r4r9r=rC classmethodboolrKrNr-listrU__static_attributes__r$rrrr s5#r{{*+36 299dD( )(*#r{{*+*58* sBKK * #r{{*+ sBKK  '#r{{*+'7[T U]UUUUUUUUS9 [5UlURR"U40U D6Ulg)a Initialize the writer pointing to `path`. Args: path: directory where the checkpoint will be written to. single_file_per_rank: Produce one file per rank instead of one file per tensor/blob. Default to True. sync_files : force files to be synced to permanent storage. Default to True. thread_count: Number of IO threads to use to write. Default to 1. per_thread_copy_ahead: How many bytes to copy from the GPU ahead of saving then. Default 10Mb. overwrite: Whether to allow overwriting existing checkpoints. Defaults to True. _extensions: Extensions to apply to output streams (EXPERIMENTAL) N. B. If sync_files is disabled, there's no guarantee that the checkpoint will be consistent in the case of a failure. )rjrkrlNsuperrrrr9r ) rr rfrgrhrirjrkrlr7 __class__s rrFsspecWriter.__init__ssU4     !#!5  ,GG%%d5f5 rrEc,[RU5$rrrKrIs rrK#FsspecWriter.validate_checkpoint_id00??rrr )rWrXrYrZ__doc__r TORCH_SAVEr r[r)r\r`intrrr rr_rKrb __classcell__rps@rrres  &*%/DH4G4R4R%6C$%%6#%6 %6  %6 # %6%6h'?@A%62%6 %6%6N@5bkk9I3J@t@@rc^\rSrSrS\\\R4SS4U4Sjjr\ S\\\R4S\ 4Sj5r Sr U=r $) rr rNc >[TU]U5 [5UlURR"U40UD6Ulgrrn)rr r7rps rrFsspecReader.__init__s4 ,GG%%d5f5 rrEc,[RU5$rrsrIs rrK#FsspecReader.validate_checkpoint_idrurrv)rWrXrYrZr r[r)r\rr_r`rKrbrzr{s@rrrsX6U3 #34646 @5bkk9I3J@t@@r)r]r)collections.abcrr contextlibrpathlibrtypingrrr fsspec.corer 'torch.distributed.checkpoint._extensionr 'torch.distributed.checkpoint.filesystemr r rrfsspecr__all__rrrr$rrrsq /%11!L)  A.A.J7@#7@t@#@r