K iJDddlZddlZddlmZGddej Zedk(rxedZejdejZ ejgZ e jejjde \ZZej%yy)NceZdZdZy)ServercVtjdtjd)N)timesleepflightFlightCancelledError)selfcontext descriptorreaderwriters _/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/pyarrow/tests/arrow_16597.pydo_putz Server.do_puts 1 ))"--N)__name__ __module__ __qualname__rrrrrs.rr__main__zgrpc://localhost:0zgrpc://localhost:r)rpyarrowpapyarrow.flightr FlightServerBaserrserverconnectportclientschemarFlightDescriptor for_commandrr done_writingrrrr%s& .V $ $.  z ( )F V^^/ }= >F RYYr]F]]++C0&:NFF  r