ó
¦–Õ\c           @` s  d  d l  m Z m Z m Z d  d l Z d  d l Z d  d l m Z d  d l Z d  d l	 Z	 d  d l
 m Z m Z m Z d  d l m Z d  d l m Z m Z d  d l m Z d  d l m Z d  d	 l m Z d  d
 l m Z m Z m Z m Z m Z e e d d ƒZ i d d 6d d 6Z i d d 6d d 6d d 6Z  y d  d l! Z! d „  Z" Wn8 e# e$ f k
 rŠd  d l% Z% d  d l& Z& d „  Z" n Xd „  Z' d „  Z( d „  Z) e	 j* j+ e j, dM k  d d ƒd  „  ƒ Z- d! „  Z. d" „  Z/ d# „  Z0 d$ „  Z1 d% „  Z2 d& „  Z3 e	 j* j4 d' d( d) g ƒ d* „  ƒ Z5 d+ „  Z6 d, „  Z7 d- „  Z8 e	 j* j+ e j9 d. k d d/ ƒd0 „  ƒ Z: d1 „  Z; d2 „  Z< g  e j D] Z= e= d f ^ q‹g  e j? D] Z= e= d3 f ^ qªZ@ e	 j* j4 d4 e@ ƒ d5 „  ƒ ZA d6 „  ZB e	 j* j4 d7 d8 d9 g ƒ d: „  ƒ ZC e	 j* j4 d; d< d= g ƒ e	 j* j4 d> eD e j ƒ ƒ d? „  ƒ ƒ ZE e	 j* j4 d> eD e j? ƒ ƒ d@ „  ƒ ZF dA „  ZG dB „  ZH e	 j* jI dC „  ƒ ZJ e	 j* j4 dD d eK f dE e jK f g ƒ dF „  ƒ ZL dG „  ZM dH „  ZN dI „  ZO dJ eP f dK „  ƒ  YZQ dL „  ZR d S(N   i    (   t   print_functiont   divisiont   absolute_importN(   t   sleep(   t   concatt   valmapt   partial(   t   compute(   t   FileNotFoundErrort   unicode(   t	   filetexts(   t   compression(   t   LocalFileSystem(   t
   read_bytest
   open_filest   get_pyarrow_filesystemt   logical_sizet   get_fs_token_pathst	   schedulert   syncs…   {"amount": 100, "name": "Alice"}
{"amount": 200, "name": "Bob"}
{"amount": 300, "name": "Charlie"}
{"amount": 400, "name": "Dennis"}
s   .test.accounts.1.jsons…   {"amount": 500, "name": "Alice"}
{"amount": 600, "name": "Bob"}
{"amount": 700, "name": "Charlie"}
{"amount": 800, "name": "Dennis"}
s   .test.accounts.2.jsons   a,b
1,2
s   .test.fakedata.1.csvs   a,b
3,4
s   .test.fakedata.2.csvs   a,b
5,6
s   subdir/.test.fakedata.2.csvc         C` s   t  j t j j |  ƒ ƒ j ƒ  S(   N(   t   pathlibt   Patht   ost   patht   abspatht   as_uri(   R   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   to_uri+   s    c         C` s%   t  j d t j t j j |  ƒ ƒ ƒ S(   Ns   file:(   t   urlparset   urljoint   urllibt   pathname2urlR   R   R   (   R   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyR   1   s    c   
      C` s  t  |  ƒ }  g  t d ƒ D] } t j j |  d | ƒ ^ q } x7 | D]/ } t | d ƒ  } | j d d ƒ Wd  QXqE Wt j d k r d n d } | t j j |  d	 ƒ } t	 | ƒ \ } } } | | k sÓ t
 ‚ t	 g  | D] }	 | |	 ^ qÝ ƒ \ } } } | | k st
 ‚ d  S(
   Ni   s   test.%02d.csvt   wbs   1,2,3
i
   t   win32s   file:///s   file://s
   test.*.csv(   t   strt   rangeR   R   t   joint   opent   writet   syst   platformR   t   AssertionError(
   t   tmpdirt   it   pathsR   t   ft   protocolt   urlpatht   _t   paths2t   p(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt&   test_urlpath_inference_strips_protocol6   s    2,c          C` sç   t  j t ƒ  }  t g  ƒ Wd  QXd t |  ƒ k s: t ‚ t  j t ƒ  }  t d d g ƒ Wd  QXd t |  ƒ k sz t ‚ t  j t ƒ  }  t d d g ƒ Wd  QXd t |  ƒ k sº t ‚ t  j t ƒ  t d d d	 h ƒ Wd  QXd  S(
   Nt   emptys   s3://test/path.csvs   /other/path.csvs   same protocol and optionss$   hdfs://myuser@node.com/test/path.csvs(   hdfs://otheruser@node.com/other/path.csvs   sets/are.csvs   unordered/so/they.csvs   should/not/be.csvallowed.csv(   t   pytestt   raisest
   ValueErrorR   R!   R(   t	   TypeError(   t   err(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_urlpath_inference_errorsI   s    	c          C` sz   t  t d d ƒb t d ƒ \ }  }  } t | ƒ d k s@ t ‚ t d g ƒ \ }  }  } t | ƒ d k sp t ‚ Wd QXd S(   s3   Make sure * is expanded in file paths when reading.t   modet   bs   .*.csvi   N(   R
   t	   csv_filesR   t   lenR(   (   R/   R+   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_urlpath_expand_read`   s
    i   i   t   reasons#   Recursive glob is new in Python 3.5c          C` sJ   t  t d d ƒ2 t d ƒ \ }  }  } t | ƒ d k s@ t ‚ Wd QXd S(   s3   Make sure * is expanded in file paths when reading.R:   R;   s	   **/.*.csvi   N(   R
   R<   R   R=   R(   (   R/   R+   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_recursive_glob_expandj   s    c       
   C` s¶   t  d d d d d ƒ\ }  }  } | d d g k s9 t ‚ t  d g d d d d ƒ\ }  }  } | d d g k su t ‚ t j t ƒ , t  d d	 g d d d d ƒ\ }  }  } Wd
 QXd
 S(   s3   Make sure * is expanded in file paths when writing.s   prefix-*.csvR:   R   t   numi   s   prefix-0.csvs   prefix-1.csvs   prefix1-*.csvs   prefix2-*.csvN(   R   R(   R4   R5   R6   (   R/   R+   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_urlpath_expand_writes   s    !$c          C` s5  t  t d d ƒt d ƒ \ }  } t |  t ƒ s: t ‚ |  d  t t t ƒ d d  k sb t ‚ |  j d ƒ sw t ‚ t | t t	 f ƒ s’ t ‚ t | d t t	 f ƒ s± t ‚ t
 | d d d ƒ sÎ t ‚ t t t | ƒ ƒ t t ƒ k sõ t ‚ t t | ƒ Œ  } t | ƒ t t j ƒ  ƒ k s+t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*i   i    s   
t   dask(   R
   t   filesR   t
   isinstancet   bytesR(   t   sortedt   endswitht   listt   tuplet   hasattrt   sumt   mapR=   R   R   t   sett   values(   t   sampleRO   t   results(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_read_bytes~   s    ('c       
   C` s¶   t  t d d ƒž t d d d d d ƒ\ }  } |  j d ƒ sF t ‚ t d d d d d ƒ\ }  } |  j d ƒ sy t ‚ t d d d	 d d ƒ\ }  } |  j d ƒ s¬ t ‚ Wd  QXd  S(
   NR:   R;   s   .test.accounts.*RP   iP   t	   delimiters   
s   .test.accounts.1.jsoni   (   R
   RD   R   RH   R(   (   RP   RO   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt    test_read_bytes_sample_delimiterŽ   s    			c          C` sM   t  t d d ƒ5 t d d d ƒ\ }  } t |  ƒ d k sC t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*RP   s   40 Bi(   (   R
   RD   R   R=   R(   (   RP   RO   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_parse_sample_bytes›   s    c          C` sG   t  t d d ƒ/ t d d t ƒ\ }  } |  t k s= t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.1.jsonRP   (   R
   RD   R   t   FalseR(   (   RP   R/   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_read_bytes_no_sample¡   s    c          C` s\   t  t d d ƒD t d d d  ƒ\ }  } t t t | ƒ ƒ t t ƒ k sR t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*t	   blocksize(   R
   RD   R   t   NoneRL   RM   R=   R(   (   RP   RO   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_read_bytes_blocksize_none§   s    RX   g      @s   5 Bc         C` s›   t  t d d ƒƒ t d d |  ƒ\ } } t t | ƒ Œ  } d j | ƒ j d ƒ } d j t j ƒ  ƒ j d ƒ } t | ƒ t | ƒ k s‘ t	 ‚ Wd  QXd  S(   NR:   R;   s   .test.account*RX   t    s   
(
   R
   RD   R   R   R   R#   t   splitRO   RN   R(   (   RX   RP   t   valsRQ   t   ourlinest	   testlines(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_read_bytes_blocksize_types­   s    c           C` sC   t  t d d ƒ+ t j t ƒ  t d d d ƒWd  QXWd  QXd  S(   NR:   R;   s   .test.account*RX   g      @(   R
   RD   R4   R5   R7   R   (    (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt$   test_read_bytes_blocksize_float_errs·   s    c          C` s`   t  t d d ƒH t d d t ƒ\ }  }  } d „  | Dƒ t t j ƒ  ƒ k sV t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*t   include_pathc         S` s&   h  |  ] } t  j j | ƒ d  ’ q S(   i   (   R   R   R\   (   t   .0R   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <setcomp>À   s   	 (   R
   RD   R   t   TrueRN   t   keysR(   (   R/   R+   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_read_bytes_include_path½   s    c          C` sl   t  t d d ƒT t d ƒ d }  t |  d d  ƒ\ } } t t t | ƒ ƒ t t ƒ k sb t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.t   *RX   (	   R
   RD   R   R   RY   RL   RM   R=   R(   (   t   urlRP   RO   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_with_urlsÃ   s    R    s!   pathlib and moto clash on windowsc       	   C` s¯   t  j d ƒ }  t t d d ƒS |  j d ƒ } t | d d  ƒ\ } } t t t	 | ƒ ƒ t	 t ƒ k sp t
 ‚ Wd  QXt  j t ƒ $ |  j d ƒ } t | d d  ƒWd  QXd  S(   NR   R:   R;   s   ./.test.accounts.*RX   s   file://.test.accounts.*(   R4   t   importorskipR
   RD   R   R   RY   RL   RM   R=   R(   R5   t   OSError(   R   Rh   RP   RO   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_with_pathsË   s    -c       
   C` s8  t  t d d ƒ xd d d d g D]}  t d d |  ƒ\ } } t t t | ƒ ƒ g  t j ƒ  D] } t | ƒ |  d	 ^ qc k sŒ t ‚ t t	 | ƒ Œ  } t
 d
 „  | Dƒ ƒ t
 d „  t j ƒ  Dƒ ƒ k sÖ t ‚ d j | ƒ j d ƒ } d j t j ƒ  ƒ j d ƒ } t | ƒ t | ƒ k s& t ‚ q& WWd  QXd  S(   NR:   R;   i   i   i-   iÜ  s   .test.account*RX   i   c         s` s   |  ] } t  | ƒ Vq d  S(   N(   R=   (   Rc   t   r(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <genexpr>á   s    c         s` s   |  ] } t  | ƒ Vq d  S(   N(   R=   (   Rc   t   v(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <genexpr>â   s    R[   s   
(   R
   RD   R   RI   RM   R=   RO   R(   R   R   RL   R#   R\   RN   (   t   bsRP   R]   Rn   RQ   R^   R_   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_read_bytes_blockÙ   s    6%c          C` s   t  t d d ƒx d d d d g D]ì}  t d d |  d	 d
 ƒ\ } } t d d |  d	 d ƒ\ } } g  t | ƒ D] } | j ^ qu g  t | ƒ D] } | j ^ q” k s² t ‚ t t | ƒ Œ  } g  | D] } | rË | ^ qË } t d „  | Dƒ ƒ sÿ t ‚ d j | ƒ j	 d
 ƒ }	 d j d „  t
 t ƒ Dƒ ƒ j	 d
 ƒ }
 |	 |
 k sQt ‚ d } t d d |  d	 | ƒ\ } } t t | ƒ Œ  } g  | D] } | rŽ| ^ qŽ} t d „  | Dƒ ƒ t | ƒ d k sÒt ‚ d j | ƒ } d j d „  t
 t ƒ Dƒ ƒ } | | k s& t ‚ q& WWd  QXd  S(   NR:   R;   i   i   i-   s   1.5 kBs   .test.accounts*RX   RS   s   
t   fooc         s` s   |  ] } | j  d  ƒ Vq d S(   s   
N(   RH   (   Rc   Rm   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <genexpr>õ   s    R[   c         s` s   |  ] } t  | Vq d  S(   N(   RD   (   Rc   t   k(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <genexpr>÷   s    t   }c         s` s   |  ] } | j  d  ƒ Vq d S(   Rs   N(   RH   (   Rc   Rm   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <genexpr>   s    i   c         s` s   |  ] } t  | Vq d  S(   N(   RD   (   Rc   Rn   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <genexpr>  s    (   R
   RD   R   R   t   keyR(   R   t   allR#   R\   RG   RL   R=   (   Ro   R/   RO   t   values2t   aR;   RQ   Rm   t   resR^   R_   t   dt   ourst   test(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_read_bytes_delimitedé   s,    		+(,i
   s   fmt,blocksizec         C` sí   t  j |  } t | t ƒ } t | d d ƒ¹ t d d | d d d |  ƒ\ } } | d  t t t ƒ d	 d  k s{ t ‚ | j d ƒ s t ‚ t	 t
 | ƒ Œ  } d
 j | ƒ d
 j g  t t ƒ D] } t | ^ qÁ ƒ k sã t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*.jsonRX   RS   s   
R   i   i    R[   (   R   t   compressR   RD   R
   R   RG   R(   RH   R   R   R#   (   t   fmtRX   R}   t   files2RP   RO   RQ   Rr   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_compression
  s    	(c          C` sž   t  t d d ƒ† t d ƒ }  t |  ƒ t t ƒ k s= t ‚ xT t |  t t ƒ ƒ D]= \ } } | ) } | j ƒ  } | t | k sŠ t ‚ Wd  QXqS WWd  QXd  S(   NR:   R;   s   .test.accounts.*(   R
   RD   R   R=   R(   t   zipRG   t   read(   t   myfilest	   lazy_filet	   data_fileR,   t   x(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_open_files  s    "	t   encodings   utf-8t   asciic         C` sÊ   t  t d d ƒ² t d d d d |  ƒ} t | ƒ t t ƒ k sI t ‚ g  } x0 | D]( } |  } | j | j ƒ  ƒ Wd  QXqV Wt | ƒ g  t t ƒ D] } t | j	 |  ƒ ^ q˜ k sÀ t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*t   rtRˆ   (
   R
   RD   R   R=   R(   t   appendR‚   RI   RG   t   decode(   Rˆ   Rƒ   t   datat   fileR,   Rr   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_open_files_text_mode$  s    	R:   RŠ   t   rbR~   c   
      C` sí   t  t j | t ƒ } t | d d ƒ¿ t d d |  d | ƒ} g  } x0 | D]( } |  } | j | j ƒ  ƒ Wd  QXqN Wg  t t ƒ D] } t | ^ q‡ } |  d k rË g  | D] }	 |	 j	 ƒ  ^ q° } n  t
 | ƒ | k sã t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*R   RŠ   (   R   R   R}   RD   R
   R   R‹   R‚   RG   RŒ   RI   R(   (
   R:   R~   R   Rƒ   R   RŽ   R,   Rr   t   solR;   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_open_files_compression1  s    	#"c         C` s^   t  j |  } t i | d ƒ d 6d d ƒ, t ƒ  } t | d |  ƒ d k sT t ‚ Wd  QXd  S(   Nt
   1234567890s   .tmp.getsizeR:   R;   i
   (   R   R}   R
   R   R   R(   (   R~   R}   t   fs(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_getsizeA  s     	c          C` sb   t  t d d ƒJ xB t t g D]4 }  t j t ƒ  |  d d d ƒ\ } } Wd  QXq  WWd  QXd  S(   NR:   R;   s   .test.accounts.*R   s	   not-found(   R
   RD   R   R   R4   R5   R6   (   t   funcRP   RO   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_bad_compressionI  s
    	c          C` sJ   d }  t  j t t f ƒ  } t |  ƒ Wd  QX|  t | ƒ k sF t ‚ d  S(   Ns
   not-a-file(   R4   R5   R   Rk   R   R!   R(   (   t   fnt   e(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_not_foundQ  s    c    	      C` sE  t  t d d ƒ-t d ƒ \ }  } t d ƒ \ }  } t t | ƒ ƒ } t t | ƒ ƒ } g  | D] } | j ^ qb g  | D] } | j ^ q{ k s™ t ‚ t d ƒ x3 t D]+ } t | d ƒ  } | j	 d ƒ Wd  QXqª Wt d ƒ \ }  } t t | ƒ ƒ } g  | D] } | j ^ qg  | D] } | j ^ qk s;t ‚ Wd  QXd  S(   NR:   R;   s   .test.accounts.*i   t   abR†   (
   R
   RD   R   RI   R   t   _keyR(   R   R$   R%   (	   R/   Rw   R;   t   aat   bbR˜   R,   t   ct   cc(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt
   test_namesX  s    >
t   compression_openert   gzipc         C` s  | \ } } t  |  ƒ }  t |  d d d d d | ƒ} t | ƒ d k sN t ‚ d „  | Dƒ d h k sm t ‚ x* | D]" } |  } | j d ƒ Wd  QXqt Wt t j |  ƒ ƒ } | d d	 g k sÇ t ‚ | t j j	 |  | d
 ƒ d ƒ  } | j
 ƒ  } Wd  QX| d k st ‚ d  S(   NRA   i   R:   R   R   c         S` s   h  |  ] } | j  ’ q S(    (   R:   (   Rc   R,   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <setcomp>s  s   	 t   000s   0.parts   1.parti    R   (   R!   R   R=   R(   R%   RG   R   t   listdirR   R#   R‚   (   R)   R¢   R   t   openerRD   t   filR,   Ry   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_open_files_writel  s    	%c         C` sô   t  |  ƒ }  t j d ƒ } t t d d ƒÁ t d ƒ } | j | j | ƒ ƒ } x• t | | ƒ D]„ \ } } | j	 | j	 k s† t
 ‚ t | j ƒ t | j ƒ k sª t
 ‚ | 4 } | % } | j ƒ  | j ƒ  k sÚ t
 ‚ Wd  QXWd  QXqb WWd  QXd  S(   Nt   cloudpickleR:   R;   s   .test.accounts.*(   R!   R4   Rj   R
   RD   R   t   loadst   dumpsR   R   R(   t   typeR”   R‚   (   R)   R©   Rƒ   t   myfiles2R,   t   f2t   f_opent   f2_open(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_pickability_of_lazy_files  s    $	 	c         C` s†   t  |  d ƒ } t j | d d ƒ } | j d ƒ Wd  QXt | d d d d ƒ} | d # } t d	 „  | Dƒ ƒ s| t ‚ Wd  QXd  S(
   Ns   myfile.txt.gzR:   R   s   hello
worldR   R£   RŠ   i    c         s` s   |  ] } t  | t ƒ Vq d  S(   N(   RE   R	   (   Rc   t   line(    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pys	   <genexpr>–  s    (   R!   R£   R$   R%   R   Ru   R(   (   R)   R˜   R,   RD   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_py2_local_bytesŽ  s    c         C` s  t  |  ƒ }  t j ƒ  } t j |  ƒ t d d ƒ  } | j d ƒ Wd  QXt ƒ  j d ƒ } t | ƒ d k st t	 ‚ t j
 | d k s t	 ‚ |  | d k r­ d | d k s³ t	 ‚ t ƒ  } t j | ƒ | j d d ƒ  } | j ƒ  } Wd  QX| d k st	 ‚ d  S(   Nt   tmpt   wt   hiRg   i   i    Rm   (   R!   R   t   getcwdt   chdirR$   R%   R   t   globR=   R(   t   sepR‚   (   R)   t   hereR,   t   outR”   Rx   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_abs_paths™  s    &	t   UnknownFileSystemc           B` s   e  Z RS(    (   t   __name__t
   __module__(    (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyR¾   «  s   c          C` s`   t  j d ƒ }  t ƒ  } t t | ƒ |  j j ƒ s9 t ‚ t  j t ƒ  t t	 ƒ  ƒ Wd  QXd  S(   Nt   pyarrow(
   R4   Rj   R   RE   R   t
   filesystemR(   R5   t   NotImplementedErrorR¾   (   t   paR”   (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   test_get_pyarrow_filesystem¯  s
    	!(   i   i   (S   t
   __future__R    R   R   R£   R   t   timeR   R&   R4   t   toolzR   R   R   RC   R   t   dask.compatibilityR   R	   t
   dask.utilsR
   t
   dask.bytesR   t   dask.bytes.localR   t   dask.bytes.coreR   R   R   R   R   RD   R<   R   R   t   ImportErrort	   NameErrorR   R   R2   R9   R>   t   markt   skipift   version_infoR@   RB   RR   RT   RU   RW   RZ   t   parametrizeR`   Ra   Rf   Ri   R'   Rl   Rp   R|   R~   RY   t   seekable_filest   fmt_bsR€   R‡   R   RI   R’   R•   R—   Rš   t   slowR¡   R$   R¨   R±   R³   R½   t   objectR¾   RÅ   (    (    (    s:   lib/python2.7/site-packages/dask/bytes/tests/test_local.pyt   <module>   sz   (



			
						$
					#	
$*'		'			