Ë
    ìmxiU  ã                   ó2  — d dl Z d dlZd dlZd dlZd dlmZ  ej                  d¬«      d„ «       Z ej                  d¬«      d„ «       Zej                  d„ «       Z	ej                  d„ «       Z
ej                  d	„ «       Z ej                  d
¬«      d„ «       Zy)é    N)ÚguidÚmodule)Úscopec                 ó   — | dz  S )NÚparquet© )Úbase_datadirs    úU/home/htdocs/ttos/venv/lib/python3.12/site-packages/pyarrow/tests/parquet/conftest.pyÚdatadirr      s   € à˜)Ñ#Ð#ó    c                  óÔ   — t         j                  dk(  rt        j                  d«       t        j
                  j                  d«      } | st        d«      ‚t        j                  | «      S )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   € ä
‡|�|�|Ò#Ü�‰Ð:Ô;Ü�Z‰Z�^‰^Ð/Ó0€FÙÜð Aó Bð 	Bä�<‰<˜ÓÐr   c           	      ón  — t        j                  d«      }t        j                  d«      }d}| d   \  }}}}|j                  dd|› d|› �|||j                  j                  d¬	«      d
¬«      }	 |j	                  |¬«       |j                  «        |S # t
        $ r Y Œw xY w# |j                  «        w xY w)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ˆ$�
˜JØ—‘ØØ˜t˜f A d VÐ,Ø$Ø(Ø�‰×%Ñ%¸Ð%Ó?Øð ó €IðØ×Ñ ~ÐÔ6ð 	�‰ÔàÐøô ò Ùðûð 	�‰Õús$   Á/B Â	BÂB" ÂBÂB" Â"B4c           	   #   ó  K  — t        j                  d«      }| d   \  }}}}|j                  ||dd|› d|› �i¬«      }|› dt        «       › �}|j	                  |«       ||f–— 	 |j                  |d¬	«       y # t        $ r Y y w xY w­w)
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ˆ$�
˜JØ	×	Ñ	ØØà˜g d V¨1¨T¨FÐ3ð
ð 
ó 
€Bð �+˜Qœt›v˜hÐ'€Ià‡H�HˆYÔØ
ˆiˆ-ÒðØ
�‰ˆi 4ˆÕ(øÜò Ùðüs*   ‚A"BÁ%A9 Á8BÁ9	BÂBÂBÂBc           	   #   ó¢   K  — ddl m} | d   \  }}}}d|› d|› d|› d|› d�	}|j                  |«      \  }}|j                  d«       |||f–— y ­w)	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   \   su   è ø€ å%à)2°<Ñ)@Ñ&€Dˆ$�
˜Jà
�
ˆ|˜1˜Z˜Lð )Ø"˜V 1 T FÐ*Eð	Gð ð ×"Ñ" 3Ó'�H€Bˆà‡M�M�*Ôà
ˆc�4ˆ-Óùs   ‚AAÚclassc                 ó$   — | j                  d«      S )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   