Ë
    êéñi¶&  ã                   ó˜  — d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlZg d¢Z	i dd“dd“d	 ej                  d	«      “d
 ej                  d
«      “dd“dd“dd“dd“dd“dd“dd“d ej                  d«      “dd“dd“dd“d ej                  d«      “dd“i dd“dd“dd“dd“dd“dd“dd“d d“d!d“d"d“d#d“d$ ej                  d$«      “d%d“d&d“d' e«       “d(d“d) ej                  d)«      “¥Zej                  d*k(  rded<   ded <   ded%<   ej                  d*k(  rej                  j                  d+«      ed(<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d dlZej                  d,k(  rded<   ned(   ed<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d d-lmZ ded<   	 d d.lmZ ded<   	 d d/lmZ ded"<   	 d d0lmZ ded<   	 d dl Zded&<   d1„ Z! e jD                  d¬2«      d3„ «       Z# e jD                  d¬2«      d4„ «       Z$ e jD                  d5¬6«      d7„ «       Z% e jD                  d5¬6«      d8„ «       Z& e jD                  d5¬6«      d9„ «       Z'y# e$ r Y �Œ?w xY w# e$ r Y �ŒAw xY w# e$ r Y �ŒCw xY w# e$ r Y �ŒEw xY w# e$ r Y �ŒGw xY w# e$ r Y �Œ1w xY w# e$ r	 ded<   Y �Œ8w xY w# e$ r	 ded<   Y �Œ?w xY w# e$ r Y �ŒAw xY w# e$ r Y �ŒCw xY w# e$ r Y �ŒEw xY w# e$ r Y �ŒEw xY w# e$ r Y �ŒEw xY w# e$ r Y �ŒEw xY w# e$ r Y �ŒEw xY w# e$ r Y �ŒGw xY w):é    N)ÚCodec)Úfs)Úis_threading_enabled)"ÚaceroÚazureÚbrotliÚbz2ÚcythonÚdatasetÚ
hypothesisÚfastparquetÚflightÚgandivaÚgcsÚgdbÚgzipÚhdfsÚlarge_memoryÚlz4Úmemory_leakÚnopandasÚnonumpyÚnumpyÚorcÚpandasÚparquetÚparquet_encryptionÚ	processesÚrequires_testing_dataÚs3ÚslowÚsnappyÚsocketsÚ	substraitÚ	threadingÚtimezone_dataÚzstdr   Fr   r   r	   r
   r   r   r   r   r   r   Tr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r    r!   r"   r#   r$   r%   r&   r'   Ú
emscriptenz/usr/share/zoneinfoÚwin32)ÚAzureFileSystem)ÚGcsFileSystem©ÚS3FileSystem)ÚHadoopFileSystemc                 óÐ  — d„ }|j                   j                  rvdt        | «      v ryg d¢}|D ]  }d|› �t        | «      v sŒt        |   rŒ y dt        | «      v r
t        d   sydt        | «      v r |«        S d	t        | «      v r	 d
dlm} yt        |j                   dd«      r1dt        | «      v rydt        | «      v rydt        | «      v r |«        S y# t        $ r Y yw xY w)Nc                  ó,   — 	 dd l } y# t        $ r Y yw xY w)Nr   TF)Úpyarrow.cudaÚImportError)Úpyarrows    úR/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/pyarrow/conftest.pyÚ_cuda_is_availablez1pytest_ignore_collect.<locals>._cuda_is_availableÚ   s   € ð	ÛØøÜò 	Ùð	ús   ‚ ‡	’z/pyarrow/tests/T)r   r   r   r   r$   zpyarrow/zpyarrow/parquet/encryptionr   zpyarrow/cudaz
pyarrow/fsr   r,   FÚdoctest_cythonz/pyarrow/_parquet_encryptionz/pyarrow/_cuda)ÚoptionÚdoctestmodulesÚstrÚdefaultsÚ
pyarrow.fsr-   r2   Úgetattr)Úcollection_pathÚconfigr5   Údoctest_groupsÚgroupr-   s         r4   Úpytest_ignore_collectrA   Ù   s  € òð ‡}�}×#Ò#à¤ OÓ 4Ñ4Øò
ˆð $ò 	 ˆEØ˜%˜Ð!¤S¨Ó%9Ò9Ü “Ùð	 ð
 (¬3¨Ó+?Ñ?ÜÐ0Ò1ØàœS Ó1Ñ1Ù)Ó+Ð+Ð+àœ3˜Ó/Ñ/ðÝ3Øô ˆv�}‰}Ð.°Ô6Ø¤ OÓ 4Ñ4ØØ)¬S°Ó-AÑAØØœs ?Ó3Ñ3Ù)Ó+Ð+Ð+àøô ò Ùðús   Â	C Ã	C%Ã$C%)Úautousec              #   ó  K  — | j                   j                  j                  }t        | j                   j                  dd«      }|s|r/| j	                  d«      }|j                  «       5  d –— d d d «       y d –— y # 1 sw Y   y xY w­w)Nr6   FÚtmpdir)r>   r7   r8   r<   ÚgetfixturevalueÚas_cwd)ÚrequestÚ	doctest_mÚ	doctest_crD   s       r4   Ú_docdirrJ     sy   è ø€ ð —‘×%Ñ%×4Ñ4€IÜ˜Ÿ™×-Ñ-Ð/?ÀÓG€Iá‘Ið ×(Ñ(¨Ó2ˆð �]‰]‹_ñ 	Û÷	ð 	ô 	÷		ð 	üs   ‚A'BÁ)A<Á.BÁ<BÂBc              #   ó¤  K  — |j                   j                  j                  }t        |j                   j                  dd«      }|s|rwt        | d<   t	        j
                  «       }|dz  }|j                  t        |«      «      5 }|j                  d«       d d d «       || d<   t        |«      | d<   t        |«      | d<   d –— y # 1 sw Y   Œ/xY w­w)	Nr6   Fr   zpyarrow-fs-example.dats   dataÚlocalÚ
