
    j                         d dl mZ d dlmZ d dlmZ ddlmZ  G d d          Z G d d	          Z	 G d
 de          Z
 G d de          ZdS )    )Any)SearchResult)
schema_pb2   MutationResultc                   B    e Zd ZdeddfdZdefdZdefdZd Zd	 ZdS )

BaseFuturefuturereturnNc                 4    ||nt                      | _        d S N)_EmptySearchFuture_f)selfr   s     ]/lsinfo/ai/hellotax_ai/base_platform/venv/lib/python3.11/site-packages/pymilvus/orm/future.py__init__zBaseFuture.__init__   s    ".&&4F4H4H    c                 Z    |                      | j                                                  S )zReturn the result from future object.

        It's a synchronous interface. It will wait executing until
        server respond or timeout occur(if specified).
        )on_responser   resultr   s    r   r   zBaseFuture.result   s$      0 0111r   resc                     |S r    r   r   s     r   r   zBaseFuture.on_response"   s    
r   c                 4    | j                                         S )zCancel the request.)r   cancelr   s    r   r   zBaseFuture.cancel%   s    w~~r   c                 4    | j                                         S )zWait for request done.)r   doner   s    r   r    zBaseFuture.done)   s    w||~~r   )	__name__
__module____qualname__r   r   r   r   r   r    r   r   r   r
   r
      s        Is It I I I I2 2 2 2 2s             r   r
   c                   *    e Zd ZdefdZddZddZdS )r   r   c                 B    t          t          j                              S r   )r   r   SearchResultDatar   s    r   r   z_EmptySearchFuture.result/   s    J799:::r   Nc                     d S r   r   r   s    r   r   z_EmptySearchFuture.cancel2       r   c                     d S r   r   r   s    r   r    z_EmptySearchFuture.done5   r(   r   )r   N)r!   r"   r#   r   r   r   r    r   r   r   r   r   .   sW        ; ; ; ; ;        r   r   c                       e Zd ZdefdZdS )MutationFuturer   c                      t          |          S r   r   r   s     r   r   zMutationFuture.on_response:   s    c"""r   N)r!   r"   r#   r   r   r   r   r   r+   r+   9   s/        #s # # # # # #r   r+   c                       e Zd ZdZdS )SearchFuturezmSearchFuture of async already returns SearchResult, add BaseFuture
    functions into async.SearchFuture
    N)r!   r"   r#   __doc__r   r   r   r.   r.   >   s           r   r.   N)typingr   pymilvus.client.abstractr   pymilvus.grpc_genr   mutationr   r
   r   r+   r.   r   r   r   <module>r4      s          1 1 1 1 1 1 ( ( ( ( ( ( $ $ $ $ $ $       0       # # # # #Z # # #
    :     r   