sh-SSKrSSKrSSKJrJr SSKJr SSKJr SSK J r J r J r SSK Jr SSKJr SSKJrJrJr \ (aSS KJr S S /r"S S \5r"SS \5r"SS \5rg)N) GeneratorSequence)contextmanager)Path)Optional TYPE_CHECKINGUnion) url_to_fs)StreamTransformExtension)FileSystemBaseFileSystemReaderFileSystemWriter)AbstractFileSystem FsspecWriter FsspecReaderc 8\rSrSrSSjr\S\\\R4S\S\ \ RSS44Sj5r S\\\R4S\S\\\R44S jrS\\\R4S\\\R44S jrS\\\R4S \\\R4SS4S jrS\\\R4SS4S jr\S\\\R4S\4Sj5rS\\\R4S\4SjrS\\\R4SS4SjrSrg) FileSystemreturnNcSUlgNfs)selfs ڃ/Users/tiagomarins/Projetos/claudeai/copy_bank/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..1s2EbTzEszw+a)rosfspathopenanyrm_file)rrr streams ` r create_streamFileSystem.create_stream#sww"""yy WW\\$ %  & % 2E222 T*& %sHAB BA B B 2BB BB  B BB suffixc@[RRX5$r)r(rjoin)rrr0s r concat_pathFileSystem.concat_path8sww||D))rc .[U40UD6uUlnU$r)r r)rrkwargs_s r init_pathFileSystem.init_path=st.v.  rnew_pathc:URRX5 gr)rrename)rrr:s rr<FileSystem.renameCs t&rc8URRUSS9 g)NT)exist_ok)rmakedirsrrs rmkdirFileSystem.mkdirHs -r checkpoint_idch[U[5(ag[U5 g![a gf=f)NFT) isinstancerr ValueErrorclsrDs rvalidate_checkpoint_id!FileSystem.validate_checkpoint_idKs8 mT * *  m $  s $ 11c8URRU5$r)rexistsrAs rrMFileSystem.existsWsww~~d##rc:URRU5 gr)rrmrAs rr,FileSystem.rm_fileZs  4rr)rN)__name__ __module__ __qualname____firstlineno__rrr strr(PathLikerioIOBaser.r3r8r<rB classmethodboolrJrMr,__static_attributes__r#rrrrs5#r{{*+36 299dD( )(*#r{{*+*58* sBKK * #r{{*+ sBKK  '#r{{*+'7[T U]UUUUUUUS9 [5UlURR"U40UD6Ulg)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. )rcrdNsuperrrrr8r) rrr_r`rarbrcrdr6 __class__s rrFsspecWriter.__init__msR2     !#  ,GG%%d5f5 rrDc,[RU5$rrrJrHs rrJ#FsspecWriter.validate_checkpoint_id00??rrr)TTiTN)rRrSrTrU__doc__r rVr(rWr[intrrr rrZrJr\ __classcell__rhs@rrr_s  &*%/DH#6C$%#6##6 #6  #6 # #6#6h'?@A#6 #6#6J@5bkk9I3J@t@@rc^\rSrSrS\\\R4SS4U4Sjjr\ S\\\R4S\ 4Sj5r Sr U=r $) rrrNc >[TU]U5 [5UlURR"U40UD6Ulgrrf)rrr6rhs rrFsspecReader.__init__s4 ,GG%%d5f5 rrDc,[RU5$rrkrHs rrJ#FsspecReader.validate_checkpoint_idrmrrn)rRrSrTrUr rVr(rWrrZr[rJr\rrrss@rrrsX6U3 #34646 @5bkk9I3J@t@@r)rXr(collections.abcrr contextlibrpathlibrtypingrrr fsspec.corer 'torch.distributed.checkpoint._extensionr 'torch.distributed.checkpoint.filesystemr r rfsspecr__all__rrrr#rrrso /%11!L)  <<@5@#5@p@#@r