local_pathÚpath)	r>   r7   r8   r<   r   ÚLocalFileSystemÚopen_output_streamr9   Úwrite)Údoctest_namespacerG   Útmp_pathrH   rI   rL   rN   Ústreams           r4   Úadd_fsrU   #  sÁ   è ø€ ð —‘×%Ñ%×4Ñ4€IÜ˜Ÿ™×-Ñ-Ð/?ÀÓG€Iá‘Iä"$Ð˜$Ñô ×"Ñ"Ó$ˆØÐ2Ñ2ˆØ×%Ñ%¤c¨$£iÓ0ð 	"°FØ�L‰L˜Ô!÷	"à%*Ð˜'Ñ"Ü*-¨h«-Ð˜,Ñ'Ü$'¨£IÐ˜&Ñ!Ü	÷	"ð 	"üs   ‚BCÂCÂ.CÃCÃ	CÚsession)Úscopec                  ó¦   ‡— ddl mŠ ˆfd„} d}dddœ}‰j                  | ||dt        j                  «       it        j                  «       «       | |fS )	z+
    Register a unary scalar function.
    r   ©Úcomputec                 óD   •— ‰j                  d|dg| j                  ¬«      S )NÚaddé   )Úmemory_pool)Úcall_functionr^   )ÚctxÚxÚpcs     €r4   Úunary_functionz*unary_func_fixture.<locals>.unary_functionA  s*   ø€ Ø×Ñ ¨¨1 vØ,/¯O©Oð  ó =ð 	=ó    zy=x+1zadd functionztest add function©ÚsummaryÚdescriptionÚarray)r3   rZ   Úregister_scalar_functionÚpaÚint64)rc   Ú	func_nameÚ	unary_docrb   s      @r4   Úunary_func_fixturern   :  s[   ø€ õ
 &ô=ð €IØ*Ø 3ñ5€Ià×Ñ Ø )Ø )Ø!(¬"¯(©(«*Ð 5Ü "§¡£
ô	,ð
 ˜9Ð$Ð$rd   c                  ó®   ‡— ddl m}  ddlŠˆfd„}d}dddœ}| j                  |||d	t	        j
                  «       it	        j
                  «       «       ||fS )
