+
    nDjU                     4   ^ RI t ^ RIt^ RIt^ RIt^ RIHt ]P                  ! RR7      R 4       t]P                  ! RR7      R 4       t]P                  R 4       t	]P                  R 4       t
]P                  R	 4       t]P                  ! R
R7      R 4       tR# )    N)guidmodule)scopec                     V R ,          # )parquet )base_datadirs   &X/data/cameron/venvs/s3viz/lib/python3.14/site-packages/pyarrow/tests/parquet/conftest.pydatadirr      s    )##    c                      \         P                  R 8X  d   \        P                  ! R4       \        P
                  P                  R4      p V '       g   \        R4      h\        P                  ! V 4      # )
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           
      z   \         P                  ! R 4      p\         P                  ! R4      pRpV R,          w  rErgVP                  RRV RV 2VVVP                  P                  RR7      R	R
7      p VP	                  VR7       VP                  4        V#   \
         d     Li ; i  TP                  4        i ; i)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$   3B B%"B( $B%%B( (B:c           	   #      "   \         P                  ! R 4      pV R,          w  r4rVVP                  VVRRV RV 2/R7      pV R\        4        2pVP	                  V4       Wx3x   VP                  VRR7       R	#   \         d     R	# i ; i5i)
s3fsr   r%   r!   r"   )keysecretclient_kwargs/T)	recursiveN)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'A< :B<BB
BBc           	   #      "   ^ RI Hp V R,          w  r#rERV RV RV RV R2	pVP                  V4      w  rxVP                  R4       WvV3x  R# 5i)	r   )
FileSystemr   zs3://r"   z5@mybucket/data.parquet?scheme=http&endpoint_override=z&allow_bucket_creation=TruemybucketN)
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                 $    V P                  R 4      # )z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   