FM / __pycache_

/usr/local/lib/python3.6/site-packages/fsspec/implementations/__pycache__/

/usr/local/lib/python3.6/site-packages/fsspec/implementations/__pycache__

Name	Size	Mode	Actions
arrow.cpython-36.pyc	7328	0644	edit dl rm
cached.cpython-36.pyc	23030	0644	edit dl rm
dask.cpython-36.pyc	4656	0644	edit dl rm
dbfs.cpython-36.pyc	13351	0644	edit dl rm
dvc.cpython-36.pyc	2622	0644	edit dl rm
ftp.cpython-36.pyc	10444	0644	edit dl rm
git.cpython-36.pyc	3750	0644	edit dl rm
github.cpython-36.pyc	7404	0644	edit dl rm
hdfs.cpython-36.pyc	7093	0644	edit dl rm
http.cpython-36.pyc	20752	0644	edit dl rm
jupyter.cpython-36.pyc	4131	0644	edit dl rm
libarchive.cpython-36.pyc	6005	0644	edit dl rm
local.cpython-36.pyc	11912	0644	edit dl rm
memory.cpython-36.pyc	6697	0644	edit dl rm
reference.cpython-36.pyc	16142	0644	edit dl rm
sftp.cpython-36.pyc	6104	0644	edit dl rm
smb.cpython-36.pyc	10591	0644	edit dl rm
tar.cpython-36.pyc	4502	0644	edit dl rm
webhdfs.cpython-36.pyc	14712	0644	edit dl rm
zip.cpython-36.pyc	3276	0644	edit dl rm
__init__.cpython-36.pyc	156	0644	edit dl rm

Edit: /usr/local/lib/python3.6/site-packages/fsspec/implementations/__pycache__/local.cpython-36.pyc (11912B)

