K i ddlZddlZddlZejdZej jZGddejZdZ ejddZ ejdd Z d Z d Zd Zy) Nzpyarrow.flightceZdZej ej dgejjdgZ dZ y) ExampleServer)aint32simplec|jdk(r |jS|jdk(r tdtd)NrunknownUnknown commandzUnknown descriptor)command simple_infoNotImplementedError)selfcontext descriptors e/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/pyarrow/tests/test_flight_async.pyget_flight_infozExampleServer.get_flight_info#sB    *## #   : -%&78 8!"677N) __name__ __module__ __qualname__flight FlightInfopyarrowschemaFlightDescriptor for_commandr rrrrrs?##'(++I6 K 8rrc|js[tjt5}|j dddtj t jyy#1swY3xYwN)supports_asyncpytestraisesr as_asyncskipstrvalue)clientes r async_or_skipr),sR  ]]. / 1 OO   CL! !  s A))A2module)scopec#Kt5}tjd|j5}|ddddddy#1swYxYw#1swYyxYww)Nzgrpc://localhost:)rrconnectport)serverr's r flight_clientr04sZ F ^^/ }= > &L   s1 A#AAA AA AAAc#FKt||jywr)r)r#r0s r async_clientr3;s-  ""s!ct|jtsJ|jr|jyt j t 5|jdddy#1swYyxYwr) isinstancer boolr#r!r"r r2s rtest_async_support_propertyr7As[ m22D 99 9## ]]. / %  " " $ % % %s A--A6cDfd}tj|y)NcKtjjd}j|d{}|tj k(sJy7w)Nr)rrrrrr )rinfor3s r_testz#test_get_flight_info.._testKsI,,88C !11*==}00000>s4AAAasynciorunr3r;s` rtest_get_flight_infor@Js1  KKrcDfd}tj|y)NcKtjjd}tjt 5}j |d{ddddtjvsJy7&#1swY%xYww)Nr r ) rrrr!r"r rreprr&)rexcinfor3s rr;z)test_get_flight_info_error.._testTss,,88D ]]. / ;7..z: : : ;!D$7777 ; ; ;s.9BA:A8A:"B8A::B?Br<r?s` rtest_get_flight_info_errorrESs8 KKr)r=r!r importorskiprmark pytestmarkFlightServerBaserr)fixturer0r3r7r@rErrrrKs$    - . [[    8F++ 8 "h  h# # %r