Ë
    ¤eh‘  ã                   ó®  — d Z ddlmZ ddlZddlmZ ddlZddlmc m	Z
 ddlZddlmZ ej                   j"                  ej                   j$                  ej                   j'                  d«      gZd„ Zd„ Zd„ Zd	„ Zd
„ Zd„ Zd„ Zd„ Zd„ Zd„ Zej                   j?                  deej@                  feejB                  fed„ f ejD                  e eejF                  d¬«       e
jH                  d«      ¬«       ejD                  e eejF                  d¬«       e
jH                  d«       e
jH                  d«      e
jJ                  g¬«      eejL                  feejN                  feej@                  feejB                  fg	«      ej                   j?                  ddddidddœg«      d„ «       «       Z(ej                   j?                  dddg«      d„ «       Z)y)z9
Tests for the pandas custom headers in http(s) requests
é    )ÚpartialN)ÚBytesIOz=ignore:Passing a BlockManager to DataFrame:DeprecationWarningc                 óÜ   — t        «       5 }t        j                  |d¬«      5 }|j                  | «       d d d «       |j	                  «       cd d d «       S # 1 sw Y   Œ"xY w# 1 sw Y   y xY w)NÚw)ÚfileobjÚmode)r   ÚgzipÚGzipFileÚwriteÚgetvalue)Úresponse_bytesÚbioÚzippers      ú_/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/pandas/tests/io/test_http_headers.pyÚ
gzip_bytesr      s]   € Ü	‹ð �cÜ�]‰] 3¨SÔ1ð 	)°VØ�L‰L˜Ô(÷	)à�|‰|‹~÷ñ ÷	)ð 	)ú÷ð ús!   ‹A"£AµA"ÁA	ÁA"Á"A+c                 óD   — | j                  d¬«      j                  d«      S ©NF)Úindexúutf-8)Úto_csvÚencode©Údfs    r   Úcsv_responderr      s   € Ø�9‰9˜5ˆ9Ó!×(Ñ(¨Ó1Ð1ó    c                 ó*   — t        t        | «      «      S ©N)r   r   r   s    r   Úgz_csv_responderr   #   s   € Ü”m BÓ'Ó(Ð(r   c                 ó@   — | j                  «       j                  d«      S )Nr   )Úto_jsonr   r   s    r   Újson_responderr!   '   s   € Ø�:‰:‹<×Ñ˜wÓ'Ð'r   c                 ó*   — t        t        | «      «      S r   )r   r!   r   s    r   Úgz_json_responderr#   +   s   € Ü”n RÓ(Ó)Ð)r   c                 óD   — | j                  d¬«      j                  d«      S r   )Úto_htmlr   r   s    r   Úhtml_responderr&   /   s   € Ø�:‰:˜Eˆ:Ó"×)Ñ)¨'Ó2Ð2r   c                 ó(   — | j                  dd¬«      S )NFÚpyarrow)r   Úengine)Ú
to_parquetr   s    r   Úparquetpyarrow_reponderr+   3   s   € Ø�=‰=˜u¨Yˆ=Ó7Ð7r   c                 ó¤   — dd l }| j                  dddd ¬«       |j                  dd«      5 }|j                  «       cd d d «       S # 1 sw Y   y xY w)Nr   z'memory://fastparquet_user_agent.parquetFÚfastparquet)r   r)   ÚcompressionÚrb)Úfsspecr*   ÚopenÚread)r   r0   Úfs      r   Úparquetfastparquet_responderr4   7   sU   € ó à‡M�MØ1ØØØð	 ô ð 
�‰Ð>ÀÓ	Eð ÈØ�v‰v‹x÷÷ ò ús   ¬AÁAc                 ó„   — t        «       5 }| j                  |«       |j                  «       cd d d «       S # 1 sw Y   y xY wr   )r   Ú	to_pickler   ©r   r   s     r   Úpickle_respnderr8   J   s3   € Ü	‹ð �cØ
�‰�SÔØ�|‰|‹~÷÷ ò ús   ‹!6¶?c                 óˆ   — t        «       5 }| j                  |d¬«       |j                  «       cd d d «       S # 1 sw Y   y xY w)NF)Úwrite_index)r   Úto_statar   r7   s     r   Ústata_responderr<   P   s7   € Ü	‹ð �cØ
�‰�C UˆÔ+Ø�|‰|‹~÷÷ ò ús	   ‹#8¸Azresponder, read_methodc                  ó2   — t        j                  | i |¤Žd   S )Nr   )ÚpdÚ	read_html)ÚargsÚkwargss     r   ú<lambda>rB   ]   s   € ¤B§L¡L°$Ð$A¸&Ñ$AÀ!Ñ$D€ r   r(   )r)   )Úmarksr-   r0   Ústorage_optionsú
User-AgentÚfooÚbar©rE   ÚAuthc                 óø  — t        j                  ddgi«      }g d¢}d| j                  v rddi}|€|}n||z  }nd }t        |«      j	                  |r|j                  «       ng «      }|j                   | |«      |¬«        ||j                  |¬«      }t        j                  ||«       t        |j                  d	   j                  «      }	|D ]%  }
|	j                  |
«      }|sŒ|
|v sŒ|||
   k(  rŒ%J ‚ |	rJ ‚y )
