/usr/local/lib/python3.6/site-packages/fsspec/implementations/__pycache__
Edit: /usr/local/lib/python3.6/site-packages/fsspec/implementations/__pycache__/dvc.cpython-36.pyc (2622B)
3
8%Egl ã @ sB d dl Z d dlZd dlmZ d dlmZ eƒ ZG dd„ deƒZdS )é N)ÚLocalFileSystem)ÚAbstractFileSystemc sR e Zd ZdZdZd‡ fdd„ Ze‡ fdd„ƒZdd d
„Zd d „ Z ddd„Z
‡ Z S )Ú
DVCFileSystemzÔDVC backend (experimental)
Load data files that are versioned using the `Data Version Control`_ system
.. _Data Version Control: https://dvc.org/
This interface is incomplete and experimental.
Ú Nc s, t ƒ jf |Ž tjj|ƒ| _| jjƒ | _dS )zœ
Parameters
----------
path: str (optional)
Location of the repo to access; defaults to the current directory.
N)ÚsuperÚ__init__ÚdvcÚrepoZRepoZ find_rootÚpath)Úselfr
Úkwargs)Ú __class__© úD/usr/local/lib/python3.6/site-packages/fsspec/implementations/dvc.pyr s zDVCFileSystem.__init__c s t ƒ j|ƒjdƒS )Nú/)r Ú_strip_protocolÚlstrip)Úclsr
)r
r r r # s z DVCFileSystem._strip_protocolFc sô | j ˆ ƒ‰ | jjjtjj| jjˆ ƒƒ}t|ƒ\}}}‡ fdd„|| D ƒ}g } xŽ|D ]†}
tjj| jj|
ƒ} t j
| ƒ} t j | ƒrŠ| j | ƒ nDy| jj
| ƒjƒ }
W n tjjk
r¸ wTY nX | j tf |
| —Žƒ |
| d d< qTW |ræ| S dd„ | D ƒS )Nc s g | ]}t jjˆ |ƒ‘qS r )Úosr
Újoin)Ú.0Úf)r
r r ú
+ s z$DVCFileSystem.ls..é Únamec S s g | ] }|d ‘qS )r r )r Údr r r r < s éÿÿÿÿ)r r ÚtreeÚwalkr r
r Úroot_dirÚnextÚlfsÚinfoÚisdirÚappendZfind_out_by_relpathZdumpdr Ú
exceptionsZOutputNotFoundErrorÚdict)r r
Zdetailr ÚallfilesÚdirnameÚdirsÚfilesÚoutÚdetailsr ÚfullÚ file_infoÚextrar )r
r Úls' s&
zDVCFileSystem.lsc C s | j |ƒd S )NÚmd5)r" )r r
r r r Úukey> s zDVCFileSystem.ukeyÚrbTc K s | j |ƒ}| jj|ƒS )N)r r Zopen_by_relpath)r r
ÚmodeÚ
block_sizeZ
autocommitZ
cache_optionsr r r r Ú_openA s
zDVCFileSystem._open)N)F)r3 NTN) Ú__name__Ú
__module__Ú __qualname__Ú__doc__Z root_markerr Ú classmethodr r0 r2 r6 Ú
__classcell__r r )r
r r s
r ) r Zdvc.repor Z fsspec.implementations.localr Z fsspec.specr r! r r r r r Ú s