
    <>i                         S SK r S SKrS SKr\R                  " S5      r\R
                  R                  r " S S\R                  5      rS r	\R                  " SS9S 5       r\R                  " SS9S	 5       rS
 rS rS rg)    Nzpyarrow.flightc                       \ rS rSr\R                  \R                  " S/5      \R                  R                  S5      / 5      r
S rSrg)ExampleServer   )aint32   simplec                     UR                   S:X  a  U R                  $ UR                   S:X  a  [        S5      e[        S5      e)Nr      unknownUnknown commandzUnknown descriptor)commandsimple_infoNotImplementedError)selfcontext
descriptors      ^/var/www/html/land-tabula/venv/lib/python3.13/site-packages/pyarrow/tests/test_flight_async.pyget_flight_infoExampleServer.get_flight_info#   sB    *###:-%&788!"677     N)__name__
__module____qualname____firstlineno__flight
FlightInfopyarrowschemaFlightDescriptorfor_commandr   r   __static_attributes__r   r   r   r   r      s=    ##'(++I6
K8r   r   c                    U R                   (       d]  [        R                  " [        5       nU R	                  5         S S S 5        [        R
                  " [        WR                  5      5        g g ! , (       d  f       N9= fN)supports_asyncpytestraisesr   as_asyncskipstrvalue)clientes     r   async_or_skipr-   ,   sI      ]]./1OO 0CL!	 !//s   A00
A>module)scopec               #      #    [        5        n [        R                  SU R                   35       nUv   S S S 5        S S S 5        g ! , (       d  f       N= f! , (       d  f       g = f7f)Nzgrpc://localhost:)r   r   connectport)serverr+   s     r   flight_clientr4   4   sE     	F^^/}=>&L ? 
>> 
s1   A(#AAA	A(
A	A
A%!A(c              #   F   #    [        U 5        U R                  5       v   g 7fr#   )r-   r'   r4   s    r   async_clientr7   ;   s     - 

 
 
""s   !c                    [        U R                  [        5      (       d   eU R                  (       a  U R                  5         g [        R
                  " [        5         U R                  5         S S S 5        g ! , (       d  f       g = fr#   )
isinstancer$   boolr'   r%   r&   r   r6   s    r   test_async_support_propertyr;   A   sU    m22D9999## ]]./""$ 0//s   A88
Bc                 H   ^  U 4S jn[         R                  " U" 5       5        g )Nc                     >#    [         R                  R                  S5      n TR                  U 5      I S h  vN nU[        R
                  :X  d   eg  N7f)Nr   )r   r   r    r   r   r   )r   infor7   s     r   _test#test_get_flight_info.<locals>._testK   sH     ,,88C
!11*==}00000 >s   4AAAasynciorunr7   r?   s   ` r   test_get_flight_inforE   J   s    1
 KKr   c                 H   ^  U 4S jn[         R                  " U" 5       5        g )Nc                     >#    [         R                  R                  S5      n [        R                  " [
        5       nTR                  U 5      I S h  vN   S S S 5        S[        WR                  5      ;   d   eg  N(! , (       d  f       N,= f7f)Nr
   r   )	r   r   r    r%   r&   r   r   reprr*   )r   excinfor7   s     r   r?   )test_get_flight_info_error.<locals>._testT   sj     ,,88D
]]./7..z::: 0 !D$7777 ; 0/s.   :BA=A;A=$B;A==
BBrA   rD   s   ` r   test_get_flight_info_errorrK   S   s    8 KKr   )rB   r%   r   importorskipr   mark
pytestmarkFlightServerBaser   r-   fixturer4   r7   r;   rE   rK   r   r   r   <module>rQ      s   $   			-	.[[
8F++ 8 " h   h#  #
%r   