NÚaÚb)zAccept-EncodingÚHostÚ
ConnectionrE   ÚgzzContent-Encodingr	   )ÚcontentÚheaders)rD   r   )r>   Ú	DataFrameÚ__name__ÚsetÚunionÚkeysÚserve_contentÚurlÚtmÚassert_frame_equalÚdictÚrequestsrQ   Úpop)Ú	responderÚread_methodÚ
httpserverrD   ÚexpectedÚdefault_headersÚextraÚexpected_headersÚresultÚrequest_headersÚheaderÚexps               r   Útest_request_headersri   V   s  € ôN �|‰|˜S 3 %˜LÓ)€HÚM€OØˆy×!Ñ!Ñ!Ø# VÐ,ˆØÐ"Ø#‰Oà˜uÑ$‰OàˆÜ˜?Ó+×1Ñ1Ù"1ˆ×ÑÔ°róÐð ×Ñ¡Y¨xÓ%8À%ÐÔHÙ˜Ÿ™¸ÔI€FÜ×Ñ˜& (Ô+ä˜:×.Ñ.¨qÑ1×9Ñ9Ó:€OØ"ò 2ˆØ×!Ñ! &Ó)ˆÚ˜v¨Ò8Ø˜/¨&Ñ1Ó1Ð1Ð1ð2ñ
 ÐÐˆr   r)   c                 óô   — dddœ}t        j                  | «       t        j                  ddgi«      }d}t        j                  t
        |¬«      5  |j                  d|| ¬	«       d d d «       y # 1 sw Y   y xY w)
NÚcustomÚother_customrH   Úcolumn_nameÚcolumn_valuezxstorage_options passed with file object or non-fsspec file path|storage_options passed with buffer, or non-supported URL)Úmatchz/tmp/junk.parquet)rD   r)   )ÚpytestÚimportorskipr>   rR   ÚraisesÚ
ValueErrorr*   )r)   rQ   Útrue_dfÚmsgs       r   Ú,test_to_parquet_to_disk_with_storage_optionsrv   —   s‚   € ð Øñ€Gô
 ×Ñ˜Ôä�l‰l˜M¨NÐ+;Ð<Ó=€Gð	Cð ô 
�‰”z¨Ô	-ñ XØ×ÑÐ.ÀÐPVÐÔW÷X÷ Xñ Xús   ÁA.Á.A7)*Ú__doc__Ú	functoolsr   r	   Úior   rp   Úpandas.util._test_decoratorsÚutilÚ_test_decoratorsÚtdÚpandasr>   Úpandas._testingÚ_testingrY   ÚmarkÚ
single_cpuÚnetworkÚfilterwarningsÚ
pytestmarkr   r   r   r!   r#   r&   r+   r4   r8   r<   ÚparametrizeÚread_csvÚ	read_jsonÚparamÚread_parquetÚ
skip_if_noÚ&skip_array_manager_not_yet_implementedÚread_pickleÚ
read_statari   rv   © r   r   ú<module>r�      sò  ðñõ Û Ý ã ç )Ð )ã Ý ð ‡K�K×ÑØ
‡K�K×ÑØ
‡K�K×ÑØGóð€
òò2ò)ò(ò*ò3ò8òò&òð ‡�×ÑØà	˜Ÿ™Ð$Ø	˜Ÿ™Ð&àÙDð	
ð 	ˆ�‰Ø#Ù�B—O‘O¨IÔ6Ø�"—-‘- 	Ó*ô	
ð
 	ˆ�‰Ø(Ù�B—O‘O¨MÔ:ð �—‘˜mÓ,Ø�—‘˜hÓ'Ø×9Ñ9ðô			
ð 
˜"Ÿ.™.Ð)Ø	˜"Ÿ-™-Ð(Ø	˜2Ÿ;™;Ð'Ø	˜BŸL™LÐ)ð3óð< ‡�×ÑØàØ	�uÐØ eÑ,ðóñóó=ðLð6 ‡�×ÑØàØðóñXóñXr   