;jy(ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z ddlmZe jdde jdd e jd d e jj e jejd ddejd<ejdkrjejddOddlmZ ejejddejd<n#e$redYnwxYwdZGddZ dZ!dZ"ej#dZ$ej#ddZ%ej#d d!Z&ej#dd"Z'ej#dd#Z(d1d'Z)ej#dd(Z*ej#dd)Z+ej#dd*Z,ej#d+d,gd-d.Z-ej#dd/Z.ej#dd0Z/dS)2N)groupsdefaultsfind_free_portcii) max_examplesdev2debug )r verbosityHYPOTHESIS_PROFILEz /dev/nullAWS_CONFIG_FILEwin32TZDIR) resourcestzdatazoneinfozCPackage "tzdata" not found. Not setting TZDIR environment variable.c d d}tD]\}|d|t|}|d|d|d|d|d|dd d |d]dS) Nctj|}|s|S|}|dvrdS|dvrdSt |d|d)N>1yonyestrueT>0nnoofffalseF=z is not parsable as boolean)osenvirongetupperlower ValueError)namedefaultvalues HC:\PYTHON\MyICR_Suite\python\Lib\site-packages\pyarrow/tests/conftest.pybool_envz"pytest_addoption..bool_envBs tzz||,, N  3 3 34 6 6 65 QQuQQQRR R PYARROW_TEST_ --enable- store_truez Enable the z test group)actionr*help --disable-Fz Disable the N)rr addoption)parserr-groupr*s r,pytest_addoptionr9@s S S S SCC(2522HUODD,U,, ,g?U???  B B B -e-- ,e@e@@@  C C C C CCr.c eZdZdZdZdZdS) PyArrowConfigci|_dSr5) is_enabled)selfs r,__init__zPyArrowConfig.__init__Ys r.cT|j}|tvr||dSdSr5)r)rrequires)r>markr8s r, apply_markzPyArrowConfig.apply_mark\s1  F?? MM%  ?r.cR|j|stj|ddSdS)Nz NOT enabled)r=pytestskip)r>r8s r,rAzPyArrowConfig.requiresas:u% 0 K5... / / / / / 0 0r.N)__name__ __module__ __qualname__r?rCrAr.r,r;r;XsA!!! 00000r.r;ct|_tD]\}|d|d|}d|}||o|| }||jj|<]dS)Nmarkersr0r4)r;pyarrowraddinivalue_line getoptionr=)configrB enable_flag disable_flagr=s r,pytest_configurerSfs"__FN 5 5 t   )$(( *D** &&{335&&|4495 *4!$'' 5 5r.cr|D]!}|jj|"dSr5) iter_markersrPrMrC)itemrBs r,pytest_runtest_setuprWwsC!!##-- &&t,,,,--r.c4tj|jSr5)pathlibPathstrpath)tmpdirs r,tempdirr]}s < ' ''r.session)scopecDtjtjdz S)Ndata)rYrZ__file__parentrJr.r, base_datadirrds < ! ! (6 11r.T)autousec2|dddS)zStop the AWS SDK from trying to contact the EC2 metadata server. Otherwise, this causes a 5 second delay in tests that exercise the S3 filesystem. AWS_EC2_METADATA_DISABLEDrN)setenv) monkeypatchs r,disable_aws_metadatarjs!2F;;;;;r.ctjdd}ttjdd}tjdd}|||fS)NARROW_HDFS_TEST_HOSTr*ARROW_HDFS_TEST_PORTrARROW_HDFS_TEST_USERhdfs)r#r$r%int)hostportusers r,hdfs_connectionrtsY :>>0) < >0& 9 9D t r.c8dt}}d\}}||||fS)N 127.0.0.1)arrow apachearrowr)rqrr access_key secret_keys r, s3_connectionr{s*n..$D3J z: --r.?cfd}|S)aP Retry decorator Parameters ---------- attempts : int, default 3 The number of attempts. delay : float, default 1 Initial delay in seconds. max_delay : float, optional The max delay between attempts. backoff : float, default 1 The multiplier to delay after each attempt. cPtjfd}|S)Nc}}|dkrX  |i|S#t$r<}|dz}|}|z} rt| }tj|Yd}~nd}~wwxYw|dkX|)Nrr~) Exceptionmintimesleep) argskwargsremaining_attempts curr_delayerrlast_exceptionattemptsbackoffdelayfunc max_delays r,wrapperz(retry..decorate..wrappers!) J$q((+40000 +++&!+&%(N')J @%(Y%?%? Jz******** +%q((! s A2AA) functoolswraps)rrrrrrs` r,decoratezretry..decoratesM    ! ! ! ! ! ! ! !   !r.rJ)rrrrrs```` r,retryrs5" Or.c#\Ktdddd}|}|\}}}}|d|}tj} | ||ddd d d d ||g} d} t j| | } |||| |dVn$#t$rtj dYnwxYw| *| | dSdS#| )| | wwxYw)Nr~r)rrrctjd|d}|dksJdS)Nzhttp://z/minio/health/live)urllibrequesturlopengetcode)addressresps r,minio_server_health_checkz,s3_server..minio_server_health_checksB~%%&K&K&K&KLL||~~$$$$$$r.:)MINIO_ACCESS_KEYMINIO_SECRET_KEYminioz--compatserverz--quietz --addressenv connectionprocessr]z!`minio` command cannot be located) r getbasetempr#r$copyupdate subprocessPopenOSErrorrErFkillwait) r{tmpdir_factoryrr\rqrrryrzrrrprocs r, s3_serverrs AQ***%%+*% ' ' ) )F)6&D$ JG *//  CJJ&& Z9k V D D#... "!'***(      999 7888889   IIKKK IIKKKKK  4  IIKKK IIKKKK s*B,C>,C  C> C  C>>-D+c#BKt}tj}d}|dt |g}d} t j||}|tj d|dd|f|dVn1#t$r$}tj d|d|Yd}~nd}~wwxYw|*| | dSdS#|)| | wwxYw) Nzstorage-testbenchz--portrCommand # did not start server successfully! localhost)rr failed to execute: ) rr#r$rstrrrpollrErFrrr)rrrexerres r, gcs_serverrsV   D *//  C C 3t99 %D D#... 99;; " KL4LLL M M M '-       >>>    IIKKK IIKKKKK  4  IIKKK IIKKKK s1AB C1 CB;6C1;CC11-Dc#Kt}tj}|}dd|dt |g}|dgz }d} t j||}|tj d|dd|d d f||d Vn8#ttf$r$}tj d|d |Yd}~nd}~wwxYw|*| |dSdS#|)| |wwxYw) Nz azurite-blobz --locationz --blobPortz--skipApiVersionCheckrrrrvdevstoreaccount1zXEby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==rr)rr#r$rrrrrrrErFModuleNotFoundErrorrrr)rrrrr\rrrs r, azure_serverrs   D *//  C  ' ' ) )F L&,D JD $ %%D D#... 99;; " KL4LLL M M M'.@CD        )>>>    IIKKK IIKKKKK  4  IIKKK IIKKKK s1 AB/" D/C$CDC$$D-Ebuiltin_pickle cloudpickle)paramsr_c6||jSr5)getfixturevalueparam)rs r, pickle_moduler*s  " "7= 1 11r.cddl}|S)Nrpicklers r,rr5sMMM Mr.cXtjd}d|jvr |j|_|S)NrHIGHEST_PROTOCOL)rE importorskip__dict__DEFAULT_PROTOCOLr)cps r,rr;s/  ] + +B,, 1 Ir.)r|r}Nr~)0rr#rYrsysrurllib.requestrrE hypothesishconftestrr pyarrow.utilrsettingsregister_profile Verbosityverbose load_profiler$r%platform importlibrpathjoinfilesrprintr9r;rSrWfixturer]rdrjrtr{rrrrrrrrJr.r,rs&$   '''''''''''''' Dt444 E333 G"&'k&9;;;  ';UCCDDD!,  <7 z~~gt$$,'''''' "$',,yx/H/H*"U"UBJw  "    EU       CCC0 0 0 0 0 0 0 0 0555"--- ((( i   22! 2<<<i   ! i   ..! .    Fi   ##! #Li   ! 2i   ! B   222i   !  i   ! s<1D..EE