+
    nDj9'                     "   ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	t
^RIHtHt ^ RIHt ]
P                   P#                  RRR7       ]
P                   P#                  R^2R7       ]
P                   P#                  R^
]
P$                  P&                  R	7       ]
P                   P)                  ]P*                  P-                  R
R4      4       R]P*                  R&   ]P.                  R8X  d_   ]P*                  P-                  RR4      fA   ^ RIHt  ]P4                  P7                  ]P8                  ! R4      R4      ]P*                  R&   R t ! R R4      t R t!R t"]PF                  R 4       t$]PF                  ! RR7      R 4       t%]PF                  ! RR7      R 4       t&]PF                  ! RR7      R 4       t']PF                  ! RR7      R  4       t(R+R! lt)]PF                  ! RR7      R" 4       t*]PF                  ! RR7      R# 4       t+]PF                  ! RR7      R$ 4       t,]PF                  ! R%R&.RR'7      R( 4       t-]PF                  ! RR7      R) 4       t.]PF                  ! RR7      R* 4       t/R#   ] d    ]! R4        EL;i ; i),    N)groupsdefaultsfind_free_portcii  )max_examplesdevdebug)r   	verbosityHYPOTHESIS_PROFILEz	/dev/nullAWS_CONFIG_FILEwin32TZDIR)	resourcestzdatazoneinfozCPackage "tzdata" not found. Not setting TZDIR environment variable.c           	          RR lp\          FR  pV! RV 2\        V,          4      pV P                  RV 2RVRV R2R7       V P                  RV 2RR	R
V R2R7       KT  	  R # )Nc                     \         P                  P                  V P                  4       4      pV'       g   V# VP	                  4       pVR9   d   R# VR9   d   R# \        V P                  4        RV R24      h)1TF=z is not parsable as boolean>   r   yonyestrue>   0nnoofffalse)osenvirongetupperlower
ValueError)namedefaultvalues   && P/data/cameron/venvs/s3viz/lib/python3.14/site-packages/pyarrow/tests/conftest.pybool_env"pytest_addoption.<locals>.bool_envB   sd    

tzz|,N3366

~Qug5PQRR    PYARROW_TEST_	--enable-
store_truezEnable the z test group)actionr'   help
--disable-FzDisable the N)r   r   	addoption)parserr*   groupr'   s   &   r)   pytest_addoptionr7   @   s    
S ]5'2HUOD9UG, ,g!,UG;? 	 	B 	:eW- ,e!-eWK@ 	 	C r,   c                   2   a  ] tR t^Xt o R tR tR tRtV tR# )PyArrowConfigc                    / V n         R # r3   
is_enabled)selfs   &r)   __init__PyArrowConfig.__init__Y   s	    r,   c                Z    VP                   pV\        9   d   V P                  V4       R # R # r3   )r&   r   requires)r=   markr6   s   && r)   
apply_markPyArrowConfig.apply_mark\   s#    		F?MM%  r,   c                n    V P                   V,          '       g   \        P                  ! V R 24       R# R# )z NOT enabledN)r<   pytestskip)r=   r6   s   &&r)   rA   PyArrowConfig.requiresa   s)    u%%KK5'./ &r,   r;   N)	__name__
__module____qualname____firstlineno__r>   rC   rA   __static_attributes____classdictcell__)__classdict__s   @r)   r9   r9   X   s     !
0 0r,   r9   c                    \        4       V n        \         Ff  pV P                  R V4       RV 2pRV 2pV P	                  V4      ;'       d    V P	                  V4      '       * pW@P                  P
                  V&   Kh  	  R# )markersr.   r2   N)r9   pyarrowr   addinivalue_line	getoptionr<   )configrB   enable_flagdisable_flagr<   s   &    r)   pytest_configurerX   f   s    "_FNt	
 "$(#D6*&&{3 5 5&&|495
*4!!$' r,   c                 ~    V P                  4        F(  pV P                  P                  P                  V4       K*  	  R # r3   )iter_markersrU   rR   rC   )itemrB   s   & r)   pytest_runtest_setupr\   w   s-    !!#&&t, $r,   c                 B    \         P                  ! V P                  4      # r3   )pathlibPathstrpath)tmpdirs   &r)   tempdirrb   }   s     <<''r,   session)scopec                  X    \         P                  ! \        4      P                  R ,          # )data)r^   r_   __file__parent r,   r)   base_datadirrj      s    <<!((611r,   T)autousec                *    V P                  RR4       R# )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_DISABLEDr   N)setenv)monkeypatchs   &r)   disable_aws_metadatarp      s     2F;r,   c                      \         P                  P                  R R4      p \        \         P                  P                  R^ 4      4      p\         P                  P                  RR4      pWV3# )ARROW_HDFS_TEST_HOSTr'   ARROW_HDFS_TEST_PORTARROW_HDFS_TEST_USERhdfs)r    r!   r"   int)hostportusers      r)   hdfs_connectionrz      sQ    ::>>0)<Drzz~~4a89D::>>0&9Dtr,   c                  &    R \        4       rRRr2WW#3# )	127.0.0.1arrowapachearrowr   )rw   rx   
access_key
secret_keys       r)   s3_connectionr      s    n.$$m
z--r,   c                    a aaa V VVV3R lpV# )a   
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.
c                 P   <a  \         P                  ! S 4      VVVV V3R  l4       pV# )c                     < SpSpV^ 8  d
    S	! V / VB # Xh  \          dJ   pT^,          pTpTS,          pS