z4
    Register a unary aggregate function (mean)
    r   rY   Nc                 óL   •— t        j                  ‰j                  |«      «      S )N)rj   ÚscalarÚnanmean)r`   ra   Únps     €r4   Úfuncz$unary_agg_func_fixture.<locals>.funcW  s   ø€ Ü�y‰y˜Ÿ™ A›Ó'Ð'rd   Úmean_udfzy=avg(x)zfind mean of xre   ra   )r3   rZ   r   Úregister_aggregate_functionrj   Úfloat64©rb   rt   rl   Úfunc_docrs   s       @r4   Úunary_agg_func_fixturerz   O  sc   ø€ õ
 &Ûô(ð €IØ%Ø/ñ1€Hð ×"Ñ" 4Ø#,Ø#+à'*¬B¯J©J«Lð$%ô $&§:¡:£<ô%ð �ˆ?Ðrd   c                  óÔ   ‡— ddl m}  ddlŠˆfd„}d}dddœ}| j                  |||t	        j
                  «       t	        j                  «       dœt	        j                  «       «       ||fS )	z-
    Register a unary aggregate function
    r   rY   Nc                 óh   •— d}|D ]  }|‰j                  |«      z  }Œ t        j                  |«      S )Ng        )rr   rj   rq   )r`   ÚargsÚsumÚargrs   s       €r4   rt   z&varargs_agg_func_fixture.<locals>.funcq  s7   ø€ ØˆØò 	#ˆCØ�2—:‘:˜c“?Ñ"‰Cð	#ä�y‰y˜‹~Ðrd   Úsum_meanzVarargs aggregatere   )ra   Úy)r3   rZ   r   rv   rj   rk   rw   rx   s       @r4   Úvarargs_agg_func_fixturer‚   i  sj   ø€ õ
 &Ûôð €IØ.Ø2ñ4€Hð ×"Ñ" 4Ø#,Ø#+ä,.¯H©H«JÜ,.¯J©J«Lñ$%ô $&§:¡:£<ô%ð �ˆ?Ðrd   )(ÚpytestÚosr3   rj   r   r   Úpyarrow.libr   ÚsysÚgroupsÚis_availabler:   ÚplatformrN   Úexistsr
   r2   r   Úpyarrow.gandivaÚpyarrow.aceroÚpyarrow.datasetÚpyarrow.orcr   r   Úpyarrow.parquetÚpyarrow.parquet.encryptionÚpyarrow.flightr;   r*   r+   r-   r.   Úpyarrow.substraitrA   ÚfixturerJ   rU   rn   rz   r‚   © rd   r4   ú<module>r•      sŠ  ðó$ ã 	Û Ý Ý Ý ,Û 
ò#
€ðJ#ØˆUð#àˆUð#ð Ð ˆe× Ñ  Ó*ð#ð 
Ðˆ5×Ñ˜eÓ$ð	#ð
 ˆeð#ð ˆuð#ð �5ð#ð ˆeð#ð ˆuð#ð 
ˆ5ð#ð 
ˆ4ð#ð ÐˆE×Ñ˜vÓ&ð#ð ˆEð#ð �%ð#ð �Eð#ð  
Ðˆ5×Ñ˜eÓ$ð!#ð" �5ñ##ð$ �ð%#ð& ˆuð'#ð( ˆUð)#ð* 
ˆ5ð+#ð, ˆeð-#ð. ˆuð/#ð0 ˜%ð1#ð2 �ð3#ð4 ˜Tð5#ð6 	ˆ%ð7#ð8 ˆEð9#ð: Ð ˆe× Ñ  Ó*ð;#ð< ˆtð=#ð> �ð?#ð@ Ñ%Ó'ðA#ðB �TðC#ðD ÐˆE×Ñ˜vÓ&ñE#€ðJ ‡<�<�<Òð €HˆU�OØ!€Hˆ[ÑØ€HˆYÑà‡<�<�<ÒØ "§¡§¡Ð/DÓ E€Hˆ_Ñð	ÛØ€HˆXÑð	ÛØ"€Hˆ]Ñð	ÛØ€HˆYÑð	ÛØ€HˆWÑð	ÛØ€HˆYÑð
	ÛØ
‡|�|�wÒØˆ�Šð
 # ?Ñ3ˆ�‰ð ÛØ€HˆXÑðÛØ€HˆWÑð	ÛØ€HˆYÑð	Û%Ø%)€HÐ!Ñ"ð	ÛØ€HˆXÑð	Ý*Ø€HˆWÑð	Ý(Ø€HˆU�Oð	Ý'Ø€HˆT�Nð	Ý+Ø€HˆVÑð	ÛØ €Hˆ[Ñò1ðj €‡�˜Ôñó ðð( €‡�˜Ôñ
ó ð
ð, €‡��iÔ ñ%ó !ð%ð( €‡��iÔ ñó !ðð2 €‡��iÔ ñó !ñøðm ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò  Ø€HˆZÔð ûð ò Ø€HˆYÔðûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ús   Å	J Å	J Å	J Å 	J& Å*	J2 Å4!J> Æ	K
 Æ 	K Æ*	K, Æ4	K8 Æ>	L ÇL ÇL Ç L( Ç,L4 Ç8	M  ÊJÊ
JÊJÊJÊJ#Ê"J#Ê&J/Ê.J/Ê2J;Ê:J;Ê>KËKË

KËKË
K)Ë(K)Ë,K5Ë4K5Ë8LÌ LÌLÌLÌLÌLÌL%Ì$L%Ì(L1Ì0L1Ì4L=Ì<L=Í M	ÍM	