Ë
    ìmxi   ã                   ó  — d dl Z d dlZd dlZ ej                  d«      Zej
                  j                  Z G d„ dej                  «      Zd„ Z	 ej                  d¬«      d„ «       Z ej                  d¬«      d	„ «       Zd
„ Zd„ Zd„ Zy)é    Nzpyarrow.flightc                   óŒ   — e Zd Zej	                   ej                  dg«      ej                  j                  d«      g «      Z	d„ Z
y)ÚExampleServer)ÚaÚint32ó   simplec                 ó‚   — |j                   dk(  r| j                  S |j                   dk(  rt        d«      ‚t        d«      ‚)Nr   ó   unknownúUnknown commandzUnknown descriptor)ÚcommandÚsimple_infoÚNotImplementedError)ÚselfÚcontextÚ
descriptors      úV/home/htdocs/ttos/venv/lib/python3.12/site-packages/pyarrow/tests/test_flight_async.pyÚget_flight_infozExampleServer.get_flight_info#   sB   € Ø×Ñ Ò*Ø×#Ñ#Ð#Ø×Ñ :Ò-Ü%Ð&7Ó8Ð8ä!Ð"6Ó7Ð7ó    N)Ú__name__Ú
__module__Ú__qualname__ÚflightÚ
FlightInfoÚpyarrowÚschemaÚFlightDescriptorÚfor_commandr   r   © r   r   r   r      s?   „ Ø×#Ñ#Øˆ�‰˜Ð'Ó(Ø×Ñ×+Ñ+¨IÓ6Ø
ó€Kó8r   r   c                 óê   — | j                   s[t        j                  t        «      5 }| j	                  «        d d d «       t        j
                  t        j                  «      «       y y # 1 sw Y   Œ3xY w©N)Úsupports_asyncÚpytestÚraisesr   Úas_asyncÚskipÚstrÚvalue)ÚclientÚes     r   Úasync_or_skipr)   ,   sR   € Ø× Ò ä�]‰]Ô.Ó/ð 	°1Ø�O‰OÔ÷	ä�‰”C˜Ÿ™“LÕ!ð	 !÷	ð 	ús   ¦A)Á)A2Úmodule)Úscopec               #   óÀ   K  — t        «       5 } t        j                  d| j                  › �«      5 }|–— d d d «       d d d «       y # 1 sw Y   ŒxY w# 1 sw Y   y xY w­w)Nzgrpc://localhost:)r   r   ÚconnectÚport)Úserverr'   s     r   Úflight_clientr0   4   sZ   è ø€ ä	‹ð ˜FÜ�^‰^Ð/°·±¨}Ð=Ó>ð 	À&ØŠL÷	÷ð ÷	ð 	ú÷ð üs1   ‚A�#A°AµA½	AÁA	ÁAÁAÁAc              #   óF   K  — t        | «       | j                  «       –— y ­wr   )r)   r#   ©r0   s    r   Úasync_clientr3   ;   s   è ø€ ä�-Ô Ø
×
 Ñ
 Ó
"Ó"ùs   ‚!c                 óò   — t        | j                  t        «      sJ ‚| j                  r| j                  «        y t	        j
                  t        «      5  | j                  «        d d d «       y # 1 sw Y   y xY wr   )Ú
isinstancer    Úboolr#   r!   r"   r   r2   s    r   Útest_async_support_propertyr7   A   s[   € Ü�m×2Ñ2´DÔ9Ð9Ð9Ø×#Ò#Ø×ÑÕ ä�]‰]Ô.Ó/ñ 	%Ø×"Ñ"Ô$÷	%÷ 	%ñ 	%ús   ÁA-Á-A6c                 óD   ‡ — ˆ fd„}t        j                   |«       «       y )Nc               “   ó¬   •K  — t         j                  j                  d«      } ‰j                  | «      ƒ d {  –—† }|t        j
                  k(  sJ ‚y 7 Œ­w)Nr   )r   r   r   r   r   r   )r   Úinfor3   s     €r   Ú_testz#test_get_flight_info.<locals>._testK   sI   øè ø€ Ü×,Ñ,×8Ñ8¸ÓCˆ
Ø!×1Ñ1°*Ó=×=ˆØ”}×0Ñ0Ò0Ð0Ñ0ð >ús   ƒ4A·A¸A©ÚasyncioÚrun©r3   r;   s   ` r   Útest_get_flight_infor@   J   s   ø€ ô1ô
 ‡K�K‘“Õr   c                 óD   ‡ — ˆ fd„}t        j                   |«       «       y )Nc               “   ó  •K  — t         j                  j                  d«      } t        j                  t
        «      5 }‰j                  | «      ƒ d {  –—†  d d d «       dt        j                  «      v sJ ‚y 7 Œ&# 1 sw Y   Œ%xY w­w)Nr	   r
   )	r   r   r   r!   r"   r   r   Úreprr&   )r   Úexcinfor3   s     €r   r;   z)test_get_flight_info_error.<locals>._testT   ss   øè ø€ Ü×,Ñ,×8Ñ8¸ÓDˆ
Ü�]‰]Ô.Ó/ð 	;°7Ø×.Ñ.¨zÓ:×:Ð:÷	;ð !¤D¨¯©Ó$7Ñ7Ð7Ñ7ð ;ø÷	;ð 	;üs.   ƒ9B¼A:ÁA8ÁA:Á"BÁ8A:Á:BÁ?Br<   r?   s   ` r   Útest_get_flight_info_errorrE   S   s   ø€ ô8ô ‡K�K‘“Õr   )r=   r!   r   Úimportorskipr   ÚmarkÚ
pytestmarkÚFlightServerBaser   r)   Úfixturer0   r3   r7   r@   rE   r   r   r   ú<module>rK      s–   ðó$ ã ã à	ˆ×	Ñ	Ð-Ó	.€Ø�[‰[×Ñ€
ô8�F×+Ñ+ô 8ò "ð €‡��hÔñó  ðð €‡��hÔñ#ó  ð#ò
%òór   