'       d   \        TS
4      p\        P                  ! T4        Rp?Ka  Rp?ii ; ir   N)	Exceptionmintimesleep)argskwargsremaining_attempts
curr_delayerrlast_exceptionattemptsbackoffdelayfunc	max_delays   *,    r)   wrapper(retry.<locals>.decorate.<locals>.wrapper   s}    !)J$q(+000 !  ! +&!+&%(N')J %(Y%?
JJz**+s    A,>A''A,)	functoolswraps)r   r   r   r   r   r   s   f r)   decorateretry.<locals>.decorate   s*    			! 	! 
	! r,   ri   )r   r   r   r   r   s   ffff r)   retryr      s     " Or,   c              #   *  "   \        ^^^R7      R 4       pVP                  4       pV w  rErgV RV 2p\        P                  P	                  4       p	V	P                  RVRV/4       RRRR	R
W.p
Rp \        P                  ! WR7      pV! V4       RV RVRV/x  Ve#   VP                  4        VP                  4        R# R#   \         d    \        P                  ! R4        LKi ; i  Te"   TP                  4        TP                  4        i i ; i5i)   )r   r   r   c                 z    \         P                  P                  R V  R24      pVP                  4       ^8X  g   Q hR# )zhttp://z/minio/health/liveN)urllibrequesturlopengetcode)addressresps   & r)   minio_server_health_check,s3_server.<locals>.minio_server_health_check   s4    ~~%%y8J&KL||~$$$r,   :MINIO_ACCESS_KEYMINIO_SECRET_KEYminioz--compatserverz--quietz	--addressNenv
connectionprocessrb   z!`minio` command cannot be located)r   getbasetempr    r!   copyupdate
subprocessPopenOSErrorrF   rG   killwait)r   tmpdir_factoryr   ra   rw   rx   r   r   r   r   r   procs   &&          r)   	s3_serverr      s'    
AQ*% +% '')F)6&D
avG
**//
CJJJJ 
 Z9kDD.
 	"'* -tv
 	
 IIKIIK   9789 IIKIIK s<   A.D1C C) (D!C&#C) %C&&C) )'DDc               #   &  "   \        4       p \        P                  P                  4       pR pVR\	        V 4      .pRp \
        P                  ! W1R7      pVP                  4       e   \        P                  ! RV R24       RRV 3RV/x  Ve#   VP                  4        VP                  4        R# R#   \         d'   p\        P                  ! RT R	T 24        Rp?LTRp?ii ; i  Te"   TP                  4        TP                  4        i i ; i5i)
zstorage-testbenchz--portNr   Command # did not start server successfully!r   	localhostr    failed to execute: )r   r    r!   r   strr   r   pollrF   rG   r   r   r   )rx   r   exer   r   es         r)   
gcs_serverr      s     D
**//
C
C3t9%DD.99;"KK(4&(KLM
 ;-t
 	

 IIKIIK   >htf$8<==> IIKIIK sA   ;DAB3 
C' (D3C$>CC' C$$C' ''DDc              #   n  "   \        4       p\        P                  P                  4       pV P	                  4       pR RVR\        V4      .pVR.,          pRp \        P                  ! WBR7      pVP                  4       e   \        P                  ! RV R24       RR	VR
R3RVRV/x  Ve#   VP                  4        VP                  4        R# R#   \        \        3 d'   p\        P                  ! RT RT 24        Rp?LZRp?ii ; i  Te"   TP                  4        TP                  4        i i ; i5i)zazurite-blobz
--locationz
--blobPortz--skipApiVersionCheckNr   r   r   r   r|   devstoreaccount1zXEby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==r   rb   r   )r   r    r!   r   r   r   r   r   r   rF   rG   ModuleNotFoundErrorr   r   r   )r   rx   r   ra   r   r   r   s   &      r)   azure_serverr     s+    D
**//
C'')FL&,D	JD 	$%%DD.99;"KK(4&(KLM ;.@CD tv
 	
 IIKIIK   ) >htf$8<==> IIKIIK sC   AD5AC D )(D5D"D>D DD 'D22D5builtin_picklecloudpickle)paramsrd   c                 8    V P                  V P                  4      # r3   )getfixturevalueparam)r   s   &r)   pickle_moduler   *  s     ""7==11r,   c                      ^ RI p V # r   pickler   s    r)   r   r   5  s
    Mr,   c                  v    \         P                  ! R 4      p RV P                  9  d   V P                  V n        V # )r   HIGHEST_PROTOCOL)rF   importorskip__dict__DEFAULT_PROTOCOLr   )cps    r)   r   r   ;  s1    			]	+B, 11Ir,   )   g      ?N   )0r   r    r^   r   sysr   urllib.requestr   rF   
hypothesishconftestr   r   pyarrow.utilr   settingsregister_profile	Verbosityverboseload_profiler!   r"   platform	importlibr   pathjoinfilesr   printr7   r9   rX   r\   fixturerb   rj   rp   rz   r   r   r   r   r   r   r   r   ri   r,   r)   <module>r      s  $  	   
     ' ' 

  Dt  4 

  E  3 

  G"&'kk&9&9  ; 

  

';UC D !,

 
 <<7	zz~~gt$,'	"$'',,yx/H*"UBJJwC00 05"- ( (
 i 2 !2 < < i  ! i . !. F i # !#L i  !2 i  !B  22 i  !
 i  !E # 	U	s   9I; ;JJ