>ieUddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl mZddlmZddgZejdZejjefZd ed <e eje d kr ejd ZeejjfzZejd dZdZ dZ!dZ"ej#$dddgdZ%dZ&dZ'dZ(dZ)ej#j*ej#$dddgdZ+ej#,ddd !ej#j*d"Z-ej#j*d#Z.dS)$) annotationsN) open_files)parse)tmpdirabrequestsztuple[type[Exception], ...]errsz0.7.4aiohttpmodule)scopec#Kt5}tD]`}ttj||d5}|ddzdddn #1swxYwYatjdddg}tj ||}d} t d nQ#tj j$r9}tjd |d z}|d krt#d |Yd}~nd}~wwxYwm|V|ddddS#1swxYwYdS)Nwbai'z-mz http.server8999)cwd Tzhttp://localhost:8999g?rzServer did not appear)rfilesopenospathjoinwritesys executable subprocessPopenr get exceptionsConnectionErrortimesleep RuntimeError terminate)dfnfcmdptimeoutes :lib/python3.11/site-packages/dask/bytes/tests/test_http.py dir_serverr-s Q & &Bbgll1b))400 &Au %%% & & & & & & & & & & & & & & &~t]F;  Sa ( ( ( G G 4555&6 G G G 33Q;;&'>??QF;;;; G  G %s_8D5 A." D5.A2 2D55A2 6-D5$B?>D5?D /DD5D  D55D9<D9ctd}td}t||zd}|5}|}dddn #1swxYwYttj||d5}||ksJ ddddS#1swxYwYdS)Nhttp://localhost:8999/rrbrrreadrrrr)r-rootr&r'dataexpecteds r, test_simpler63s( #D qB4"9a A avvxx bgll:r**D 1 1'Xx}}&&&&&''''''''''''''''''s#A  AAB--B14B1c^d}td}t||zd}ttj||d5}|}|5}|d}||ddksJ|jdksJ|d|d}||ddksJ|dd|jdksJ dddn #1swxYwYddddS#1swxYwYdS)Nr/rr0) rrrrrrr2locseek)r-r3r&r'r5r4s r,test_locr>=s #D qB4"9a A bgll:r**D 1 1 X==??  !66!99D8BQB<''''5A:::: FF1III66!99D8BQB<'''' FF1aLLL5A:::::                                 s7D"-BD > D" D D"D D""D&)D&cd}td}ddi}t||z|d}|5}|d|dz}dddn #1swxYwYttj||d 5}||ksJ ddddS#1swxYwYdS) Nr/rDatezWed, 21 Oct 2015 07:28:00 GMT)headersr:)lengthr0r1)r-r3r&rAr'r4r5s r,test_fetch_range_with_headersrDNsQ #D qB67G4"9g...q1A 4avvQv!&&&"3"33444444444444444 bgll:r**D 1 1'Xx}}&&&&&''''''''''''''''''s#.A**A.1A.#C  CC block_sizeicd}td}t||zd}ttj||d5}|}|5}|d|ddksJ|d|d|ddksJ|d|ddksJ|dd||ddksJ dddn #1swxYwYddddS#1swxYwYdS)Nr/rr0rir8)rrrrrrr2r=)r-rEr3r&r'r5s r,test_opsrHZs #D qB4"9a A bgll:r**D 1 1 .X==??  .!66"::#2#.... FF1III66"::#2#....66"::"R%0000 FF3NNN6688x~----- . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .s7E -B7D1% E 1D5 5E 8D5 9E  E E ctd}td}t||zdd}ttj||d5}|}|5}||ksJ|jt|ksJ dddn #1swxYwYtd}t||zdd}|5}ttj tdkrVtj t5|d|ddksJ dddn #1swxYwYn#|d|ddksJdddn #1swxYwYddddS#1swxYwYdS) Nr/rr8)rEr0r:z 2021.11.1r)rrrrrrr2sizelen parse_versionfsspec __version__pytestraises ValueError)r-r3r&r'r5s r,test_ops_blocksizerRks #D qB4"9+++A.A bgll:r**D 1 13X==??  +!6688x''''6S]]*****  + + + + + + + + + + + + + + +1X tbyQ / / / 2  3!V/00=3M3MMM]:..7766"::#2#66666777777777777777vvbzzXcrc]2222 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3333333333333333333sF-/5B1% F-1B5 5F-8B5 9,F-%AF)$E FE F!E "'F F-F F-F F--F14F1ctdd}tjt5|5}|dddn #1swxYwYdddn #1swxYwYtdd}t }tj|5|5}|dddn #1swxYwYdddn #1swxYwYd}t d}t||zdd}tjt5|5 dddn #1swxYwYdddn #1swxYwYt||zd}|5}tjt5| ddddn #1swxYwYddddS#1swxYwYdS)Nz"http://localhost:8999/doesnotexistrzhttp://nohost/r/r)moderC) rrOrPr r2FileNotFoundErrorrNotImplementedErrorrQr=)r-r'r5r3r&s r, test_errorsrWs788;A t    ! FFHHH                #$$Q'A H x   ! FFHHH                $D qB4"94(((+A * + +                    4"9a A a ]: & &   FF2JJJ               sA*A A*A A*A A**A.1A.%C (C = C  C C C C  C$'C$-E0D>2 E>E EE EEE:GF6* G6F: :G=F: >GGGcdtfdtD}t|tD]\}}|5}ttj||d5}||ksJ dddn #1swxYwYdddn #1swxYwYdS)Nr/cg|]}|zSrZ).0r'r3s r, ztest_files..s---!TAX---r0)rrziprrrrr2)r-fsr'f2r5r3s @r, test_filesras> #D ----u--- . .BR332  3!bgll:r22D99 3Xvvxx8==??22222 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 333s6/C/-B) C)B- -C0B- 1CC C czd}t|dz}|djdksJ|djdksJdS)Nr/*rzhttp://localhost:8999/ar:zhttp://localhost:8999/b)rr)r-r3r_s r,test_open_globrdsN #D D3J  B a5:2 2 2 2 2 a5:2 2 2 2 2 2 2r]enginepyarrow fastparquetctjddtjd}tj||dg|}|jt tdksJ|jgdksJdS) Nr z2.21.0) minversiondask.dataframezthttps://github.com/Parquet/parquet-compatibility/raw/master/parquet-testdata/impala/1.1.1-NONE/nation.impala.parquet)re) n_nationkeyn_name n_regionkey n_comment) rO importorskip read_parquetcomputerltolistlistrangecolumns)redddfs r, test_parquetrys  x8888  - . .B   $    gii > " "d599oo 5 5 5 5 :    "W"W"W W W W W W Wr]rz(https://github.com/dask/dask/issues/3696)reruns reruns_delayreasoncxddg}tj|}|jdksJ|dS)Nrhttps://raw.githubusercontent.com/weierophinney/pastebin/master/public/js-src/dojox/data/tests/stores/patterns.csvzhttps://en.wikipedia.orgr8)db read_text npartitionsrr)urlsrs r,test_bagrsG D" D TA =A    IIKKKKKr]ctjd}d}||}|dS)Nrjr)rOrpread_csvrr)rwurlrs r, test_read_csvrsB  - . .B D CAIIKKKKKr])/ __future__rrrrr!rMrO fsspec.corerpackaging.versionrrLdask.bagbagr dask.utilsrrrpr rRequestExceptionrUr __annotations__rNr client_exceptionsClientResponseErrorfixturer-r6r>rDmark parametrizerHrRrWrardnetworkryflakyrrrZr]r,rs"""""""  """"""444444 c  6 z * * (%=#$$}}W'='===!f!),,G 7,@B BDh ,'''" ' ' 'e}55 . .65 . 33340333333I}#=>> X X?> X  A&P   r]