+
    nDj                         ^ RI t ^ RIt^ RIt]P                  ! R4      t]P
                  P                  t ! R R]P                  4      tR t	]P                  ! RR7      R 4       t]P                  ! RR7      R	 4       tR
 tR tR tR# )    Nzpyarrow.flightc                      a  ] tR t^t o ]P                  ]P                  ! R.4      ]P                  P                  R4      . 4      t
R tRtV tR# )ExampleServer   simplec                    VP                   R 8X  d   V P                  # VP                   R8X  d   \        R4      h\        R4      h)r      unknownUnknown commandzUnknown descriptor)commandsimple_infoNotImplementedError)selfcontext
descriptors   &&&Y/data/cameron/venvs/s3viz/lib/python3.14/site-packages/pyarrow/tests/test_flight_async.pyget_flight_infoExampleServer.get_flight_info#   sB    *###:-%&788!"677     N)aint32)__name__
__module____qualname____firstlineno__flight
FlightInfopyarrowschemaFlightDescriptorfor_commandr
   r   __static_attributes____classdictcell__)__classdict__s   @r   r   r      sE     ##'(++I6
K8 8r   r   c                    V P                   '       gg   \        P                  ! \        4      ;_uu_ 4       pV P	                  4        R R R 4       \        P
                  ! \        XP                  4      4       R # R #   + '       g   i     L=; iN)supports_asyncpytestraisesr   as_asyncskipstrvalue)clientes   & r   async_or_skipr.   ,   sO       ]].//1OO 0CL!	 !//s   A;;B	module)scopec            	   #      "   \        4       ;_uu_ 4       p \        P                  R V P                   24      ;_uu_ 4       pVx  RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i5i)zgrpc://localhost:N)r   r   connectport)serverr,   s     r   flight_clientr5   4   sL     	F^^/}=>>&L ? 
>> 
s4   A>+A* A	A*
A>A'"A**A;	5	A>c              #   H   "   \        V 4       V P                  4       x  R # 5ir$   )r.   r(   r5   s   &r   async_clientr8   ;   s     - 

 
 
""s    "c                 0   \        V P                  \        4      '       g   Q hV P                  '       d   V P                  4        R # \        P
                  ! \        4      ;_uu_ 4        V P                  4        R R R 4       R #   + '       g   i     R # ; ir$   )
isinstancer%   boolr(   r&   r'   r   r7   s   &r   test_async_support_propertyr<   A   s^    m22D9999### ]].//""$ 0///s   )BB	c                 J   a  V 3R  lp\         P                  ! V! 4       4       R# )c                     <"   \         P                  P                  R 4      p SP                  V 4      G Rj  xL
 pV\        P
                  8X  g   Q hR#  L5i)r   N)r   r   r   r   r   r
   )r   infor8   s     r   _test#test_get_flight_info.<locals>._testK   sH     ,,88C
!11*==}00000 >s   4AAANasynciorunr8   r@   s   f r   test_get_flight_inforF   J   s    1
 KKr   c                 J   a  V 3R  lp\         P                  ! V! 4       4       R# )c                  8  <"   \         P                  P                  R 4      p \        P                  ! \
        4      ;_uu_ 4       pSP                  V 4      G Rj  xL
  RRR4       R\        XP                  4      9   g   Q hR#  L*  + '       g   i     L0; i5i)r   Nr   )	r   r   r   r&   r'   r   r   reprr+   )r   excinfor8   s     r   r@   )test_get_flight_info_error.<locals>._testT   sm     ,,88D
]].//7..z::: 0 !D$7777 ; 0/s0   ABBBB&BBB	BNrB   rE   s   f r   test_get_flight_info_errorrL   S   s    8 KKr   )rC   r&   r   importorskipr   mark
pytestmarkFlightServerBaser   r.   fixturer5   r8   r<   rF   rL   r   r   r   <module>rR      s   $   			-	.[[
8F++ 8 " h   h#  #
%r   