3 8%Eg�,�@s�ddlZddlZddlZddljZddlZddlZddlZddl Z ddl Z ddlmZddl mZddlmZddlmZGdd�de�Zejfdd �ZGd d�dej�ZdS)�N)�AbstractFileSystem)�compr)�get_compression)�stringify_pathcs�eZdZdZdZdZdZd4�fdd� Zd5dd �Zd6d d�Z dd �Z d7dd�Z�fdd�Zdd�Z dd�Zdd�Zd8dd�Zd9dd�Zdd�Zdd �Zd:d!d"�Zd;d$d%�Zd&d'�Zd(d)�Zd*d+�Zed,d-��Zed.d/��Zd0d1�Zd2d3�Z�ZS)<�LocalFileSystemaInterface to files on local storage Parameters ---------- auto_mkdir: bool Whether, when opening a file, the directory containing it should be created (if it doesn't already exist). This is assumed by pyarrow code. �/�fileTFcst�jf|�||_dS)N)�super�__init__� auto_mkdir)�selfr�kwargs)� __class__��F/usr/local/lib/python3.6/site-packages/fsspec/implementations/local.pyr szLocalFileSystem.__init__cKsB|j|�}|j|�rt|��|r0|j|dd�ntj|f|�dS)NT)�exist_ok)�_strip_protocol�exists�FileExistsError�makedirs�os�mkdir)r�pathZcreate_parentsr rrrr$s zLocalFileSystem.mkdircCs|j|�}tj||d�dS)N)r)rrr)rrrrrrr-s zLocalFileSystem.makedirscCs|j|�}tj|�dS)N)rr�rmdir)rrrrrr1s zLocalFileSystem.rmdirc sP�j��|r4tj��}�fdd�|D�SQRXn�fdd�tj��D�SdS)Ncsg|]}�j|��qSr)�info)�.0�f)rrr� 9sz&LocalFileSystem.ls..csg|]}tj�|��qSr)� posixpath�join)rr)rrrr;s)rr�scandir�listdir)rrZdetailr �itr)rrr�ls5s zLocalFileSystem.lscs|j|�}t�j|f|�S)N)rr �glob)rrr )rrrr$=s zLocalFileSystem.globc Ks@t|tj�rV|jdd�}|j�}|jdd�r2d}n|jdd�rDd}nd}|j|j�}n^|j|�}tj|dd�}tj |j �}|r�tj|dd�}tj|j �r�d}ntj|j �r�d}nd}||j ||j|d�}xdD]}t|d|�||<q�W|d �r�sz"make_path_posix..�~r�\�:z\\z /[A-Za-z]:roNz [A-Za-z]:z//)r2�list�set�tupler*rF� expanduserrtrr[�seprurZ�re�match�replace�lstrip)rr�rrrru�s. ruc@s�eZdZd2dd�Zdd�Zdd�Zd d �Zdd�Zd d�Zdd�Z e d�dd�Ze d�dd�Zdd�Z dd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�Zed&d'��Zd(d)�Zd*d+�Zd,d-�Zd.d/�Zd0d1�ZdS)3rdTNcKs>||_||_||_d|_||_t||�|_tj|_ |j �dS)N)rr-rcr� autocommitr�compression�io�DEFAULT_BUFFER_SIZE� blocksizerf)rrr-r�rcr�r rrrr �szLocalFileOpener.__init__cCs�|jdks|jjr�|js"d|jkrXt|j|jd�|_|jr�t|j}||j|jd�|_n,tj �\}}t j|�||_t||jd�|_d|jkr�|jj dd�|_|jj d�|j|j_dS)Nrb)r-r�)r�closedr�r-rirr�r�tempfile�mkstemprrj�temp�seekr))r�compress�ir(rrrrf�s zLocalFileOpener._opencCs2d|jkrt�|j�|jj|�|jj||�S)N�r)r-r\rfrr��read)r�start�endrrr�_fetch_ranges zLocalFileOpener._fetch_rangecCsHd|_|jdd�}|jj|�d|dkrDd|_|j�|jj|�dS)N�locr�r-)r�pop�__dict__�updaterfr�)r�stater�rrr�__setstate__szLocalFileOpener.__setstate__cCsB|jj�}|jd�d|jkr.|jj�|d<n|jjs>td��|S)Nrr�r�z+Cannot serialise open write-mode local file)r��copyr�r-r�tellr�r\)r�drrr�__getstate__s zLocalFileOpener.__getstate__cCs"|jrtd��tj|j|j�dS)Nz0Can only commit if not already set to autocommit)r��RuntimeErrorrKrUr�r)rrrr�commit)szLocalFileOpener.commitcCs|jrtd��tj|j�dS)Nz#Cannot discard if set to autocommit)r�r�rrWr�)rrrr�discard.szLocalFileOpener.discard)�returncCsdS)NTr)rrrr�readable3szLocalFileOpener.readablecCs d|jkS)Nr�)r-)rrrr�writable6szLocalFileOpener.writablecOs|jj||�S)N)rr�)r�argsr rrrr�9szLocalFileOpener.readcOs|jj||�S)N)r�write)rr�r rrrr�<szLocalFileOpener.writecOs|jj||�S)N)rr�)rr�r rrrr�?szLocalFileOpener.tellcOs|jj||�S)N)rr�)rr�r rrrr�BszLocalFileOpener.seekcOs|jj||�S)N)r�seekable)rr�r rrrr�EszLocalFileOpener.seekablecOs|jj||�S)N)r�readline)rr�r rrrr�HszLocalFileOpener.readlinecOs|jj||�S)N)r� readlines)rr�r rrrr�KszLocalFileOpener.readlinescCs |jj�S)N)rrj)rrrrrjNszLocalFileOpener.closecCs|jjS)N)rr�)rrrrr�QszLocalFileOpener.closedcCs|jS)N)r)rrrr� __fspath__UszLocalFileOpener.__fspath__cCs |jj�S)N)r�__iter__)rrrrr�YszLocalFileOpener.__iter__cCst|j|�S)N)r>r)r�itemrrr�__getattr__\szLocalFileOpener.__getattr__cCsd|_|jj�S)NT)� _incontextr� __enter__)rrrrr�_szLocalFileOpener.__enter__cCsd|_|jj|||�dS)NF)r�r�__exit__)r�exc_type� exc_value� tracebackrrrr�cszLocalFileOpener.__exit__)TNN)rxryrzr rfr�r�r�r�r��boolr�r�r�r�r�r�r�r�r�rj�propertyr�r�r�r�r�r�rrrrrd�s. rd)rlr�r�os.pathrrFrr�rKr4r�ZfsspecrZfsspec.compressionrZfsspec.corerZfsspec.utilsrrr�ru�IOBaserdrrrr�s 8'