
    gJ                     D   d dl Z d dlZd dlmZ  G d dej
                        Zedk(  rx ed      Z ej                  dej                         Z ej                  g       Zej                  ej                  j                  d      e      \  ZZej%                          yy)    Nc                       e Zd Zd Zy)Serverc                 V    t        j                  d       t        j                  d      )N    )timesleepflightFlightCancelledError)selfcontext
descriptorreaderwriters        N/var/www/openai/venv/lib/python3.12/site-packages/pyarrow/tests/arrow_16597.pydo_putzServer.do_put   s    

1))"--    N)__name__
__module____qualname__r    r   r   r   r      s    .r   r   __main__zgrpc://localhost:0zgrpc://localhost:r   )r   pyarrowpapyarrow.flightr
   FlightServerBaser   r   serverconnectportclientschemar   FlightDescriptorfor_commandr   r   done_writingr   r   r   <module>r%      s   &   .V$$ . z()FV^^/}=>FRYYr]F]]++C0&:NFF
 r   