o
    hJ                     @   s   d dl Z d dlZd dlmZ G dd dejZedkr?edZe	dej
 Zeg Zeejde\ZZe  dS dS )    Nc                   @   s   e Zd Zdd ZdS )Serverc                 C   s   t d td)N    )timesleepflightFlightCancelledError)selfcontext
descriptorreaderwriter r   M/var/www/vscode/kcb/lib/python3.10/site-packages/pyarrow/tests/arrow_16597.pydo_put   s   

zServer.do_putN)__name__
__module____qualname__r   r   r   r   r   r      s    r   __main__zgrpc://localhost:0zgrpc://localhost:    )r   pyarrowpapyarrow.flightr   FlightServerBaser   r   serverconnectportclientschemar   FlightDescriptorfor_commandr   r   done_writingr   r   r   r   <module>   s   
