
    <>iU                         S SK r S SKrS SKrS SKrS SKJr  \R                  " SS9S 5       r\R                  " SS9S 5       r\R                  S 5       r	\R                  S 5       r
\R                  S	 5       r\R                  " S
S9S 5       rg)    N)guidmodule)scopec                     U S-  $ )Nparquet )base_datadirs    ]/var/www/html/land-tabula/venv/lib/python3.13/site-packages/pyarrow/tests/parquet/conftest.pydatadirr      s    )##    c                      [         R                  S:X  a  [        R                  " S5        [        R
                  R                  S5      n U (       d  [        S5      e[        R                  " U 5      $ )N
emscriptenz$needs PARQUET_TEST_DATA files accessPARQUET_TEST_DATAzRPlease point the PARQUET_TEST_DATA environment variable to the test data directory)
sysplatformpytestskiposenvirongetRuntimeErrorpathlibPath)results    r
   parquet_test_datadirr       sU    
|||#:;ZZ^^/0F A B 	B<<r   c           
      ^   [         R                  " S5      n[         R                  " S5      nSnU S   u  pEpgUR                  SSU SU 3UUUR                  R                  SS	9S
S9n UR	                  US9  UR                  5         U$ ! [
         a     Nf = f! UR                  5         f = f)Nboto3botocorez	test-s3fs
connections3http://:s3v4)signature_versionz	us-east-1)endpoint_urlaws_access_key_idaws_secret_access_keyconfigregion_name)Bucket)r   importorskipclientConfigcreate_bucket	Exceptionclose)		s3_serverr   r   s3_bucket_namehostport
access_key
secret_key	s3_clients	            r
   	s3_bucketr8   +   s    (E"":.H N)2<)@&D
tfAdV,$(%%%?  I~6 	   	s$   )B
 

BB BB B,c           	   #     #    [         R                  " S5      nU S   u  p4pVUR                  UUSSU SU 30S9nU S[        5        3nUR	                  U5        Xx4v    UR                  USS	9  g ! [         a     g f = f7f)
Ns3fsr   r%   r!   r"   )keysecretclient_kwargs/T)	recursive)r   r+   S3FileSystemr   mkdirrmFileNotFoundError)	r1   r8   r:   r3   r4   r5   r6   fs	test_paths	            r
   s3_example_s3fsrF   E   s     v&D)2<)@&D
			gdV1TF3
 
 
B +Qtvh'IHHY
-
i4( s*   AB A1 0B1
A>;B=A>>Bc           	   #      #    SSK Jn  U S   u  p#pESU SU SU SU S3	nUR                  U5      u  pxUR                  S5        XvU4v   g 7f)	Nr   )
FileSystemr   zs3://r"   z5@mybucket/data.parquet?scheme=http&endpoint_override=z&allow_bucket_creation=Truemybucket)
pyarrow.fsrH   from_uri
create_dir)	r1   rH   r3   r4   r5   r6   urirD   paths	            r
   s3_example_fsrO   \   sl     %)2<)@&D


|1ZL )"V1TF*E	G  ""3'HBMM*
4-s   A	Aclassc                 $    U R                  S5      $ )Nzpyarrow-parquet)mktemp)tmp_path_factorys    r
   reusable_tempdirrT   l   s    ""#455r   )r   r   r   r   pyarrow.utilr   fixturer   r   r8   rF   rO   rT   r   r   r
   <module>rW      s   $ 
  
   h$  $ h      2  ,   g6 6r   