§
     �’j»Ü ã                   ó‚  — d dl Zd dlZd dlZd dlmZ d dlmZ d dlm	Z	m
Z
mZmZmZmZmZmZ d dlZd dlmZ d dlmZmZ d dlmZ d dlmZmZ d d	lmZ d d
lmZ d dlm Z  d dl!m"Z" d dl#m$Z$m%Z% d dl&m'Z( d dl)m*Z+ d dl,m-Z- d dl.m/Z/m0Z0m1Z1 d dl2m3Z3m4Z4m5Z5 d dl6m7Z7 d dl8m9Z9 d dl:m;Z; d dl<m=Z= d dl>m?Z?  G d„ de"¦  «        Z@dS )é    N)Úget_all_start_methods)ÚThread)ÚAnyÚ	AwaitableÚCallableÚIterableÚMappingÚSequenceÚTypeÚget_args)ÚCompression)ÚUrlÚ	parse_url)Úurljoin)Úshow_warningÚshow_warning_once)Úgrpc)Ú	construct)Ú
BearerAuth)ÚAsyncQdrantBase)Úis_compatibleÚget_server_version)Úget_async_channel)Úcommon_types)Úget_args_subscribed)Ú
GrpcToRestÚ
RestToGrpcÚ!grpc_payload_schema_to_field_type)ÚAsyncApiClientÚ	AsyncApisÚmodels)Úasync_rest_headers_middleware)ÚParallelWorkerPool)ÚGrpcBatchUploader)ÚRestBatchUploader)ÚBaseUploaderc            '       ó¬  ‡ — e Zd ZdZdZ	 	 	 	 	 	 	 	 	 	 	 	 	 	 dºdedz  d	edz  d
edededz  dedz  dedz  dedz  dedz  deee	f         dz  de
g ef         e
g ee         f         z  dz  dededz  deeef         dz  de	fˆ fd„Zededeee	f         de	deddf
d„¦   «         Zedefd„¦   «         Zd»dedz  de	ddfd„Zededeedz  eedz  edz  f         fd „¦   «         Zdefd!„Zd¼d"„Zd¼d#„Zd¼d$„Zd¼d%„Zd¼d&„Zdefd'„Zedej        fd(„¦   «         Zedej        fd)„¦   «         Z edej!        fd*„¦   «         Z"edej#        fd+„¦   «         Z$ede%e&         fd,„¦   «         Z'ede%e&         fd-„¦   «         Z(	 	 	 	 	 	 	 	 	 	 	 	 	 	 d½d/ed0e)j*        e+e         z  e+e+e                  z  e)j,        z  e)j-        z  e)j.        z  e)j/        z  e)j0        z  e)j1        z  dz  d1edz  d2e)j2        e+e)j2                 z  dz  d3e)j3        dz  d4e)j4        dz  d5ed6edz  d7ee5e         z  e)j6        z  d8ee5e         z  d9edz  d:e)j7        dz  d;e)j8        dz  d<e)j9        dz  dedz  de	de)j:        f"d=„Z;	 	 d¾d/ed>e5e)j<                 d;e)j8        dz  dedz  de	de+e)j:                 fd?„Z=	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d¿d/ed@ed0e)j*        e+e         z  e+e+e                  z  e)j,        z  e)j-        z  e)j.        z  e)j/        z  e)j0        z  e)j1        z  dz  d1edz  d2e)j2        e+e)j2                 z  dz  d3e)j3        dz  d4e)j4        dz  d5edAed7ee5e         z  e)j6        z  d8ee5e         z  d9edz  dBe)j>        dz  d:e)j7        dz  d;e)j8        dz  d<e)j9        dz  dedz  de	de)j?        f&dC„Z@	 	 	 	 	 	 	 dÀd/ed3e)j3        dz  d5edDed1edz  d;e)j8        dz  d<e)j9        dz  dedz  de	de)jA        fdE„ZB	 	 	 	 	 	 	 dÀd/ed3e)j3        dz  d5edDed1edz  d;e)j8        dz  d<e)j9        dz  dedz  de	de)jC        fdF„ZD	 	 	 	 	 	 	 	 	 dÁd/edGe)j3        dz  d5edHe)jE        dz  d6e)j*        dz  d7ee5e         z  e)j6        z  d8ee5e         z  d;e)j8        dz  d<e)j9        dz  dedz  de	dee+e)jF                 e)j*        dz  f         fdI„ZG	 	 	 	 	 dÂd/edJe)j3        dz  dKed<e)j9        dz  dedz  d;e)j8        dz  de	de)jH        fdL„ZI	 	 	 	 	 	 dÃd/edMedNe)j3        dz  d5edKededz  d;e)j8        dz  d<e)j9        dz  de	de)jJ        fdO„ZK	 	 	 	 	 	 dÄd/edPe)jL        dQedRe)jM        dz  d<e)j9        dz  dSe)j3        dz  dTe)jN        dz  dedz  de	de)jO        fdU„ZP	 	 	 	 	 dÅd/edPe5e)jQ                 dQedRe)jM        dz  d<e)j9        dz  dSe)j3        dz  dedz  de	de)jO        fdV„ZR	 	 	 	 dÆd/edWe5e         dPe)jS        dQedRe)jM        dz  d<e)j9        dz  dedz  de	de)jO        fdX„ZT	 	 	 	 	 dÇd/edYe5e)j*                 d7ee5e         z  e)j6        z  d8ee5e         z  d;e)j8        dz  d<e)j9        dz  dedz  de	de+e)jF                 fdZ„ZUeVdPe)jS        deejS        ej9        dz  f         fd[„¦   «         ZWeVdPe)jS        d<e)j9        dz  deXjS        fd\„¦   «         ZYeVd]ejS        de+ej*                 fd^„¦   «         ZZeVdPe)jS        dee+eXj[                 dz  eXj3        dz  f         fd_„¦   «         Z\	 	 	 	 dÆd/ed]e)jS        dQedRe)jM        dz  d<e)j9        dz  dedz  de	de)jO        fd`„Z]	 	 	 	 	 dÂd/edae)j^        dPe)jS        dMedz  dQedRe)jM        dz  d<e)j9        dz  dedz  de	de)jO        fdb„Z_	 	 	 	 dÆd/edae)j^        dPe)jS        dQedRe)jM        dz  d<e)j9        dz  dedz  de	de)jO        fdc„Z`	 	 	 	 dÆd/edde5e         dPe)jS        dQedRe)jM        dz  d<e)j9        dz  dedz  de	de)jO        fde„Za	 	 	 	 dÆd/ed]e)jS        dQedRe)jM        dz  d<e)j9        dz  dedz  de	de)jO        fdf„Zb	 	 	 dÈd/edge5e)jc                 dQedRe)jM        dz  dedz  de	de+e)jO                 fdh„Zd	 d»die5e)je                 dedz  de	defdj„Zfd/ede	de)jg        fdk„Zhde	de)jg        fdl„Zide	de)jj        fdm„Zkd/ede	de)jl        fdn„Zmd/ede	defdo„Zn	 	 	 	 	 	 	 	 	 dÉd/edpe)jo        dz  dqe)jp        dz  dre)jq        dz  dse)jr        dz  dte)js        dz  dedz  duetee)ju        f         dz  dve)jv        dz  dwe)j^        dz  de	defdx„Zw	 d»d/ededz  de	defdy„Zx	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dÊd/edre)jy        etee)jy        f         z  dz  dzedz  d{edz  d|edz  d}edz  dse)jr        dz  dpe)jo        dz  d~e)jz        dz  dte)j{        dz  dedz  duetee)ju        f         dz  de)j|        dz  dve)jv        dz  dwe)j^        dz  dae)j}        dz  de	def$d€„Z~	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dÊd/edre)jy        etee)jy        f         z  dz  dzedz  d{edz  d|edz  d}edz  dse)jr        dz  dpe)jo        dz  d~e)jz        dz  dte)j{        dz  dedz  duetee)ju        f         dz  de)j|        dz  dve)jv        dz  dwe)j^        dz  dae)j}        dz  de	def$d�„Zede€e�         fd‚„¦   «         Z‚	 	 	 	 	 	 dËd„eƒd/ed…ed†ed‡edz  dQed<e)j9        dz  dSe)j3        dz  dTe)jN        dz  ddfdˆ„Z„	 	 	 	 	 	 	 	 dÌd/edPeƒe)j…                 dŠed†ed‡edz  d…edQed<e)j9        dz  dSe)j3        dz  dTe)jN        dz  de	ddfd‹„Z†	 	 	 	 	 	 	 	 	 	 dÍd/edWeee)j.        f         e)j.        z  eƒe)j‡                 z  daeƒee	e	f                  dz  dYeƒe)j*                 dz  dŠed†ed‡edz  d…edQed<e)j9        dz  dSe)j3        dz  dTe)jN        dz  de	ddfdŒ„Zˆ	 	 	 	 	 dÎd/ed�edŽe)j‰        dz  d�e)j‰        dz  dQedRe)jM        dz  dedz  de	de)jO        fd�„ZŠ	 	 	 dÈd/ed�edQedRe)jM        dz  dedz  de	de)jO        fd‘„Z‹	 	 	 dÈd/ed’ed“e)jŒ        dQedRe)jM        dz  dedz  de	de)jO        fd”„Z�	 	 	 dÈd/ed’edQedRe)jM        dz  dedz  de	de)jO        fd•„ZŽd/ede	de+e)j�                 fd–„Z�	 dÏd/edQede	de)j�        dz  fd—„Z‘	 dÏd/ed˜edQede	dedz  f
d™„Z’de	de+e)j�                 fdš„Z“	 dÏdQede	de)j�        fd›„Z”	 dÏd˜edQede	dedz  fdœ„Z•	 	 	 	 dÐd/ed�ededz  džedz  dŸe)j–        dz  dQede	dedz  fd „Z—d/ed¡ede	de+e)j�                 fd¢„Z˜	 dÏd/ed¡edQede	de)j�        dz  f
d£„Z™	 dÏd/ed¡ed˜edQede	dedz  fd¤„Zš	 	 	 	 dÐd/ed¡ed�ededz  džedz  dŸe)j–        dz  dQede	dedz  fd¥„Z›	 	 	 	 	 dÑd/ed¦e)jœ        d§edz  d{edz  d¨e+e         dz  d©e)j�        dz  dedz  de	defdª„Zž	 d»d/ed¦e)jœ        dedz  de	def
d«„ZŸde)j         fd¬„Z¡	 d»d/ed­e)j¢        dedz  de	def
d®„Z£de)j¤        fd¯„Z¥defd°„Z¦	 d¾d±ed²edz  dedz  de	def
d³„Z§d/ede)j¨        fd´„Z©	 d»d/edµedz  de	de)jª        fd¶„Z«d/ede	de)j¬        fd·„Z­	 d¾d¸edz  dedz  de	de)j®        fd¹„Z¯ˆ xZ°S )ÒÚAsyncQdrantRemoteé   é   Né½  é¾  FTÚurlÚportÚ	grpc_portÚprefer_grpcÚhttpsÚapi_keyÚprefixÚtimeoutÚhostÚgrpc_optionsÚauth_token_providerÚcheck_compatibilityÚ	pool_sizeÚheadersÚkwargsc                 óp  •—  t          ¦   «         j        d6i |¤Ž || _        || _        |
pi | _        |�|n|d u| _        | j        rdnd| _        d | _        |�t          d|¦  «        }|| _        |pd| _	        t          | j	        ¦  «        dk    r | j	        d         dk    rd| j	        › �| _	        |�|	�t          d|› d|	› �¦  «        ‚|	�9|	                     d	¦  «        s|	                     d
¦  «        rt          d¦  «        ‚|rÖ|                     d¦  «        rd|› �}t          |¦  «        }|j        |j        c| _        | _        |j        r|j        dk    | _        |j        | _        | j        r| j        n|| _        | j	        r!|j        rt          d|› d|j        › �¦  «        ‚|j        r|j        | _	        | j        dvrt          d| j        › �¦  «        ‚n|	pd| _        || _        |�t)          j        |¦  «        nd }|| _        || _        |                     dd ¦  «        }|€B| j        dv rt3          j        d d¬¦  «        }n>| j        �t3          j        | j        ¬¦  «        }n| j        �t          d|› d|› �¦  «        ‚|                     dd¦  «        }g | _        d„ |                     di ¦  «                             ¦   «         D ¦   «         | _        |r@|                     ¦   «         D ]+\  }}|| j        |<   | j                             ||f¦  «         Œ,|�†| j        dk    rt?          dt@          d¬¦  «         tC          d„ | j        D ¦   «         ¦  «        s	d | j        v rtE          d!t@          d¬¦  «         || j        d <   | j                             d |f¦  «         tF          j$         %                    d"¦  «        }tM          j'        ¦   «         }d#|› d$|› �}d%| j        v rtE          d&|› d'�¦  «         |
�d(|
v rtE          d)|› d'�t@          d¬¦  «         || j        d%<   || j        d(<   |                     d*d ¦  «        }|�4tQ          |tR          ¦  «        stU          d+tW          |¦  «        › �¦  «        ‚|tR          j,        k    rt          d,¦  «        ‚|| _-        | j        �| j        › d-| j        › �n| j        }| j        › d.|› �}t]          || j	        ¦  «        | _/        | j        |d/œ|¥| _0        |�
|| j0        d<   |�|| j0        d0<   || _1        n| j2        | _1        | j        �@| j        dk    rt?          d1t@          d¬¦  «         tg          | j        ¦  «        }|| j0        d2<   ti          d6d3| j/        i| j0        ¤Ž| _5        | j5        j6         7                    tp          ¦  «         g | _9        d | _:        d | _;        d | _<        d | _=        d| _>        d| _?        |rVt�          | jA        | j/        | j        | j0         B                    d2¦  «        | j1        fd4¬5¦  «         C                    ¦   «          d S d S )7Nr1   Úhttpé   Ú r   ú/z+Only one of (url, host) can be set. url is z
, host is zhttp://zhttps://zk`host` param is not expected to contain protocol (http:// or https://). Try to use `url` parameter instead.Ú	localhostz//z9Prefix can be set either in `url` or in `prefix`. url is z, prefix is )r=   r1   zUnknown scheme: Úlimits)rA   z	127.0.0.1)Úmax_connectionsÚmax_keepalive_connections)rC   z>`pool_size` and `limits` are mutually exclusive. `pool_size`: z, `limit`: Úhttp2Fc                 ó   — i | ]\  }}||“Œ	S © rG   )Ú.0ÚkÚvs      úOC:\Projects\DSCons\.venv\Lib\site-packages\qdrant_client\async_qdrant_remote.pyú
<dictcomp>z.AsyncQdrantRemote.__init__.<locals>.<dictcomp>x   s   € ÐTÐTÐT¡v¨¨1˜a ÐTÐTÐTó    Úmetadataz,Api key is used with an insecure connection.é   ©ÚmessageÚcategoryÚ
stacklevelc                 ó    — g | ]\  }}|d k    ‘ŒS )úapi-keyrG   )rH   Úheader_nameÚ_s      rK   ú
<listcomp>z.AsyncQdrantRemote.__init__.<locals>.<listcomp>…   s"   € ÐYÐYÐYÑ2B°;À�[ IÒ-ÐYÐYÐYrM   rU   z``api-key` has been passed in `headers`, but it will be overridden with `api_key` parameter valueúqdrant-clientzpython-client/z python/z
User-Agentz^`User-Agent` has been passed in `headers`, but it will be overridden with the builtin value: `z`.zgrpc.primary_user_agentzD`grpc.primary_user_agent will be overridden with the builtin value: Úgrpc_compressionzLExpected 'grpc_compression' to be of type grpc.Compression or None, but got zfgrpc.Compression.Deflate is not supported. Try grpc.Compression.Gzip or grpc.Compression.NoCompressionú:z://)r:   rE   r4   z8Auth token provider is used with an insecure connection.Úauthr5   T)ÚtargetÚargsÚdaemonrG   )DÚsuperÚ__init__Ú_prefer_grpcÚ
_grpc_portÚ_grpc_optionsÚ_httpsÚ_schemeÚ
_pool_sizeÚmaxÚ_prefixÚlenÚ
ValueErrorÚ
startswithr   r5   r.   Ú_hostÚ_portÚschemeÚpathÚmathÚceilÚ_api_keyÚ_auth_token_providerÚpopÚhttpxÚLimitsÚ_grpc_headersÚitemsÚ_rest_headersÚappendr   ÚUserWarningÚanyr   Ú	importlibrN   ÚversionÚplatformÚpython_versionÚ
isinstancer   Ú	TypeErrorÚtypeÚDeflateÚ_grpc_compressionr   Úrest_uriÚ
_rest_argsÚ_timeoutÚDEFAULT_GRPC_TIMEOUTr   r    Úopenapi_clientÚclientÚadd_middlewarer"   Ú_grpc_channel_poolÚ_grpc_points_client_poolÚ_grpc_collections_client_poolÚ_grpc_snapshots_client_poolÚ_grpc_root_client_poolÚ_grpc_client_next_indexÚ_closedr   Ú_check_compatibilityÚgetÚstart)Úselfr-   r.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   r9   r:   r;   Ú
parsed_urlr‰   rB   rE   ÚkeyÚvalueÚclient_versionr�   Ú
user_agentrZ   ÚaddressÚbase_urlÚbearer_authÚ	__class__s                                €rK   ra   zAsyncQdrantRemote.__init__0   sZ  ø€ ð$ 	�‰ŒÔÐ"Ð"˜6Ð"Ð"Ð"Ø'ˆÔØ#ˆŒØ)Ð/¨RˆÔØ$Ð0�e�e°gÀTÐ6IˆŒØ"&¤+Ð9�w�w°6ˆŒØ&*ˆŒØÐ Ý˜A˜yÑ)Ô)ˆIØ'ˆDŒOØ�| ˆŒÝˆtŒ|ÑÔ˜qÒ Ð  T¤\°!¤_¸Ò%;Ð%;Ø-˜tœ|Ð-Ð-ˆDŒLØˆ?˜tÐ/ÝÐ`È3Ð`Ð`ÐZ^Ð`Ð`ÑaÔaÐaØÐ §¢°Ñ!;Ô!;Ð¸t¿ºÈzÑ?ZÔ?ZÐÝØ~ñô ð ð ð 	Ø�~Š~˜kÑ*Ô*ð !Ø ˜3�j�j�Ý'¨™nœnˆJØ(2¬¸¼Ð$ˆTŒZ˜œØÔ ð 1Ø(Ô/°7Ò:�”Ø)Ô0�”Ø'+¤zÐ;˜œ˜°tˆDŒJØŒ|ð / 
¤ð /Ý ØrÐPSÐrÐrÐakÔapÐrÐrñô ð ð ”ð /Ø)œ�”ØŒ|Ð#4Ð4Ð4Ý Ð!B°D´LÐ!BÐ!BÑCÔCÐCð 5ð Ð, ˆDŒJØˆDŒJØ)0Ð)<•4”9˜WÑ%Ô%Ð%À$ˆØˆŒØ$7ˆÔ!Ø—’˜H dÑ+Ô+ˆØˆ>ØŒzÐ7Ð7Ð7Ýœ°dÐVWÐXÑXÔX��Ø”Ð,Ýœ°d´oÐFÑFÔF�øØŒ_Ð(ÝØoÐQZÐoÐoÐgmÐoÐoñô ð ð —
’
˜7 EÑ*Ô*ˆØˆÔØTÐT°·²¸JÈÑ1KÔ1K×1QÒ1QÑ1SÔ1SÐTÑTÔTˆÔØð 	8Ø%Ÿmšm™oœoð 8ð 8‘
��UØ*/�Ô" 3Ñ'ØÔ"×)Ò)¨3°¨,Ñ7Ô7Ð7Ð7ØÐØŒ|˜vÒ%Ð%ÝØJÝ(Ø ðñ ô ð õ ÐYÐYÀdÔFXÐYÑYÔYÑZÔZðà Ô 2Ð2Ð2å!Ø~Ý(Ø ðñ ô ð ð
 -4ˆDÔ˜yÑ)ØÔ×%Ò% y°'Ð&:Ñ;Ô;Ð;Ý"Ô+×3Ò3°OÑDÔDˆÝ!Ô0Ñ2Ô2ˆØN nÐNÐN¸nÐNÐNˆ
Ø˜4Ô-Ð-Ð-ÝØÐq{ÐÐÐñô ð ð Ð#Ð(AÀ\Ð(QÐ(QÝØmÐ_iÐmÐmÐmÝ$Øðñ ô ð ð
 ,6ˆÔ˜<Ñ(Ø8BˆÔÐ4Ñ5Ø/5¯zªzÐ:LÈdÑ/SÔ/SÐØÐ'µÐ<LÍkÑ1ZÔ1ZÐ'ÝØwÕ_cÐdtÑ_uÔ_uÐwÐwñô ð ð �{Ô2Ò2Ð2ÝØxñô ð ð "2ˆÔØ26´*Ð2H�T”ZÐ.Ð. $¤*Ð.Ð.Ð.ÈdÌjˆØ”lÐ0Ð0 wÐ0Ð0ˆÝ ¨$¬,Ñ7Ô7ˆŒØ&*Ô&8À5ÐSÐSÈFÐSˆŒØÐØ(.ˆDŒO˜HÑ%ØÐØ)1ˆDŒO˜IÑ&Ø$ˆDŒMˆMà Ô5ˆDŒMØÔ$Ð0ØŒ|˜vÒ%Ð%ÝØVÝ(Ø ðñ ô ð õ
 % TÔ%>Ñ?Ô?ˆKØ&1ˆDŒO˜FÑ#Ý9Bð :
ð :
Ø”ð:
Ø"&¤/ð:
ð :
ˆÔð 	ÔÔ"×1Ò1Õ2OÑPÔPÐPØ68ˆÔØFJˆÔ%ØPTˆÔ*ØLPˆÔ(ØDHˆÔ#Ø,-ˆÔ$Ø"ˆŒØð 
	ÝØÔ0à”MØÔ&Ø”O×'Ò'¨Ñ/Ô/Ø”Mð	ð ð	ñ 	ô 	÷ Še‰gŒgˆgˆgˆgð
	ð 
	rM   r‡   Úrest_headersr\   Úreturnc                 óP  — 	 t           j                             d¦  «        }t          | |||¦  «        }|st	          dt
          d¬¦  «         d S t          ||¦  «        s t	          d|› d|› d�t
          d¬¦  «         d S d S # t          $ r t	          dt
          d¬¦  «         Y d S w xY w)NrY   z‚Failed to obtain server version. Unable to check client-server compatibility. Set check_compatibility=False to skip version check.é   rP   zQdrant client version z% is incompatible with server version z‚. Major versions should match and minor version difference must not exceed 1. Set check_compatibility=False to skip version check.)r~   rN   r   r   r   r|   r   Ú	Exception)r‡   r¢   r\   r4   rœ   Úserver_versions         rK   r•   z&AsyncQdrantRemote._check_compatibilityÓ   s"  € ð	Ý&Ô/×7Ò7¸ÑHÔHˆNÝ/°¸,ÈÈgÑVÔVˆNØ!ð Ýð aÝ(Ø ðñ ô ð ð ð õ
 # >°>ÑBÔBð Ýð }°^ð  }ð  }Ðjxð  }ð  }ð  }Ý(Ø ðñ ô ð ð ð ðð øõ ð 	ð 	ð 	Ýð ]Ý$Øðñ ô ð ð ð ð ð	øøøs   ‚A
B  Á.B  Â !B%Â$B%c                 ó   — | j         S ©N)r”   ©r˜   s    rK   ÚclosedzAsyncQdrantRemote.closedí   s
   € àŒ|ÐrM   Ú
grpc_gracec              ‹   óª  K  — t          | d¦  «        rqt          | j        ¦  «        dk    rY| j        D ]Q}	 |                     |¬¦  «        ƒ d {V —† Œ # t          $ r t          dt          d¬¦  «         Y ŒCt          $ r Y ŒNw xY w	 | j         	                    ¦   «         ƒ d {V —† n'# t          $ r t          dt          d¬¦  «         Y nw xY wd| _        d S )	NrŽ   r   )ÚgracezKUnable to close grpc_channel. Connection was interrupted on the server siderO   rP   zNUnable to close http connection. Connection was interrupted on the server sideT)Úhasattrrj   rŽ   ÚcloseÚAttributeErrorr   r|   ÚRuntimeErrorr=   Úacloser¦   r”   )r˜   r¬   r;   Úchannels       rK   r°   zAsyncQdrantRemote.closeñ   sM  è è € Ý�4Ð-Ñ.Ô.ð 	µ3°tÔ7NÑ3OÔ3OÐRSÒ3SÐ3SØÔ2ð 
ð 
�ð	Ø!Ÿ-š-¨j˜-Ñ9Ô9Ð9Ð9Ð9Ð9Ð9Ð9Ð9Ð9øÝ%ð ð ð Ý Ø mÝ!,Ø#$ðñ ô ð ð ð õ
 $ð ð ð Ø�Dðøøøð	Ø”)×"Ò"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$øÝð 	ð 	ð 	ÝØhÝ$Øðñ ô ð ð ð ð	øøøð ˆŒˆˆs)   µAÁ!BÁ5	BÂ BÂB% Â%!C	ÃC	c                 ój   — t          | ¦  «        }|j        |j        |j        |j        f\  }}}}||||fS r©   )r   ro   r5   r.   rp   )r-   Úparse_resultro   r5   r.   r3   s         rK   Ú
_parse_urlzAsyncQdrantRemote._parse_url  sF   € å% c™NœNˆàÔØÔØÔØÔð	(
Ñ$ˆ��t˜Vð ˜˜d FÐ+Ð+rM   c                 ó,   — | j         �| j         S | j        S )zà
        Returns the pool size to use for GRPC connection pool.
        This method should be preferred over accessing `self._pool_size` directly as it applies the
        default value if no pool_size was provided.
        )rg   ÚDEFAULT_GRPC_POOL_SIZErª   s    rK   Ú_get_grpc_pool_sizez%AsyncQdrantRemote._get_grpc_pool_size  s   € ð Œ?Ð&Ø”?Ð"àÔ.Ð.rM   c           
      ó¦  — | j         rt          d¦  «        ‚	 g }t          | j        ¦  «        dk    r{t	          |                      ¦   «         ¦  «        D ]P}t          | j        | j        | j	        | j
        | j        | j        | j        ¬¦  «        }|                     |¦  «         ŒQ|| _        d S d S # t          $ r}t          d|› �¦  «        ‚d }~ww xY w)Nz=Client was closed. Please create a new QdrantClient instance.r   )r5   r.   ÚsslrN   ÚoptionsÚcompressionr7   z+Error initializing the grpc connection(s): )r”   r²   rj   rŽ   Úrangerº   Úget_channelrm   rc   re   rx   rd   r†   rt   r{   r¦   )r˜   Úchannel_poolrW   r´   Úes        rK   Ú_init_grpc_channelz$AsyncQdrantRemote._init_grpc_channel  s  € ØŒ<ð 	`ÝÐ^Ñ_Ô_Ð_ð	RØˆLÝ�4Ô*Ñ+Ô+¨qÒ0Ð0Ý˜t×7Ò7Ñ9Ô9Ñ:Ô:ð 
1ð 
1�AÝ)Ø!œZØ!œ_Ø œKØ!%Ô!3Ø $Ô 2Ø$(Ô$:Ø,0Ô,Eðñ ô �Gð !×'Ò'¨Ñ0Ô0Ð0Ð0Ø*6�Ô'Ð'Ð'ð 1Ð0øõ ð 	Rð 	Rð 	RÝÐPÈQÐPÐPÑQÔQÐQøøøøð	Røøøs   ˜BB/ Â/
CÂ9CÃCc                 óZ   — |                       ¦   «          d„ | j        D ¦   «         | _        d S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Ú
PointsStub©rH   r´   s     rK   rX   z>AsyncQdrantRemote._init_grpc_points_client.<locals>.<listcomp>5  s/   € ð )
ð )
ð )
Ø)0�DŒO˜GÑ$Ô$ð)
ð )
ð )
rM   )rÃ   rŽ   r�   rª   s    rK   Ú_init_grpc_points_clientz*AsyncQdrantRemote._init_grpc_points_client3  s>   € Ø×ÒÑ!Ô!Ð!ð)
ð )
Ø48Ô4Kð)
ñ )
ô )
ˆÔ%Ð%Ð%rM   c                 óZ   — |                       ¦   «          d„ | j        D ¦   «         | _        d S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   ÚCollectionsStubrÇ   s     rK   rX   zCAsyncQdrantRemote._init_grpc_collections_client.<locals>.<listcomp>;  s0   € ð .
ð .
ð .
Ø.5�DÔ  Ñ)Ô)ð.
ð .
ð .
rM   )rÃ   rŽ   r�   rª   s    rK   Ú_init_grpc_collections_clientz/AsyncQdrantRemote._init_grpc_collections_client9  s>   € Ø×ÒÑ!Ô!Ð!ð.
ð .
Ø9=Ô9Pð.
ñ .
ô .
ˆÔ*Ð*Ð*rM   c                 óZ   — |                       ¦   «          d„ | j        D ¦   «         | _        d S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   ÚSnapshotsStubrÇ   s     rK   rX   zAAsyncQdrantRemote._init_grpc_snapshots_client.<locals>.<listcomp>A  s0   € ð ,
ð ,
ð ,
Ø,3�DÔ˜wÑ'Ô'ð,
ð ,
ð ,
rM   )rÃ   rŽ   r‘   rª   s    rK   Ú_init_grpc_snapshots_clientz-AsyncQdrantRemote._init_grpc_snapshots_client?  s>   € Ø×ÒÑ!Ô!Ð!ð,
ð ,
Ø7;Ô7Nð,
ñ ,
ô ,
ˆÔ(Ð(Ð(rM   c                 óZ   — |                       ¦   «          d„ | j        D ¦   «         | _        d S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Ú
QdrantStubrÇ   s     rK   rX   z<AsyncQdrantRemote._init_grpc_root_client.<locals>.<listcomp>G  s/   € ð '
ð '
ð '
Ø)0�DŒO˜GÑ$Ô$ð'
ð '
ð '
rM   )rÃ   rŽ   r’   rª   s    rK   Ú_init_grpc_root_clientz(AsyncQdrantRemote._init_grpc_root_clientE  s>   € Ø×ÒÑ!Ô!Ð!ð'
ð '
Ø48Ô4Kð'
ñ '
ô '
ˆÔ#Ð#Ð#rM   c                 ó\   — | j         }| j         dz   |                      ¦   «         z  | _         |S )Nr>   )r“   rº   )r˜   Úcurrent_indexs     rK   Ú_next_grpc_clientz#AsyncQdrantRemote._next_grpc_clientK  s6   € ØÔ4ˆàÔ(¨1Ñ,Ø×$Ò$Ñ&Ô&ñ('ˆÔ$ð ÐrM   c                 óˆ   — | j         €|                      ¦   «          | j         €J ‚| j         |                      ¦   «                  S )z‚gRPC client for collections methods

        Returns:
            An instance of raw gRPC client, generated from Protobuf
        )r�   rÌ   r×   rª   s    rK   Úgrpc_collectionsz"AsyncQdrantRemote.grpc_collectionsR  sH   € ð Ô-Ð5Ø×.Ò.Ñ0Ô0Ð0ØÔ1Ð=Ð=Ð=ØÔ1°$×2HÒ2HÑ2JÔ2JÔKÐKrM   c                 óˆ   — | j         €|                      ¦   «          | j         €J ‚| j         |                      ¦   «                  S )z}gRPC client for points methods

        Returns:
            An instance of raw gRPC client, generated from Protobuf
        )r�   rÈ   r×   rª   s    rK   Úgrpc_pointszAsyncQdrantRemote.grpc_points^  sH   € ð Ô(Ð0Ø×)Ò)Ñ+Ô+Ð+ØÔ,Ð8Ð8Ð8ØÔ,¨T×-CÒ-CÑ-EÔ-EÔFÐFrM   c                 óˆ   — | j         €|                      ¦   «          | j         €J ‚| j         |                      ¦   «                  S )z€gRPC client for snapshots methods

        Returns:
            An instance of raw gRPC client, generated from Protobuf
        )r‘   rÐ   r×   rª   s    rK   Úgrpc_snapshotsz AsyncQdrantRemote.grpc_snapshotsj  sH   € ð Ô+Ð3Ø×,Ò,Ñ.Ô.Ð.ØÔ/Ð;Ð;Ð;ØÔ/°×0FÒ0FÑ0HÔ0HÔIÐIrM   c                 óˆ   — | j         €|                      ¦   «          | j         €J ‚| j         |                      ¦   «                  S )z{gRPC client for info methods

        Returns:
            An instance of raw gRPC client, generated from Protobuf
        )r’   rÔ   r×   rª   s    rK   Ú	grpc_rootzAsyncQdrantRemote.grpc_rootv  sH   € ð Ô&Ð.Ø×'Ò'Ñ)Ô)Ð)ØÔ*Ð6Ð6Ð6ØÔ*¨4×+AÒ+AÑ+CÔ+CÔDÐDrM   c                 ó   — | j         S ©ztREST Client

        Returns:
            An instance of raw REST API client, generated from OpenAPI schema
        ©r‹   rª   s    rK   ÚrestzAsyncQdrantRemote.rest‚  ó   € ð Ô"Ð"rM   c                 ó   — | j         S rá   râ   rª   s    rK   r=   zAsyncQdrantRemote.http‹  rä   rM   é
   Úcollection_nameÚqueryÚusingÚprefetchÚquery_filterÚsearch_paramsÚlimitÚoffsetÚwith_payloadÚwith_vectorsÚscore_thresholdÚlookup_fromÚconsistencyÚshard_key_selectorc              ‹   óâ  K  — | j         �rO|�t          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        g}t          |t          ¦  «        rd„ |D ¦   «         }t          |t          j        ¦  «        rt          j	        |¬¦  «        }t          |t          j
        ¦  «        rt          j        |¦  «        }t          |	t          t          j        ¦  «        ¦  «        rt          j        |	¦  «        }	t          |
t          t          j        ¦  «        ¦  «        rt          j        |
¦  «        }
t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t3          j        |||||||
|	|||||||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†}d„ |j        D ¦   «         }t	          j        |¬¦  «        S t          |t2          j        ¦  «        rt=          j	        |¬¦  «        }t          |t2          j
        ¦  «        rt=          j        |¦  «        }t          |	t2          j        ¦  «        rt=          j         |	¦  «        }	t          |t2          j        ¦  «        rt=          j        |¦  «        }t	          j!        ||||||||||
|	|¬¦  «        }| j"        j#         $                    ||||¬¦  «        ƒ d {V —†}|j        }|€
J d	¦   «         ‚|S )
Nc                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   ©r‚   r!   ÚPrefetchr   Úconvert_prefetch_query©rH   Úps     rK   rX   z2AsyncQdrantRemote.query_points.<locals>.<listcomp>¶  óK   € ð ð ð àõ =GÀqÍ&Ì/Ñ<ZÔ<ZÐa•JÔ5°aÑ8Ô8Ð8Ð`aðð ð rM   ©Úmodel)rç   rè   rê   Úfilterrí   rî   rð   rï   Úparamsrñ   ré   rò   r4   rô   Úread_consistency©r4   c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   ©r   Úconvert_scored_point©rH   Úhits     rK   rX   z2AsyncQdrantRemote.query_points.<locals>.<listcomp>Ü  s#   € ÐXÐXÐXÀc�ZÔ<¸SÑAÔAÐXÐXÐXrM   ©Úpoints)Ú	shard_keyrê   rè   ré   rÿ   r   rñ   rí   rî   Úwith_vectorrï   rò   )rç   ró   r4   Úquery_requestzSearch returned None)%rb   r   Úconvert_queryr‚   r!   rø   rù   ÚlistÚFilterÚconvert_filterÚSearchParamsÚconvert_search_paramsr   ÚWithPayloadInterfaceÚconvert_with_payload_interfaceÚ
WithVectorÚconvert_with_vectorsÚLookupLocationÚconvert_lookup_locationÚReadConsistencyÚconvert_read_consistencyÚShardKeySelectorÚconvert_shard_key_selectorrÛ   ÚQueryr   ÚQueryPointsr‰   ÚresultÚQueryResponser   ÚWithPayloadSelectorÚconvert_with_payload_selectorÚQueryRequestr=   Ú
search_apiÚquery_points)r˜   rç   rè   ré   rê   rë   rì   rí   rî   rï   rð   rñ   rò   ró   rô   r4   r;   ÚresÚscored_pointsr  Úquery_resultr  s                         rK   r%  zAsyncQdrantRemote.query_points”  s¶  è è € ð8 Ôñ M	ØÐ Ý"Ô0°Ñ7Ô7�Ý˜(¥F¤OÑ4Ô4ð IÝ&Ô=¸hÑGÔGÐH�Ý˜(¥DÑ)Ô)ð ðð à%ðñ ô �õ ˜,­¬Ñ6Ô6ð MÝ)Ô8¸|ÐLÑLÔL�Ý˜-­Ô)<Ñ=Ô=ð PÝ *Ô @ÀÑ OÔ O�Ý˜,Õ(;½FÔ<WÑ(XÔ(XÑYÔYð WÝ)ÔHÈÑVÔV�Ý˜,Õ(;½FÔ<MÑ(NÔ(NÑOÔOð MÝ)Ô>¸|ÑLÔL�Ý˜+¥vÔ'<Ñ=Ô=ð NÝ(Ô@ÀÑMÔM�Ý˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ø,0Ô,<×,BÒ,BÝÔ Ø$3ØØ%Ø'ØØ!Ø!-Ø!-Ø(Ø$3ØØ +Ø#Ø'9Ø%0ðñ ô ð" $+Ð#6˜˜¸D¼Mð% -Cñ -ô -ð 'ð 'ð 'ð 'ð 'ð 'ˆCð( YÐXÈSÌZÐXÑXÔXˆMÝÔ'¨}Ð=Ñ=Ô=Ð=å˜,­¬Ñ4Ô4ð MÝ)Ô8¸|ÐLÑLÔL�Ý˜-­Ô):Ñ;Ô;ð PÝ *Ô @ÀÑ OÔ O�Ý˜,­Ô(@ÑAÔAð VÝ)ÔGÈÑUÔU�Ý˜+¥tÔ':Ñ;Ô;ð NÝ(Ô@ÀÑMÔM�Ý"Ô/Ø,Ø!ØØØ#Ø$Ø /ØØØ(Ø)Ø'ðñ ô ˆMð "&¤Ô!5×!BÒ!BØ /Ø'ØØ+ð	 "Cñ "ô "ð ð ð ð ð ð ˆLð 3?Ô2EˆFØÐ%Ð%Ð'=Ñ%Ô%Ð%ØˆMrM   Úrequestsc              ‹   óê  ‡K  — | j         r›ˆfd„|D ¦   «         }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t          j
        ‰|||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†}d„ |j        D ¦   «         S | j        j                             ‰||t          j        |¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nc                 ór   •— g | ]3}t          |t          j        ¦  «        rt          j        |‰¦  «        n|‘Œ4S rG   )r‚   r!   r#  r   Úconvert_query_request)rH   Úrrç   s     €rK   rX   z8AsyncQdrantRemote.query_batch_points.<locals>.<listcomp>  sR   ø€ ð ð ð ð õ ˜a¥Ô!4Ñ5Ô5ð•
Ô0°°OÑDÔDÐDàðð ð rM   )rç   r%  r  r4   r  c                 óV   — g | ]&}t          j        d „ |j        D ¦   «         ¬¦  «        ‘Œ'S )c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   r  r  s     rK   rX   zCAsyncQdrantRemote.query_batch_points.<locals>.<listcomp>.<listcomp>  s#   € ÐUÐUÐUÀS�JÔ;¸CÑ@Ô@ÐUÐUÐUrM   r  )r!   r   r  )rH   r-  s     rK   rX   z8AsyncQdrantRemote.query_batch_points.<locals>.<listcomp>  sO   € ð ð ð ð õ Ô$ØUÐUÈAÌHÐUÑUÔUðñ ô ðð ð rM   )Úsearches)rç   ró   r4   Úquery_request_batchzQuery batch returned None)rb   r‚   r   r!   r  r   r  rÛ   Ú
QueryBatchr   ÚQueryBatchPointsr‰   r  r=   r$  Úquery_batch_pointsÚQueryRequestBatch)r˜   rç   r)  ró   r4   r;   Úgrpc_resÚhttp_ress    `      rK   r4  z$AsyncQdrantRemote.query_batch_pointsÿ  s~  øè è € ð Ôð "	ðð ð ð ð "ð	ñ ô ˆHõ ˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�Ø6:Ô6F×6QÒ6QÝÔ%Ø$3Ø!)Ø%0Ø#ð	ñ ô ð $+Ð#6˜˜¸D¼Mð 7Rñ 7ô 7ð 1ð 1ð 1ð 1ð 1ð 1ˆHðð ð "œð	ñ ô ð ð ”iÔ*×=Ò=Ø$3Ø +Ø#Ý(.Ô(@È(Ð(SÑ(SÔ(Sð	 >ñ ô ð ð ð ð ð ð ô ð ð Ð'Ð'Ð)DÑ'Ô'Ð'ØˆOrM   Úgroup_byÚ
group_sizeÚwith_lookupc              ‹   ó¶  K  — | j         �r¹|�t          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        g}t          |t          ¦  «        rd„ |D ¦   «         }t          |t          j        ¦  «        rt          j	        |¬¦  «        }t          |t          j
        ¦  «        rt          j        |¦  «        }t          |
t          t          j        ¦  «        ¦  «        rt          j        |
¦  «        }
t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }t          |t&          ¦  «        rt)          j        |¬¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t)          j        di d|“d|“d|“d|“d|“d	|“d
|
“d|“d|“d|“d|“d|	“d|“d|“d|“d|“d|“Ž|�|n| j        ¬¦  «        ƒ d {V —†j        }tA          j!        |¦  «        S t          |t(          j        ¦  «        rtA          j	        |¬¦  «        }t          |t(          j
        ¦  «        rtA          j        |¦  «        }t          |
t(          j"        ¦  «        rtA          j#        |
¦  «        }
t          |t(          j        ¦  «        rtA          j        |¦  «        }t	          j$        ||||||||||	||
||¬¦  «        }| j%        j&         '                    ||||¬¦  «        ƒ d {V —†}|€
J d¦   «         ‚|j        S )Nc                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   r÷   rú   s     rK   rX   z9AsyncQdrantRemote.query_points_groups.<locals>.<listcomp>O  rü   rM   rý   )Ú
collectionrç   rè   rê   rÿ   rí   rð   rï   r   rñ   ré   r8  r9  r:  rò   r4   rô   r  r  )r
  rê   rè   ré   rÿ   r   rñ   rí   r8  r9  r  rï   r:  rò   )rç   ró   r4   Úquery_groups_requestz%Query points groups API returned NonerG   )(rb   r   r  r‚   r!   rø   rù   r  r  r  r  r  r   r  r  r  r  Ú
WithLookupÚconvert_with_lookupÚstrr   r  r  r  r  r  r  rÛ   ÚQueryGroupsÚQueryPointGroupsr‰   r  r   Úconvert_groups_resultr!  r"  ÚQueryGroupsRequestr=   r$  Úquery_points_groups)r˜   rç   r8  rè   ré   rê   rë   rì   rí   r9  rï   rð   rñ   r:  rò   ró   rô   r4   r;   r  r  r(  s                         rK   rF  z%AsyncQdrantRemote.query_points_groups+  s�  è è € ð< Ôñ U	'ØÐ Ý"Ô0°Ñ7Ô7�Ý˜(¥F¤OÑ4Ô4ð IÝ&Ô=¸hÑGÔGÐH�Ý˜(¥DÑ)Ô)ð ðð à%ðñ ô �õ ˜,­¬Ñ6Ô6ð MÝ)Ô8¸|ÐLÑLÔL�Ý˜-­Ô)<Ñ=Ô=ð PÝ *Ô @ÀÑ OÔ O�Ý˜,Õ(;½FÔ<WÑ(XÔ(XÑYÔYð WÝ)ÔHÈÑVÔV�Ý˜,Õ(;½FÔ<MÑ(NÔ(NÑOÔOð MÝ)Ô>¸|ÑLÔL�Ý˜+¥vÔ'8Ñ9Ô9ð JÝ(Ô<¸[ÑIÔI�Ý˜+¥sÑ+Ô+ð FÝ"œo¸ÐEÑEÔE�Ý˜+¥vÔ'<Ñ=Ô=ð NÝ(Ô@ÀÑMÔM�Ý˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"àÔ&×2Ò2ÝÔ)ð ð ð Ø(7¨ðà#˜eðð "* ðð  ,˜|ð	ð
 $˜eðð &2 \ðð &2 \ðð  -˜}ðð )8¨ðð $˜eðð "* ðð $. :ðð %0 Kðð %0 Kðð !( ðð  ,>Ð+=ð!ð" *5¨ð#ð& (/Ð':˜G˜GÀÄð) 3ñ ô ð ð ð ð ð ð ô, ð/ õ0 Ô3°FÑ;Ô;Ð;å˜,­¬Ñ4Ô4ð MÝ)Ô8¸|ÐLÑLÔL�Ý˜-­Ô):Ñ;Ô;ð PÝ *Ô @ÀÑ OÔ O�Ý˜,­Ô(@ÑAÔAð VÝ)ÔGÈÑUÔU�Ý˜+¥tÔ':Ñ;Ô;ð NÝ(Ô@ÀÑMÔM�Ý"Ô5Ø,Ø!ØØØ#Ø$Ø /ØØ!Ø%Ø(Ø)Ø'Ø'ðñ ô ˆMð  "&¤Ô!5×!IÒ!IØ /Ø'ØØ%2ð	 "Jñ "ô "ð ð ð ð ð ð ˆLð  Ð+Ð+Ð-TÑ+Ô+Ð+ØÔ&Ð&rM   Úsamplec	              ‹   ó   K  — | j         �rt          |t          j        ¦  «        rt	          j        |¬¦  «        }t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        }t          |t          t          j	        ¦  «        ¦  «        rt	          j
        |¦  «        }| j                             t          j        ||||||||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†}
t!          j        |
j        ¦  «        S t          |t          j        ¦  «        rt!          j        |¬¦  «        }| j        j                             |||t          j        |||||¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nrý   ©rç   rÿ   rG  rí   ré   r4   r  rô   r  ©r
  rí   rG  ré   rÿ   ©rç   ró   r4   Úsearch_matrix_requestz(Search matrix pairs returned None result)rb   r‚   r!   r  r   r  r   r  r  r  r  rÛ   ÚSearchMatrixPairsr   ÚSearchMatrixPointsr‰   r   Úconvert_search_matrix_pairsr  r‹   r$  Úsearch_matrix_pairsÚSearchMatrixRequest©r˜   rç   rë   rí   rG  ré   ró   rô   r4   r;   ÚresponseÚsearch_matrix_results               rK   rP  z%AsyncQdrantRemote.search_matrix_pairs   sä  è è € ð Ôñ 	KÝ˜,­¬Ñ6Ô6ð MÝ)Ô8¸|ÐLÑLÔL�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�Ø!Ô-×?Ò?ÝÔ'Ø$3Ø'Ø!ØØØ#Ø%0Ø'9ð	ñ 	ô 	ð $+Ð#6˜˜¸D¼Mð @ñ ô ð ð ð ð ð ð ˆHõ Ô9¸(¼/ÑJÔJÐJÝ�l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLàÔ%Ô0×DÒDØ /Ø'ØÝ&,Ô&@Ø0ØØ!ØØ'ð'ñ 'ô 'ð	 Eñ ô ð ð ð ð ð ð ô ð 	ð $Ð/Ð/Ð1[Ñ/Ô/Ð/Ø#Ð#rM   c	              ‹   ó   K  — | j         �rt          |t          j        ¦  «        rt	          j        |¬¦  «        }t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        }t          |t          t          j	        ¦  «        ¦  «        rt	          j
        |¦  «        }| j                             t          j        ||||||||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†}
t!          j        |
j        ¦  «        S t          |t          j        ¦  «        rt!          j        |¬¦  «        }| j        j                             |||t          j        |||||¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nrý   rI  r  rJ  rK  z*Search matrix offsets returned None result)rb   r‚   r!   r  r   r  r   r  r  r  r  rÛ   ÚSearchMatrixOffsetsr   rN  r‰   r   Úconvert_search_matrix_offsetsr  r‹   r$  Úsearch_matrix_offsetsrQ  rR  s               rK   rX  z'AsyncQdrantRemote.search_matrix_offsetsÔ  sä  è è € ð Ôñ 	MÝ˜,­¬Ñ6Ô6ð MÝ)Ô8¸|ÐLÑLÔL�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�Ø!Ô-×AÒAÝÔ'Ø$3Ø'Ø!ØØØ#Ø%0Ø'9ð	ñ 	ô 	ð $+Ð#6˜˜¸D¼Mð Bñ ô ð ð ð ð ð ð ˆHõ Ô;¸H¼OÑLÔLÐLÝ�l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLàÔ%Ô0×FÒFØ /Ø'ØÝ&,Ô&@Ø0ØØ!ØØ'ð'ñ 'ô 'ð	 Gñ ô ð ð ð ð ð ð ô ð 	ð $Ð/Ð/Ð1]Ñ/Ô/Ð/Ø#Ð#rM   Úscroll_filterÚorder_byc              ‹   ó|  K  — | j         �rt          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¬¦  «        }t          |t          t          j	        ¦  «        ¦  «        rt          j
        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |	t          t          j        ¦  «        ¦  «        rt          j        |	¦  «        }	t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t+          j        |||||||||	|
¬¦
  «
        |
�|
n| j        ¬¦  «        ƒ d {V —†}d„ |j        D ¦   «         |                     d¦  «        rt5          j        |j        ¦  «        nd fS t          |t*          j        ¦  «        rt5          j        |¦  «        }t          |t*          j        ¦  «        rt5          j        |¬¦  «        }t          |t*          j        ¦  «        rt5          j        |¦  «        }t          |t*          j         ¦  «        rt5          j!        |¦  «        }| j"        j#         $                    ||t          j%        |||||||	¬¦  «        |
¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|j&        |j        fS )	Nrý   )
rç   rÿ   rZ  rî   rð   rï   rí   r  rô   r4   r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   ©r   Úconvert_retrieved_point©rH   Úpoints     rK   rX   z,AsyncQdrantRemote.scroll.<locals>.<listcomp>5  s#   € ÐSÐSÐS¸u•Ô3°EÑ:Ô:ÐSÐSÐSrM   Únext_page_offset)rÿ   rí   rZ  rî   rï   r  r
  )rç   ró   Úscroll_requestr4   z&Scroll points API returned None result)'rb   r‚   r   r!   ÚExtendedPointIdr   Úconvert_extended_point_idr  r  r  r  r  r  r  r  r  r  ÚOrderByInterfaceÚconvert_order_by_interfacerÛ   ÚScrollr   ÚScrollPointsr‰   r  ÚHasFieldr   Úconvert_point_idra  ÚPointIdÚOrderByÚconvert_order_byr!  r"  r‹   Ú
points_apiÚscroll_pointsÚScrollRequestr	  )r˜   rç   rY  rí   rZ  rî   rï   rð   ró   rô   r4   r;   r&  Úscroll_results                 rK   ÚscrollzAsyncQdrantRemote.scroll  s`  è è € ð Ôñ >	JÝ˜&Õ"5µfÔ6LÑ"MÔ"MÑNÔNð FÝ#Ô=¸fÑEÔE�Ý˜-­¬Ñ7Ô7ð OÝ *Ô 9ÀÐ NÑ NÔ N�Ý˜,Õ(;½FÔ<WÑ(XÔ(XÑYÔYð WÝ)ÔHÈÑVÔV�Ý˜,Õ(;½FÔ<MÑ(NÔ(NÑOÔOð MÝ)Ô>¸|ÑLÔL�Ý˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜(Õ$7½Ô8OÑ$PÔ$PÑQÔQð KÝ%Ô@ÀÑJÔJ�Ø-1Ô-=×-DÒ-DÝÔ!Ø$3Ø(Ø%Ø!Ø!-Ø!-ØØ%0Ø'9Ø#ðñ ô ð $+Ð#6˜˜¸D¼Mð .Eñ .ô .ð (ð (ð (ð (ð (ð (ˆCð  TÐSÈÌ
ÐSÑSÔSà—<’<Ð 2Ñ3Ô3ð•
Ô+¨CÔ,@ÑAÔAÐAàð	ð õ ˜&¥$¤,Ñ/Ô/ð =Ý#Ô4°VÑ<Ô<�Ý˜-­¬Ñ5Ô5ð OÝ *Ô 9ÀÐ NÑ NÔ N�Ý˜(¥D¤LÑ1Ô1ð AÝ%Ô6°xÑ@Ô@�Ý˜,­Ô(@ÑAÔAð VÝ)ÔGÈÑUÔU�àÔ)Ô4×BÒBØ$3Ø +Ý#)Ô#7Ø,Ø#Ø!)Ø%Ø%1Ø$0Ø"4ð$ñ $ô $ð $ð Cñ ô ð ð ð ð ð ð ô ð ð  !Ð,Ð,Ð.VÑ,Ô,Ð,Ø!Ô(¨-Ô*HÐIÐIrM   Úcount_filterÚexactc           
   ‹   ó  K  — | j         �rt          |t          j        ¦  «        rt	          j        |¬¦  «        }t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        }t          |t          t          j	        ¦  «        ¦  «        rt	          j
        |¦  «        }| j                             t          j        ||||||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†j        }t#          j        |¦  «        S t          |t          j        ¦  «        rt#          j        |¬¦  «        }| j        j                             |t          j        |||¬¦  «        ||¬¦  «        ƒ d {V —†j        }	|	€
J d¦   «         ‚|	S )Nrý   )rç   rÿ   rt  rô   r4   r  r  )rÿ   rt  r
  )rç   Úcount_requestró   r4   z!Count points returned None result)rb   r‚   r!   r  r   r  r   r  r  r  r  rÛ   ÚCountr   ÚCountPointsr‰   r  r   Úconvert_count_resultr‹   rn  Úcount_pointsÚCountRequest)
r˜   rç   rs  rt  rô   r4   ró   r;   rS  Úcount_results
             rK   ÚcountzAsyncQdrantRemote.countV  sÜ  è è € ð Ôñ 	=Ý˜,­¬Ñ6Ô6ð MÝ)Ô8¸|ÐLÑLÔL�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�àÔ&×,Ò,ÝÔ$Ø(7Ø+Ø#Ø+=Ø 'Ø)4ðñ ô ð (/Ð':˜G˜GÀÄð -ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ô ð õ Ô2°8Ñ<Ô<Ð<Ý�l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLàÔ%Ô0×=Ò=Ø /Ý$Ô1Ø'¨uÐ@Rðñ ô ð (Øð >ñ ô ð ð ð ð ð ð ô ð 	ð Ð'Ð'Ð)LÑ'Ô'Ð'ØÐrM   rš   Úfacet_filterc	              ‹   ó6  K  — | j         �rt          |t          j        ¦  «        rt	          j        |¬¦  «        }t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        }t          |t          t          j	        ¦  «        ¦  «        rt	          j
        |¦  «        }| j                             t          j        ||||||||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†}
t!          j        d„ |
j        D ¦   «         ¬¦  «        S t          |t          j        ¦  «        rt'          j        |¬¦  «        }| j        j                             |||t          j        |||||¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )	Nrý   )rç   rš   rÿ   rí   rt  r4   r  rô   r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_facet_value_hitr  s     rK   rX   z+AsyncQdrantRemote.facet.<locals>.<listcomp>¥  s#   € ÐWÐWÐWÀ#•jÔ8¸Ñ=Ô=ÐWÐWÐWrM   )Úhits)r
  rš   rí   rÿ   rt  )rç   ró   r4   Úfacet_requestz!Facet points returned None result)rb   r‚   r!   r  r   r  r   r  r  r  r  rÛ   ÚFacetr   ÚFacetCountsr‰   ÚtypesÚFacetResponser‚  r   r‹   rn  ÚfacetÚFacetRequestr  )r˜   rç   rš   r~  rí   rt  r4   ró   rô   r;   rS  Úfacet_results               rK   rˆ  zAsyncQdrantRemote.facet„  sý  è è € ð Ôñ 	Ý˜,­¬Ñ6Ô6ð MÝ)Ô8¸|ÐLÑLÔL�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�Ø!Ô-×3Ò3ÝÔ Ø$3ØØ'ØØØ#Ø%0Ø'9ð	ñ 	ô 	ð $+Ð#6˜˜¸D¼Mð 4ñ ô ð ð ð ð ð ð ˆHõ Ô&ØWÐWÈÌÐWÑWÔWðñ ô ð õ �l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLàÔ%Ô0×6Ò6Ø /Ø'ØÝ$Ô1Ø0ØØØ'Øðñ ô ð	 7ñ ô ð ð ð ð ð ð ô ð 	ð Ð'Ð'Ð)LÑ'Ô'Ð'ØÐrM   r	  ÚwaitÚorderingÚupdate_filterÚupdate_modec	              ‹   óJ  ‡‡K  — | j         �rÁt          ‰t          j        ¦  «        rZt	          j        ‰j        t          ‰j        ¦  «        ¦  «        Šˆˆfd„t          t          ‰j        ¦  «        ¦  «        D ¦   «         Št          ‰t          ¦  «        rd„ ‰D ¦   «         Št          |t          j        ¦  «        rt	          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        }t          |t          j        ¦  «        rt	          j        |¬¦  «        }t          |t          j        ¦  «        rt	          j        |¦  «        }| j                             t-          j        ||‰|||||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        }
|
€
J d¦   «         ‚t5          j        |
¦  «        S t          |t,          j        ¦  «        rt5          j        |¬¦  «        }t          ‰t          ¦  «        r$d„ ‰D ¦   «         Št          j        ‰|||¬¦  «        Št          ‰t          j        ¦  «        rt          j        ‰|||¬	¦  «        Š| j        j                              ||‰||¬
¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nc           
      óÐ   •— g | ]b}t          j        t          j        ‰j        |         ¦  «        ‰|         ‰j        �t          j        ‰j        |         ¦  «        nd ¬¦  «        ‘ŒcS )N)ÚidÚvectorsÚpayload)r   ÚPointStructr   rd  ÚidsÚpayloadsÚconvert_payload)rH   Úidxr	  Úvectors_batchs     €€rK   rX   z,AsyncQdrantRemote.upsert.<locals>.<listcomp>Ë  s~   ø€ ð 	ð 	ð 	ð õ Ô$Ý%Ô?ÀÄ
È3ÄÑPÔPØ -¨cÔ 2à!œ?Ð6õ !+Ô :¸6¼?È3Ô;OÑ PÔ PÐ Pà!ðñ ô ð	ð 	ð 	rM   c                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   )r‚   r!   r”  r   Úconvert_point_structr_  s     rK   rX   z,AsyncQdrantRemote.upsert.<locals>.<listcomp>Ö  sO   € ð ð ð ð õ " %­Ô);Ñ<Ô<ð•JÔ3°EÑ:Ô:Ð:àðð ð rM   rý   )rç   r‹  r	  rŒ  rô   r�  r4   rŽ  r  úUpsert returned None resultc                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   )r‚   r   r”  r   r›  r_  s     rK   rX   z,AsyncQdrantRemote.upsert.<locals>.<listcomp>ù  sO   € ð ð ð ð õ " %­Ô)9Ñ:Ô:ð•JÔ3°EÑ:Ô:Ð:àðð ð rM   )r	  r
  r�  rŽ  )Úbatchr
  r�  rŽ  )rç   r‹  Úpoint_insert_operationsrŒ  r4   )!rb   r‚   r!   ÚBatchr   Úconvert_batch_vector_structr’  rj   r•  r¿   r  ÚWriteOrderingÚconvert_write_orderingr   r  r  r  r  Ú
UpdateModeÚconvert_update_moderÛ   ÚUpsertr   ÚUpsertPointsr‰   r  r   Úconvert_update_resultÚ
PointsListÚPointsBatchr‹   rn  Úupsert_points)r˜   rç   r	  r‹  rŒ  rô   r�  rŽ  r4   r;   Úgrpc_resultÚhttp_resultr™  s     `         @rK   ÚupsertzAsyncQdrantRemote.upsertº  s2  øøè è € ð Ôñ P	Ý˜&¥&¤,Ñ/Ô/ð Ý4>Ô4ZØ”N¥C¨¬
¡O¤Oñ5ô 5�ð	ð 	ð 	ð 	ð 	õ  %¥S¨¬¡_¤_Ñ5Ô5ð	ñ 	ô 	�õ ˜&¥$Ñ'Ô'ð ðð ð "(ð	ñ ô �õ ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜-­¬Ñ7Ô7ð OÝ *Ô 9ÀÐ NÑ NÔ N�Ý˜+¥vÔ'8Ñ9Ô9ð JÝ(Ô<¸[ÑIÔI�àÔ&×-Ò-ÝÔ%Ø(7Ø!Ø%Ø!)Ø+=Ø&3Ø 'Ø$/ð	ñ 	ô 	ð !œMð .ñ ô ð ð ð ð ð ð ô ð ð Ð*Ð*Ð,IÑ*Ô*Ð*ÝÔ3°KÑ@Ô@Ð@å˜-­¬Ñ5Ô5ð OÝ *Ô 9ÀÐ NÑ NÔ N�Ý˜&¥$Ñ'Ô'ð ðð ð "(ð	ñ ô �õ  Ô*Ø!Ø0Ø"/Ø +ð	ñ ô �õ ˜&¥&¤,Ñ/Ô/ð ÝÔ+Ø Ø0Ø"/Ø +ð	ñ ô �ð Ô)Ô4×BÒBØ$3ØØ,2Ø%Ø#ð Cñ ô ð ð ð ð ð ð ô ð ð Ð*Ð*Ð,IÑ*Ô*Ð*ØÐrM   c              ‹   ó  K  — | j         �r	d„ |D ¦   «         }t          |t          j        ¦  «        rt	          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        }t          |t          j	        ¦  «        rt	          j
        |¬¦  «        }| j                             t          j        |||||||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        }	|	€
J d¦   «         ‚t#          j        |	¦  «        S t          |t          j	        ¦  «        rt#          j
        |¬¦  «        }| j        j                             ||t          j        |||¬¦  «        ||¬¦  «        ƒ d {V —†j        S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_point_vectorsr_  s     rK   rX   z4AsyncQdrantRemote.update_vectors.<locals>.<listcomp>$  s#   € ÐRÐRÐRÀ%•jÔ6°uÑ=Ô=ÐRÐRÐRrM   rý   )rç   r‹  r	  rŒ  rô   r�  r4   r  rœ  )r	  r
  r�  )rç   r‹  Úupdate_vectorsrŒ  r4   )rb   r‚   r!   r¢  r   r£  r   r  r  r  r  rÛ   ÚUpdateVectorsr   ÚUpdatePointVectorsr‰   r  r   r¨  r‹   rn  r²  )
r˜   rç   r	  r‹  rŒ  rô   r�  r4   r;   r¬  s
             rK   r²  z AsyncQdrantRemote.update_vectors  sÝ  è è € ð Ôñ %	ØRÐRÈ6ÐRÑRÔRˆFÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜-­¬Ñ7Ô7ð OÝ *Ô 9ÀÐ NÑ NÔ N�àÔ&×4Ò4ÝÔ+Ø(7Ø!Ø%Ø!)Ø+=Ø&3Ø 'ðñ ô ð !œMð 5ñ ô ð ð ð ð ð ð ô ð ð Ð*Ð*Ð,IÑ*Ô*Ð*ÝÔ3°KÑ@Ô@Ð@å˜-­¬Ñ5Ô5ð OÝ *Ô 9ÀÐ NÑ NÔ N�àÔ)Ô4×CÒCØ$3ØÝ#)Ô#7Ø%Ð1CÐS`ð$ñ $ô $ð &Ø#ð Dñ ô ð ð ð ð ð ð ô ð
rM   r’  c              ‹   óÔ  K  — | j         rý|                      |¦  «        \  }	}
|p|
}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }| j
                             t          j        ||t          j        |¬¦  «        |	|||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚t#          j        |¦  «        S |                      |¦  «        \  }}| j        j                             ||||t/          t          j        ||||¬¦  «        ¬¦  «        ƒ d {V —†j        S )N)Únames)rç   r‹  r’  Úpoints_selectorrŒ  rô   r4   r  z#Delete vectors returned None result)Úvectorr	  rÿ   r
  )rç   r‹  rŒ  r4   Údelete_vectors)rb   Ú_try_argument_to_grpc_selectorr‚   r!   r¢  r   r£  r   r  r  rÛ   ÚDeleteVectorsr   ÚDeletePointVectorsÚVectorsSelectorr‰   r  r   r¨  Ú'_try_argument_to_rest_points_and_filterr‹   rn  r¹  r   )r˜   rç   r’  r	  r‹  rŒ  rô   r4   r;   r·  Úopt_shard_key_selectorr¬  Ú_pointsÚ_filters                 rK   r¹  z AsyncQdrantRemote.delete_vectorsJ  sÊ  è è € ð Ôð '	Ø8<×8[Ò8[Ð\bÑ8cÔ8cÑ5ˆ_Ð4Ø!3Ð!MÐ7MÐÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"àÔ&×4Ò4ÝÔ+Ø(7Ø!Ý $Ô 4¸7Ð CÑ CÔ CØ(7Ø!)Ø+=Ø 'ðñ ô ð !œMð 5ñ ô ð ð ð ð ð ð ô ð ð Ð*Ð*Ð,QÑ*Ô*Ð*ÝÔ3°KÑ@Ô@Ð@à!%×!MÒ!MÈfÑ!UÔ!UÑˆW�gàÔ)Ô4×CÒCØ$3ØØ%Ø#Ý#,ÝÔ,Ø&Ø&Ø&Ø"4ð$ñ $ô $ð Dñ ô ð ð ð ð ð ð ô ðrM   r•  c              ‹   ó’  K  — | j         �r2t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }d„ |D ¦   «         }t          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          |t          t          j
        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t          j        |||||||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†j        }	|	€
J d¦   «         ‚d„ |	D ¦   «         S t          |t          j        ¦  «        rt'          j        |¦  «        }d„ |D ¦   «         }| j        j                             ||t          j        ||||¬¦  «        |¬¦  «        ƒ d {V —†j        }
|
€
J d	¦   «         ‚|
S )
Nc                 óˆ   — g | ]?}t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        n|‘Œ@S rG   ©r‚   r   r!   rc  r   rd  ©rH   r˜  s     rK   rX   z.AsyncQdrantRemote.retrieve.<locals>.<listcomp>Œ  sX   € ð ð ð ð õ ˜cÕ#6µvÔ7MÑ#NÔ#NÑOÔOð•
Ô4°SÑ9Ô9Ð9àðð ð rM   )rç   r•  rï   rð   r  rô   r4   r  zRetrieve returned None resultc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   r]  )rH   Úrecords     rK   rX   z.AsyncQdrantRemote.retrieve.<locals>.<listcomp>¦  s#   € ÐTÐTÐTÀ6•JÔ6°vÑ>Ô>ÐTÐTÐTrM   c                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   ©r‚   r   rk  r   rj  rÅ  s     rK   rX   z.AsyncQdrantRemote.retrieve.<locals>.<listcomp>ª  sJ   € ð ð ð àõ 5?¸sÅDÄLÑ4QÔ4QÐZ•
Ô+¨CÑ0Ô0Ð0ÐWZðð ð rM   )r•  rï   r  r
  )rç   ró   Úpoint_requestr4   z!Retrieve API returned None result)rb   r‚   r   r!   r  r   r  r  r  r  r  r  rÛ   ÚGetr   Ú	GetPointsr‰   r  r!  r   r"  r‹   rn  Ú
get_pointsÚPointRequest)r˜   rç   r•  rï   rð   ró   rô   r4   r;   r  r­  s              rK   ÚretrievezAsyncQdrantRemote.retrieve~  sR  è è € ð Ôñ 3	Ý˜,Õ(;½FÔ<WÑ(XÔ(XÑYÔYð WÝ)ÔHÈÑVÔV�ðð ð ð	ñ ô ˆCõ &Ô:¸<ÑHÔHˆLÝ˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"àÔ&×*Ò*Ý”NØ(7ØØ%1Ø%1Ø)4Ø+=Ø 'ðñ ô ð (/Ð':˜G˜GÀÄð +ñ ô ð ð ð ð ð ð ô ð ð Ð%Ð%Ð'FÑ%Ô%Ð%ØTÐTÈVÐTÑTÔTÐTå˜,­Ô(@ÑAÔAð VÝ)ÔGÈÑUÔU�ðð àðñ ô ˆCð
 Ô)Ô4×?Ò?Ø$3Ø +Ý"(Ô"5ØØ%1Ø$0Ø"4ð	#ñ #ô #ð $ð @ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ô ð ð Ð*Ð*Ð,OÑ*Ô*Ð*ØÐrM   c                 óÀ  — d }t          |t          ¦  «        r4t          j        t          j        d„ |D ¦   «         ¬¦  «        ¬¦  «        }�nt          |t          j        ¦  «        r|}nót          |t          t          j        ¦  «        ¦  «        r5|j        �t          j	        |j        ¦  «        }t          j
        |¦  «        }n—t          |t          j        ¦  «        r.t          j
        t          t          j        |¬¦  «        ¦  «        }nOt          |t          j        ¦  «        rt          j        |¬¦  «        }nt          dt          |¦  «        › �¦  «        ‚||fS )Nc                 óˆ   — g | ]?}t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        n|‘Œ@S rG   rÄ  rÅ  s     rK   rX   zDAsyncQdrantRemote._try_argument_to_grpc_selector.<locals>.<listcomp>Æ  sX   € ð ð ð ð  õ & cÕ+>½vÔ?UÑ+VÔ+VÑWÔWð!�
Ô<¸SÑAÔAÐAà ðð ð rM   )r•  r  )rÿ   ú"Unsupported points selector type: )r‚   r  r   ÚPointsSelectorÚPointsIdsListr   r!   r
  r   r  Úconvert_points_selectorr  r   ÚFilterSelectorrk   r„   )Úclsr	  rô   r·  s       rK   rº  z0AsyncQdrantRemote._try_argument_to_grpc_selector¾  sf  € ð "ÐÝ�f�dÑ#Ô#ð 	RÝ"Ô1ÝÔ)ðð ð $*ð	ñ ô ðñ ô ð	ñ 	ô 	ˆO‰Oõ ˜¥Ô 3Ñ4Ô4ð 	RØ$ˆOˆOÝ˜¥­Ô)>Ñ ?Ô ?Ñ@Ô@ð 	RØÔÐ+Ý%/Ô%JÈ6ÔK[Ñ%\Ô%\Ð"Ý(Ô@ÀÑHÔHˆOˆOÝ˜¥¤Ñ.Ô.ð 	RÝ(Ô@Ý�&Ô/¸Ð?Ñ?Ô?ñô ˆOˆOõ ˜¥¤Ñ,Ô,ð 	RÝ"Ô1¸Ð@Ñ@Ô@ˆOˆOåÐPÅ$ÀvÁ,Ä,ÐPÐPÑQÔQÐQØÐ!3Ð4Ð4rM   c                 ó�  — t          |t          ¦  «        r*d„ |D ¦   «         }t          t          j        ||¬¦  «        }�nt          |t
          j        ¦  «        rt          j        |¦  «        }||_	        nÐt          |t          t          j        ¦  «        ¦  «        r
|}||_	        nŸt          |t          j        ¦  «        rt          t          j        ||¬¦  «        }nht          |t
          j        ¦  «        r/t          t          j        t          j        |¦  «        |¬¦  «        }nt          dt          |¦  «        › �¦  «        ‚|S )Nc                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   rÉ  rÅ  s     rK   rX   zDAsyncQdrantRemote._try_argument_to_rest_selector.<locals>.<listcomp>ã  óJ   € ð ð ð àõ 5?¸sÅDÄLÑ4QÔ4QÐZ•
Ô+¨CÑ0Ô0Ð0ÐWZðð ð rM   )r	  r
  )rÿ   r
  rÒ  )r‚   r  r   r!   ÚPointIdsListr   rÓ  r   rÕ  r
  r   r  rÖ  r  rk   r„   )r×  r	  rô   rÀ  r·  s        rK   Ú_try_argument_to_rest_selectorz0AsyncQdrantRemote._try_argument_to_rest_selectorÞ  sX  € õ �f�dÑ#Ô#ð 	Rðð à!ðñ ô ˆGõ (ÝÔ#¨GÐ?Qðñ ô ˆO‰Oõ ˜¥Ô 3Ñ4Ô4ð 	RÝ(Ô@ÀÑHÔHˆOØ(:ˆOÔ%Ð%Ý˜¥­Ô)>Ñ ?Ô ?Ñ@Ô@ð 	RØ$ˆOØ(:ˆOÔ%Ð%Ý˜¥¤Ñ.Ô.ð 	RÝ'ÝÔ%¨fÐ@Rðñ ô ˆOˆOõ ˜¥¤Ñ,Ô,ð 	RÝ'ÝÔ%Ý!Ô0°Ñ8Ô8Ø,ðñ ô ˆOˆOõ ÐPÅ$ÀvÁ,Ä,ÐPÐPÑQÔQÐQØÐrM   r·  c                 óŒ   — |                      d¦  «        }|€g S t          ||¦  «        }|dk    rt          |j        ¦  «        S g S )NÚpoints_selector_one_ofr	  )Ú
WhichOneofÚgetattrr  r•  )r×  r·  ÚnameÚvals       rK   Ú_points_selector_to_points_listz1AsyncQdrantRemote._points_selector_to_points_listþ  sO   € ð ×)Ò)Ð*BÑCÔCˆØˆ<ØˆIÝ�o tÑ,Ô,ˆØ�8ÒÐÝ˜œ‘=”=Ð Øˆ	rM   c                 óš  — d }d }t          |t          ¦  «        rd„ |D ¦   «         }�n!t          |t          j        ¦  «        rXt	          j        |¦  «        }t          |t          j        ¦  «        r|j        }nÑt          |t          j	        ¦  «        r|j
        }n¯t          |t          j        ¦  «        r|j        }n�t          |t          j	        ¦  «        r|j
        }nkt          |t          j        ¦  «        r|}nNt          |t          j        ¦  «        rt	          j        |¦  «        }nt          dt          |¦  «        › �¦  «        ‚||fS )Nc                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   rÉ  rÅ  s     rK   rX   zMAsyncQdrantRemote._try_argument_to_rest_points_and_filter.<locals>.<listcomp>  rÚ  rM   rÒ  )r‚   r  r   rÓ  r   rÕ  r!   rÛ  r	  rÖ  rÿ   r  r  rk   r„   )r×  r	  rÀ  rÁ  Úselectors        rK   r¾  z9AsyncQdrantRemote._try_argument_to_rest_points_and_filter
  sM  € ð ˆØˆÝ�f�dÑ#Ô#ð 	Rðð à!ðñ ô ˆG‰Gõ ˜¥Ô 3Ñ4Ô4ð 	RÝ!Ô9¸&ÑAÔAˆHÝ˜(¥FÔ$7Ñ8Ô8ð *Ø"œ/��Ý˜H¥fÔ&;Ñ<Ô<ð *Ø"œ/�øÝ˜¥Ô 3Ñ4Ô4ð 		RØ”mˆGˆGÝ˜¥Ô 5Ñ6Ô6ð 	RØ”mˆGˆGÝ˜¥¤Ñ.Ô.ð 	RØˆGˆGÝ˜¥¤Ñ,Ô,ð 	RÝ Ô/°Ñ7Ô7ˆGˆGåÐPÅ$ÀvÁ,Ä,ÐPÐPÑQÔQÐQØ˜Ð!Ð!rM   c              ‹   óp  K  — | j         rÛ|                      |¦  «        \  }}|p|}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||||||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        ¦  «        S |                      ||¦  «        }| j        j                             |||||¬¦  «        ƒ d {V —†j        }	|	€
J d¦   «         ‚|	S )N©rç   r‹  r	  rŒ  rô   r4   r  )rç   r‹  r·  rŒ  r4   zDelete points returned None)rb   rº  r‚   r!   r¢  r   r£  r   r  r  r   r¨  rÛ   ÚDeleter   ÚDeletePointsr‰   r  rÜ  r‹   rn  Údelete_points©
r˜   rç   r·  r‹  rŒ  rô   r4   r;   r¿  r  s
             rK   ÚdeletezAsyncQdrantRemote.delete'  s©  è è € ð Ôð &	Ø8<×8[Ò8[Øñ9ô 9Ñ5ˆ_Ð4ð "4Ð!MÐ7MÐÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"ÝÔ3àÔ*×1Ò1ÝÔ)Ø,;Ø!%Ø#2Ø%-Ø/AØ$+ðñ ô ð !%¤ð 2ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ô ñô ð ð  #×AÒAØÐ!3ñô ˆOð Ô)Ô4×BÒBØ$3ØØ$3Ø%Ø#ð Cñ ô ð ð ð ð ð ð ô ð ð Ð%Ð%Ð'DÑ%Ô%Ð%ØˆMrM   r“  c	              ‹   óÊ  K  — | j         rï|                      |¦  «        \  }
}|p|}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||t          j        |¦  «        |
||||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        ¦  «        S |                      |¦  «        \  }}| j        j                             ||||t          j        |||||¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)rç   r‹  r“  r·  rŒ  rô   rš   r4   r  )r“  r	  rÿ   r
  rš   ©rç   r‹  rŒ  r4   Úset_payloadzSet payload returned None)rb   rº  r‚   r!   r¢  r   r£  r   r  r  r   r¨  rÛ   Ú
SetPayloadr   ÚSetPayloadPointsr—  r‰   r  r¾  r‹   rn  rð  )r˜   rç   r“  r	  rš   r‹  rŒ  rô   r4   r;   r·  r¿  rÀ  rÁ  r  s                  rK   rð  zAsyncQdrantRemote.set_payloadY  sÐ  è è € ð Ôð *	Ø8<×8[Ò8[Ð\bÑ8cÔ8cÑ5ˆ_Ð4Ø!3Ð!MÐ7MÐÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"ÝÔ3àÔ*×5Ò5ÝÔ-Ø,;Ø!%Ý$.Ô$>¸wÑ$GÔ$GØ,;Ø%-Ø/AØ #Ø$+ð	ñ 	ô 	ð !%¤ð 6ñ ô ð ð ð ð ð ð ô ñô ð ð$ "&×!MÒ!MÈfÑ!UÔ!UÑˆW�gàÔ)Ô4×@Ò@Ø$3ØØ%Ø#Ý &Ô 1Ø 'Ø&Ø&Ø"4Øð!ñ !ô !ð Añ ô ð ð ð ð ð ð ô ð ð Ð%Ð%Ð'BÑ%Ô%Ð%ØˆMrM   c              ‹   óÆ  K  — | j         rî|                      |¦  «        \  }	}
|p|
}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||t          j        |¦  «        |	|||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        ¦  «        S |                      |¦  «        \  }}| j        j                             ||||t          j        ||||¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)rç   r‹  r“  r·  rŒ  rô   r4   r  )r“  r	  rÿ   r
  rï  zOverwrite payload returned None)rb   rº  r‚   r!   r¢  r   r£  r   r  r  r   r¨  rÛ   ÚOverwritePayloadr   rò  r—  r‰   r  r¾  r‹   rn  Úoverwrite_payloadrñ  )r˜   rç   r“  r	  r‹  rŒ  rô   r4   r;   r·  r¿  rÀ  rÁ  r  s                 rK   rõ  z#AsyncQdrantRemote.overwrite_payload‘  sÊ  è è € ð Ôð (	Ø8<×8[Ò8[Ð\bÑ8cÔ8cÑ5ˆ_Ð4Ø!3Ð!MÐ7MÐÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"ÝÔ3àÔ*×;Ò;ÝÔ-Ø,;Ø!%Ý$.Ô$>¸wÑ$GÔ$GØ,;Ø%-Ø/AØ$+ðñ ô ð !%¤ð <ñ ô ð ð ð ð ð ð ô ñô ð ð" "&×!MÒ!MÈfÑ!UÔ!UÑˆW�gàÔ)Ô4×FÒFØ$3ØØ%Ø#Ý &Ô 1Ø 'Ø&Ø&Ø"4ð	!ñ !ô !ð Gñ ô ð ð ð ð ð ð ô ð ð Ð%Ð%Ð'HÑ%Ô%Ð%ØˆMrM   Úkeysc              ‹   ó¢  K  — | j         rÜ|                      |¦  «        \  }	}
|p|
}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||||	|||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        ¦  «        S |                      |¦  «        \  }}| j        j                             ||||t          j        ||||¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)rç   r‹  rö  r·  rŒ  rô   r4   r  )rö  r	  rÿ   r
  )rç   r‹  rŒ  r4   Údelete_payloadzDelete payload returned None)rb   rº  r‚   r!   r¢  r   r£  r   r  r  r   r¨  rÛ   ÚDeletePayloadr   ÚDeletePayloadPointsr‰   r  r¾  r‹   rn  rø  )r˜   rç   rö  r	  r‹  rŒ  rô   r4   r;   r·  r¿  rÀ  rÁ  r  s                 rK   rø  z AsyncQdrantRemote.delete_payloadÆ  s½  è è € ð Ôð %	Ø8<×8[Ò8[Ð\bÑ8cÔ8cÑ5ˆ_Ð4Ø!3Ð!MÐ7MÐÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"ÝÔ3àÔ*×8Ò8ÝÔ0Ø,;Ø!%Ø!%Ø,;Ø%-Ø/AØ$+ðñ ô ð !%¤ð 9ñ ô ð ð ð ð ð ð ô ñô ð ð" "&×!MÒ!MÈfÑ!UÔ!UÑˆW�gàÔ)Ô4×CÒCØ$3ØØ%Ø#Ý#)Ô#7Ø!¨'¸'ÐM_ð$ñ $ô $ð Dñ ô ð ð ð ð ð ð ô ð ð Ð%Ð%Ð'EÑ%Ô%Ð%ØˆMrM   c              ‹   óp  K  — | j         rÛ|                      |¦  «        \  }}|p|}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||||||¬¦  «        | j        ¬¦  «        ƒ d {V —†j        ¦  «        S |                      ||¦  «        }| j        j                             |||||¬¦  «        ƒ d {V —†j        }	|	€
J d¦   «         ‚|	S )Nrè  r  )rç   r‹  rŒ  r4   r·  zClear payload returned None)rb   rº  r‚   r!   r¢  r   r£  r   r  r  r   r¨  rÛ   ÚClearPayloadr   ÚClearPayloadPointsr‰   r  rÜ  r‹   rn  Úclear_payloadrì  s
             rK   rþ  zAsyncQdrantRemote.clear_payloadø  s©  è è € ð Ôð &	Ø8<×8[Ò8[Øñ9ô 9Ñ5ˆ_Ð4ð "4Ð!MÐ7MÐÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ÝÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"ÝÔ3àÔ*×7Ò7ÝÔ/Ø,;Ø!%Ø#2Ø%-Ø/AØ$+ðñ ô ð !%¤ð 8ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ô ñô ð ð  #×AÒAØÐ!3ñô ˆOð Ô)Ô4×BÒBØ$3ØØ%Ø#Ø$3ð Cñ ô ð ð ð ð ð ð ô ð ð Ð%Ð%Ð'DÑ%Ô%Ð%ØˆMrM   Úupdate_operationsc           
   ‹   óÂ  K  — | j         r‡d„ |D ¦   «         }t          |t          j        ¦  «        rt	          j        |¦  «        }d„ | j                             t          j	        |||||¬¦  «        | j
        ¬¦  «        ƒ d {V —†j        D ¦   «         S | j        j                             ||||t          j        |¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_update_operation©rH   Ú	operations     rK   rX   z9AsyncQdrantRemote.batch_update_points.<locals>.<listcomp>4  s0   € ð !ð !ð !ØCL•
Ô3°IÑ>Ô>ð!ð !ð !rM   c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   r¨  )rH   r  s     rK   rX   z9AsyncQdrantRemote.batch_update_points.<locals>.<listcomp>9  s3   € ð ð ð àõ Ô0°Ñ8Ô8ðð ð rM   )rç   r‹  Ú
operationsrŒ  r4   r  )r  )rç   r‹  rŒ  r4   rÿ  z!Batch update points returned None)rb   r‚   r!   r¢  r   r£  rÛ   ÚUpdateBatchr   ÚUpdateBatchPointsr‰   r  r‹   rn  Úbatch_updateÚUpdateOperations)r˜   rç   rÿ  r‹  rŒ  r4   r;   r  s           rK   Úbatch_update_pointsz%AsyncQdrantRemote.batch_update_points*  sf  è è € ð Ôð  	ð!ð !ØPað!ñ !ô !Ðõ ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ðð ð Ô*×6Ò6ÝÔ.Ø,;Ø!%Ø'8Ø%-Ø$+ðñ ô ð !%¤ð 7ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ô ðñ ô ð ð" Ô)Ô4×AÒAØ$3ØØ%Ø#Ý&,Ô&=ÐIZÐ&[Ñ&[Ô&[ð Bñ ô ð ð ð ð ð ð ô ð ð Ð%Ð%Ð'JÑ%Ô%Ð%ØˆMrM   Úchange_aliases_operationsc              ‹   óf  K  — | j         rPd„ |D ¦   «         }| j                             t          j        ||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†j        S d„ |D ¦   «         }| j        j         	                    |t          j        |¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nc                 ón   — g | ]2}t          |t          j        ¦  «        st          j        |¦  «        n|‘Œ3S rG   )r‚   r   ÚAliasOperationsr   Úconvert_alias_operationsr  s     rK   rX   z?AsyncQdrantRemote.update_collection_aliases.<locals>.<listcomp>\  sO   € ð (ð (ð (ð õ " )­TÔ-AÑBÔBð•
Ô3°IÑ>Ô>Ð>àð(ð (ð (rM   )r4   Úactionsr  c                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   )r‚   r   r  r   r  r  s     rK   rX   z?AsyncQdrantRemote.update_collection_aliases.<locals>.<listcomp>h  sO   € ð $
ð $
ð $
ð õ ˜)¥TÔ%9Ñ:Ô:ð�JÔ/°	Ñ:Ô:Ð:àð$
ð $
ð $
rM   )r  )r4   Úchange_aliases_operationzUpdate aliases returned None)rb   rÙ   ÚUpdateAliasesr   ÚChangeAliasesr‰   r  r=   Úaliases_apiÚupdate_aliasesr!   ÚChangeAliasesOperation)r˜   r  r4   r;   r  r  s         rK   Úupdate_collection_aliasesz+AsyncQdrantRemote.update_collection_aliasesU  s:  è è € ð Ôð 	ð(ð (ð ";ð	(ñ (ô (Ð$ð Ô+×9Ò9ÝÔ&¨wÐ@XÐYÑYÔYØ'.Ð':˜G˜GÀÄð :ñ ô ð ð ð ð ð ð ô ðð$
ð $
ð 7ð	$
ñ $
ô $
Ð ð ”)Ô'×6Ò6ØÝ)/Ô)FØ4ð*ñ *ô *ð 7ñ ô ð ð ð ð ð ð ô ð 	ð Ð!Ð!Ð#AÑ!Ô!Ð!ØˆrM   c              ‹   óB  K  — | j         r^| j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —†j        }t          j        d„ |D ¦   «         ¬¦  «        S | j	        j
                             |¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N©rç   r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   ©r   Úconvert_alias_description©rH   Údescriptions     rK   rX   z<AsyncQdrantRemote.get_collection_aliases.<locals>.<listcomp>„  ó0   € ð ð ð ØJU•JÔ8¸ÑEÔEðð ð rM   ©Úaliasesz$Get collection aliases returned None)rb   rÙ   ÚListCollectionAliasesr   ÚListCollectionAliasesRequestr‰   r#  r†  ÚCollectionsAliasesResponser=   r  Úget_collection_aliasesr  ©r˜   rç   r;   rS  r  s        rK   r'  z(AsyncQdrantRemote.get_collection_aliasesy  sö   è è € ð Ôð 	àÔ+×AÒAÝÔ5ÀoÐVÑVÔVØ œMð Bñ ô ð ð ð ð ð ð ô ð õ Ô3ðð ØYaðñ ô ðñ ô ð ð ”)Ô'×>Ò>ÈÐ>Ñ_Ô_Ð_Ð_Ð_Ð_Ð_Ð_Ü
ð 	ð Ð!Ð!Ð#IÑ!Ô!Ð!ØˆrM   c              ‹   ó:  K  — | j         r\| j                             t          j        ¦   «         | j        ¬¦  «        ƒ d {V —†j        }t          j        d„ |D ¦   «         ¬¦  «        S | j	        j
                             ¦   «         ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nr  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   r  r  s     rK   rX   z1AsyncQdrantRemote.get_aliases.<locals>.<listcomp>–  r!  rM   r"  zGet aliases returned None)rb   rÙ   ÚListAliasesr   ÚListAliasesRequestr‰   r#  r†  r&  r=   r  Úget_collections_aliasesr  ©r˜   r;   rS  r  s       rK   Úget_aliaseszAsyncQdrantRemote.get_aliasesŽ  sè   è è € ØÔð 
	àÔ+×7Ò7ÝÔ+Ñ-Ô-°t´}ð 8ñ ô ð ð ð ð ð ð ô ð	 õ
 Ô3ðð ØYaðñ ô ðñ ô ð ð ”)Ô'×?Ò?ÑAÔAÐAÐAÐAÐAÐAÐAÜ
ð 	ð Ð!Ð!Ð#>Ñ!Ô!Ð!ØˆrM   c              ‹   ó:  K  — | j         r\| j                             t          j        ¦   «         | j        ¬¦  «        ƒ d {V —†j        }t          j        d„ |D ¦   «         ¬¦  «        S | j	        j
                             ¦   «         ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nr  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_collection_descriptionr  s     rK   rX   z5AsyncQdrantRemote.get_collections.<locals>.<listcomp>¨  s3   € ð ð ð à#õ Ô=¸kÑJÔJðð ð rM   )ÚcollectionszGet collections returned None)rb   rÙ   ÚListr   ÚListCollectionsRequestr‰   r3  r†  ÚCollectionsResponser=   Úcollections_apiÚget_collectionsr  r.  s       rK   r8  z!AsyncQdrantRemote.get_collections   sè   è è € ØÔð 	àÔ+×0Ò0ÝÔ/Ñ1Ô1¸4¼=ð 1ñ ô ð ð ð ð ð ð ô ð	 õ
 Ô,ðð à'/ðñ ô ðñ ô ð ð ”)Ô+×;Ò;Ñ=Ô=Ð=Ð=Ð=Ð=Ð=Ð=Ü
ð 	ð Ð!Ð!Ð#BÑ!Ô!Ð!ØˆrM   c              ‹   ó(  K  — | j         rQt          j        | j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —†j        ¦  «        S | j	        j
                             |¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nr  r  zGet collection returned None)rb   r   Úconvert_collection_inforÙ   rË  r   ÚGetCollectionInfoRequestr‰   r  r=   r7  Úget_collection©r˜   rç   r;   r  s       rK   r<  z AsyncQdrantRemote.get_collection³  sË   è è € ØÔð 	ÝÔ5àÔ/×3Ò3ÝÔ5ÀoÐVÑVÔVØ $¤ð 4ñ ô ð ð ð ð ð ð ô ñô ð ð ”)Ô+×:Ò:È?Ð:Ñ[Ô[Ð[Ð[Ð[Ð[Ð[Ð[Ü
ð 	ð Ð!Ð!Ð#AÑ!Ô!Ð!ØˆrM   c              ‹   ó  K  — | j         rD| j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —†j        j        S | j        j	         
                    |¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|j        S )Nr  r  zCollection exists returned None)rb   rÙ   ÚCollectionExistsr   ÚCollectionExistsRequestr‰   r  Úexistsr=   r7  Úcollection_existsr=  s       rK   rB  z#AsyncQdrantRemote.collection_existsÃ  sÀ   è è € ØÔð 	àÔ+×<Ò<ÝÔ0ÀÐQÑQÔQØ œMð =ñ ô ð ð ð ð ð ð ô ”Vðð ”)Ô+×=Ò=ÈoÐ=Ñ^Ô^Ð^Ð^Ð^Ð^Ð^Ð^Ü
ð 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØŒ}ÐrM   Úoptimizers_configÚcollection_paramsÚvectors_configÚhnsw_configÚquantization_configÚsparse_vectors_configÚstrict_mode_configrN   c              ‹   ó   K  — | j         �rºt          |t          j        ¦  «        rt	          j        |¦  «        }t          |t          j        ¦  «        rt	          j        |¦  «        }t          |t          ¦  «        rt	          j	        |¦  «        }t          |t          j
        ¦  «        rt	          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        }t          |t          ¦  «        rt	          j        |¦  «        }t          |	t          j        ¦  «        rt	          j        |	¦  «        }	t          |
t          ¦  «        rt	          j        |
¦  «        }
| j                             t+          j        ||||||||	||
¬¦
  «
        |�|n| j        ¬¦  «        ƒ d {V —†j        S t          |t*          j        ¦  «        rt3          j        |¦  «        }t          |t*          j        ¦  «        rt3          j        |¦  «        }t          |t*          j        ¦  «        rt3          j	        |¦  «        }t          |t*          j
        ¦  «        rt3          j        |¦  «        }t          |t*          j        ¦  «        rt3          j        |¦  «        }| j        j                             |t          j        |||||||	|
¬¦  «        |¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)
rç   rC  r   rE  rF  rG  rH  rI  r4   rN   r  )rC  r   r’  rF  rG  Úsparse_vectorsrI  rN   )Úupdate_collectionr4   zUpdate collection returned None)rb   r‚   r!   ÚOptimizersConfigDiffr   Úconvert_optimizers_config_diffÚCollectionParamsDiffÚconvert_collection_params_diffÚdictÚconvert_vectors_config_diffÚHnswConfigDiffÚconvert_hnsw_config_diffr   ÚQuantizationConfigDiffÚ convert_quantization_config_diffÚconvert_sparse_vector_configÚStrictModeConfigÚconvert_strict_mode_configr—  rÙ   ÚUpdater   ÚUpdateCollectionr‰   r  r   ÚVectorsConfigDiffr=   r7  rL  )r˜   rç   rC  rD  rE  rF  rG  r4   rH  rI  rN   r;   r  s                rK   rL  z#AsyncQdrantRemote.update_collectionÑ  s@  è è € ð Ôñ %	ÝÐ+­VÔ-HÑIÔIð aÝ$.Ô$MÐN_Ñ$`Ô$`Ð!ÝÐ+­VÔ-HÑIÔIð aÝ$.Ô$MÐN_Ñ$`Ô$`Ð!Ý˜.­$Ñ/Ô/ð XÝ!+Ô!GÈÑ!WÔ!W�Ý˜+¥vÔ'<Ñ=Ô=ð OÝ(ÔAÀ+ÑNÔN�ÝÐ-­x½Ô8UÑ/VÔ/VÑWÔWð Ý&0Ô&QØ'ñ'ô 'Ð#õ Ð/µÑ6Ô6ð Ý(2Ô(OØ)ñ)ô )Ð%õ Ð,­fÔ.EÑFÔFð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜(¥DÑ)Ô)ð @Ý%Ô5°hÑ?Ô?�àÔ+×2Ò2ÝÔ)Ø(7Ø*;Ø0Ø'5Ø$/Ø,?Ø.CØ+=Ø 'Ø!)ðñ ô ð (/Ð':˜G˜GÀÄð 3ñ ô ð ð ð ð ð ð ô ð!õ" Ð'­Ô)BÑCÔCð 	]Ý *Ô IÐJ[Ñ \Ô \ÐÝÐ'­Ô)BÑCÔCð 	]Ý *Ô IÐJ[Ñ \Ô \ÐÝ�n¥dÔ&<Ñ=Ô=ð 	TÝ'ÔCÀNÑSÔSˆNÝ�k¥4Ô#6Ñ7Ô7ð 	KÝ$Ô=¸kÑJÔJˆKÝÐ)­4Ô+FÑGÔGð 	cÝ",Ô"MÐNaÑ"bÔ"bÐà”)Ô+×=Ò=ØÝ"(Ô"9Ø&7Ø,Ø*Ø +Ø(;Ø#8Ø'9Ø%ð	#ñ 	#ô 	#ð  ð >ñ ô ð ð ð ð ð ð ô ð 	ð  Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   c              ‹   ó  K  — | j         rD| j                             t          j        ||¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†j        S | j        j         	                    ||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N©rç   r4   r  zDelete collection returned None)
rb   rÙ   ré  r   ÚDeleteCollectionr‰   r  r=   r7  Údelete_collection)r˜   rç   r4   r;   r  s        rK   r`  z#AsyncQdrantRemote.delete_collection"  sÌ   è è € ð Ôð 	àÔ+×2Ò2ÝÔ)¸/ÐSZÐ[Ñ[Ô[Ø'.Ð':˜G˜GÀÄð 3ñ ô ð ð ð ð ð ð ô ðð ”)Ô+×=Ò=¸oÐW^Ð=Ñ_Ô_Ð_Ð_Ð_Ð_Ð_Ð_Ü
ð 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   Úshard_numberÚreplication_factorÚwrite_consistency_factorÚon_disk_payloadÚ
wal_configÚsharding_methodc              ‹   óÂ  K  — | j         �rAt          |t          j        t          f¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          j	        ¦  «        rt          j
        |¦  «        }t          |	t          j        ¦  «        rt          j        |	¦  «        }	t          |
t          t          j        ¦  «        ¦  «        rt          j        |
¦  «        }
t          |t          ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }t1          j        di d|“d|“d|	“d|“d|“d|“d|“d|“d	|“d
|“d|
“d|“d|“d|“d|“d|“Ž}| j                             || j        ¬¦  «        ƒ d {V —†j        S t          |t0          j        ¦  «        rt=          j        |¦  «        }t          |t0          j	        ¦  «        rt=          j
        |¦  «        }t          |	t0          j        ¦  «        rt=          j        |	¦  «        }	t          |
t0          j        ¦  «        rt=          j        |
¦  «        }
t          j        ||||||||	|
|||||¬¦  «        }| j        j          !                    |||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nrç   rF  re  rC  ra  rd  r4   rE  rb  rc  rG  rH  rf  rI  rN   r“  r  )r’  ra  rb  rc  rd  rF  rC  re  rG  rK  rf  rI  rN   r“  )rç   Úcreate_collectionr4   zCreate collection returned NonerG   )"rb   r‚   r!   ÚVectorParamsrQ  r   Úconvert_vectors_configrS  rT  rM  rN  ÚWalConfigDiffÚconvert_wal_config_diffr   ÚQuantizationConfigÚconvert_quantization_configrW  ÚShardingMethodÚconvert_sharding_methodrX  rY  r—  ÚPayloadStorageParamsÚconvert_payload_storage_paramsr   ÚCreateCollectionrÙ   ÚCreater‰   r  r   r=   r7  rh  )r˜   rç   rE  ra  rb  rc  rd  rF  rC  re  rG  r4   rH  rf  rI  rN   r“  r;   rh  Úcreate_collection_requestr  s                        rK   rh  z#AsyncQdrantRemote.create_collection2  s  è è € ð( Ôñ +	Ý˜.­6Ô+>ÅÐ*EÑFÔFð SÝ!+Ô!BÀ>Ñ!RÔ!R�Ý˜+¥vÔ'<Ñ=Ô=ð OÝ(ÔAÀ+ÑNÔN�ÝÐ+­VÔ-HÑIÔIð aÝ$.Ô$MÐN_Ñ$`Ô$`Ð!Ý˜*¥fÔ&:Ñ;Ô;ð LÝ'Ô?À
ÑKÔK�
ÝÐ-­x½Ô8QÑ/RÔ/RÑSÔSð bÝ&0Ô&LÐM`Ñ&aÔ&aÐ#ÝÐ/µÑ6Ô6ð Ý(2Ô(OØ)ñ)ô )Ð%õ ˜/­6Ô+@ÑAÔAð VÝ",Ô"DÀ_Ñ"UÔ"U�ÝÐ,­fÔ.EÑFÔFð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"Ý˜(¥DÑ)Ô)ð @Ý%Ô5°hÑ?Ô?�Ý˜'¥6Ô#>Ñ?Ô?ð MÝ$ÔCÀGÑLÔL�Ý $Ô 5ð !ð !ð !Ø / ð!à'˜Kð!ð &˜:ð!ð #4Ð"3ð	!ð
 *˜\ð!ð !0 ð!ð  ˜ð!ð  .˜~ð!ð $6Ð#5ð!ð *BÐ)Að!ð %8Ð$7ð!ð '<Ð&;ð!ð !0 ð!ð $6Ð#5ð!ð "˜ð!ð   ˜ð!!Ðð& Ô+×2Ò2Ð3DÈdÌmÐ2Ñ\Ô\Ð\Ð\Ð\Ð\Ð\Ð\Üðõ �k¥4Ô#6Ñ7Ô7ð 	KÝ$Ô=¸kÑJÔJˆKÝÐ'­Ô)BÑCÔCð 	]Ý *Ô IÐJ[Ñ \Ô \ÐÝ�j¥$Ô"4Ñ5Ô5ð 	HÝ#Ô;¸JÑGÔGˆJÝÐ)­4Ô+BÑCÔCð 	^Ý",Ô"HÐI\Ñ"]Ô"]ÐÝ$*Ô$;Ø"Ø%Ø1Ø%=Ø+Ø#Ø/Ø!Ø 3Ø0Ø+Ø1ØØð%
ñ %
ô %
Ð!ð" ”)Ô+×=Ò=Ø /Ø";Øð >ñ ô ð ð ð ð ð ð ô
 ð 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   c              ‹   ó–   K  — |                       ||¬¦  «        ƒ d {V —† |                      |||||||||	|
||||||¬¦  «        ƒ d {V —†S )Nr  )rç   rE  ra  rb  rc  rd  rF  rC  re  rG  r4   rH  rf  rI  rN   r“  )r`  rh  )r˜   rç   rE  ra  rb  rc  rd  rF  rC  re  rG  r4   rH  rf  rI  rN   r“  r;   s                     rK   Úrecreate_collectionz%AsyncQdrantRemote.recreate_collection”  sž   è è € ð( ×$Ò$ _¸gÐ$ÑFÔFÐFÐFÐFÐFÐFÐFÐFØ×+Ò+Ø+Ø)Ø%Ø1Ø%=Ø+Ø#Ø/Ø!Ø 3ØØ"7Ø+Ø1ØØð! ,ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
rM   c                 ó,   — | j         rt          S t          S r©   )rb   r$   r%   rª   s    rK   Ú_updater_classz AsyncQdrantRemote._updater_class¼  s   € àÔð 	%Ý$Ð$å$Ð$rM   r>   Úbatches_iteratorÚmax_retriesÚparallelÚmethodc
                 óä  — |�4|t          ¦   «         v r|}
n5t          d|› dt          ¦   «         › �¦  «        ‚dt          ¦   «         v rdnd}
| j        r.|| j        | j        || j        | j        ||| j        | j        ||	dœ}n|| j	        |||||	dœ| j
        ¥}|dk    r, | j        j        d	i |¤Ž}|                     |¦  «        D ]}Œd S t          || j        |
¬¦  «        } |j        |fi |¤ŽD ]}Œd S )
NzStart methods z& is not available, available methods: Ú
forkserverÚspawn)rç   r5   r.   r{  r¼   rN   r‹  rô   r½   r4   r�  rŽ  )rç   Úurir{  r‹  rô   r�  rŽ  r>   )Ústart_methodrG   )r   rk   rb   rm   rc   re   rx   rd   r‰   r‡   rˆ   ry  r—   Úprocessr#   Úunordered_map)r˜   rz  rç   r{  r|  r}  r‹  rô   r�  rŽ  r‚  Úupdater_kwargsÚupdaterrW   Úpools                  rK   Ú_upload_collectionz$AsyncQdrantRemote._upload_collectionÃ  sƒ  € ð ÐØÕ.Ñ0Ô0Ð0Ð0Ø%��å Øl VÐlÐlÕShÑSjÔSjÐlÐlñô ð ð ,8Õ;PÑ;RÔ;RÐ+RÐ+R˜<˜<ÐX_ˆLØÔð 	à#2Øœ
ØœØ*Ø”{Ø Ô.ØØ&8ØÔ-Øœ=Ø!.Ø*ðð ˆNˆNð  $3Ø”}Ø*ØØ&8Ø!.Ø*ð	ð 	ð ”/ð	ˆNð �qŠ=ˆ=Ø/�dÔ)Ô/ÐAÐA°.ÐAÐAˆGØ—_’_Ð%5Ñ6Ô6ð ð �Øðð õ & h°Ô0CÐR^Ð_Ñ_Ô_ˆDØ'�TÔ'Ð(8ÐKÐK¸NÐKÐKð ð �Øðð rM   é@   Ú
batch_sizec                 óz   — | j                              ||¬¦  «        }|                      ||||||||	|
¬¦	  «	         d S )N)ÚrecordsrŠ  ©	rz  rç   r{  r|  r}  r‹  rô   r�  rŽ  )ry  Úiterate_records_batchesrˆ  )r˜   rç   r	  rŠ  r|  r}  r{  r‹  rô   r�  rŽ  r;   rz  s                rK   Úupload_pointszAsyncQdrantRemote.upload_pointsû  sl   € ð  Ô.×FÒFØ zð Gñ 
ô 
Ðð 	×ÒØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 ñ 
	
ô 
	
ð 
	
ð 
	
ð 
	
rM   c                 ó~   — | j                              ||||¬¦  «        }|                      ||||||	|
||¬¦	  «	         d S )N)r’  r“  r•  rŠ  r�  )ry  Úiterate_batchesrˆ  )r˜   rç   r’  r“  r•  rŠ  r|  r}  r{  r‹  rô   r�  rŽ  r;   rz  s                  rK   Úupload_collectionz#AsyncQdrantRemote.upload_collection  so   € ð   Ô.×>Ò>Ø W°#À*ð ?ñ 
ô 
Ðð 	×ÒØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 ñ 
	
ô 
	
ð 
	
ð 
	
ð 
	
rM   Ú
field_nameÚfield_schemaÚ
field_typec           	   ‹   ó  K  — |�t          dt          dd¬¦  «         |}| j        �r½d }	t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          ¦  «        r&t          j        t	          j        |¦  «        ¦  «        }t          |t          ¦  «        rt          |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        �r|}	|	                     d¦  «        }
t#          |	|
¦  «        }t          |t          j        ¦  «        rt          j        j        }t          |t          j        ¦  «        rt          j        j        }t          |t          j        ¦  «        rt          j        j        }t          |t          j        ¦  «        rt          j        j        }t          |t          j        ¦  «        rt          j        j        }t          |t          j        ¦  «        rt          j        j        }t          |t          j        ¦  «        rt          j        j         }t          |t          j!        ¦  «        rt          j        j"        }t          j#        ||||	|||¬¦  «        }tI          j%        | j&         '                    || j(        ¬¦  «        ƒ d {V —†j)        ¦  «        S t          |t          ¦  «        rtI          j        |¦  «        }t          |t          j        ¦  «        rtI          j        |¦  «        }| j*        j+         ,                    |t	          j'        ||¬¦  «        |||¬	¦  «        ƒ d {V —†j)        }|€
J d
¦   «         ‚|S )Nz2field_type is deprecated, use field_schema insteadr)   zpayload-index-field-type)rQ   rR   rS   r˜  Úindex_params)rç   r“  r•  Úfield_index_paramsr‹  rŒ  r4   r  )r“  r”  )rç   Úcreate_field_indexr‹  rŒ  r4   z Create field index returned None)-r   ÚDeprecationWarningrb   r‚   r!   ÚPayloadSchemaTyper   Úconvert_payload_schema_typerA  Úintr   r   ÚPayloadSchemaParamsÚconvert_payload_schema_paramsr   ÚPayloadIndexParamsrß  rà  ÚTextIndexParamsÚ	FieldTypeÚFieldTypeTextÚIntegerIndexParamsÚFieldTypeIntegerÚKeywordIndexParamsÚFieldTypeKeywordÚFloatIndexParamsÚFieldTypeFloatÚGeoIndexParamsÚFieldTypeGeoÚBoolIndexParamsÚFieldTypeBoolÚDatetimeIndexParamsÚFieldTypeDatetimeÚUuidIndexParamsÚFieldTypeUuidÚCreateFieldIndexCollectionr   r¨  rÛ   ÚCreateFieldIndexr‰   r  r‹   Úindexes_apir™  )r˜   rç   r“  r”  r•  r‹  rŒ  r4   r;   r˜  rá  r—  Úrequestr  s                 rK   Úcreate_payload_indexz&AsyncQdrantRemote.create_payload_index7  sx  è è € ð Ð!ÝØLÝ+ØØ.ð	ñ ô ð ð &ˆLØÔñ +	Ø!%ÐÝ˜,­Ô(@ÑAÔAð TÝ)ÔEÀlÑSÔS�Ý˜,­Ñ,Ô,ð Ý)ÔEÝÔ,¨\Ñ:Ô:ñ ô  �õ ˜,­Ñ,Ô,ð OÝ@ÀÑNÔN�Ý˜,­µÔ1KÑ(LÔ(LÑMÔMð VÝ)ÔGÈÑUÔU�Ý˜,­Ô(?Ñ@Ô@ñ @Ø%1Ð"Ø)×4Ò4°^ÑDÔD�Ý&Ð'9¸4Ñ@Ô@�Ý˜l­DÔ,@ÑAÔAð @Ý#'¤>Ô#?�LÝ˜l­DÔ,CÑDÔDð CÝ#'¤>Ô#B�LÝ˜l­DÔ,CÑDÔDð CÝ#'¤>Ô#B�LÝ˜l­DÔ,AÑBÔBð AÝ#'¤>Ô#@�LÝ˜l­DÔ,?Ñ@Ô@ð ?Ý#'¤>Ô#>�LÝ˜l­DÔ,@ÑAÔAð @Ý#'¤>Ô#?�LÝ˜l­DÔ,DÑEÔEð DÝ#'¤>Ô#C�LÝ˜l­DÔ,@ÑAÔAð @Ý#'¤>Ô#?�LÝÔ5Ø /Ø%Ø'Ø#5ØØ!Øðñ ô ˆGõ Ô3ØÔ'×8Ò8¸È$Ì-Ð8ÑXÔXÐXÐXÐXÐXÐXÐXÔ`ñô ð õ �l¥CÑ(Ô(ð 	PÝ%ÔAÀ,ÑOÔOˆLÝ�l¥DÔ$;Ñ<Ô<ð 	RÝ%ÔCÀLÑQÔQˆLàÔ%Ô1×DÒDØ /Ý#)Ô#:Ø)¸ð$ñ $ô $ð Ø!Øð Eñ ô ð ð ð ð ð ð ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   c              ‹   ó<  K  — | j         rWt          j        |||||¬¦  «        }t          j        | j                             || j        ¬¦  «        ƒ d {V —†j        ¦  «        S | j	        j
                             |||||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)rç   r“  r‹  rŒ  r4   r  z Delete field index returned None)rb   r   ÚDeleteFieldIndexCollectionr   r¨  rÛ   ÚDeleteFieldIndexr‰   r  r‹   r´  Údelete_field_index)	r˜   rç   r“  r‹  rŒ  r4   r;   rµ  r  s	            rK   Údelete_payload_indexz&AsyncQdrantRemote.delete_payload_indexˆ  sô   è è € ð Ôð 
	ÝÔ5Ø /Ø%ØØ!Øðñ ô ˆGõ Ô3ØÔ'×8Ò8¸È$Ì-Ð8ÑXÔXÐXÐXÐXÐXÐXÐXÔ`ñô ð ð Ô%Ô1×DÒDØ /Ø%ØØ!Øð Eñ ô ð ð ð ð ð ð ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   Úvector_nameÚvector_name_configc           	   ‹   óÆ  K  — | j         �ršd }d }	t          |t          j        ¦  «        r||j        }
t          j        |
j        t          j	        |
j
        ¦  «        |
j        �t          j        |
j        ¦  «        nd |
j        �t          j        |
j        ¦  «        nd ¬¦  «        }nwt          |t          j        ¦  «        r]|j        }
t          j        |
j        �t          j        |
j        ¦  «        nd |
j        �t          j        |
j        ¦  «        nd ¬¦  «        }	t          |t          j        ¦  «        rt          j        |¦  «        nd }t          j        |||||	||¬¦  «        }t/          j        | j                             || j        ¬¦  «        ƒ d {V —†j        ¦  «        S | j        j                             ||||||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)ÚsizeÚdistanceÚmultivector_configÚdatatype)ÚmodifierrÂ  )rç   r‹  r¼  Údense_configÚsparse_configr4   rŒ  r  )rç   r¼  r‹  rŒ  r4   r½  z Create vector name returned None) rb   r‚   r!   ÚDenseVectorNameConfigÚdenser   ÚDenseVectorCreationConfigr¿  r   Úconvert_distancerÀ  rÁ  Úconvert_multivector_configrÂ  Úconvert_datatypeÚSparseVectorNameConfigÚsparseÚSparseVectorCreationConfigrÃ  Úconvert_modifierr¢  r£  ÚCreateVectorNameRequestr   r¨  rÛ   ÚCreateVectorNamer‰   r  r=   r7  Úcreate_vector_name)r˜   rç   r¼  r½  r‹  rŒ  r4   r;   rÄ  rÅ  ÚcfgÚgrpc_orderingrµ  r  s                 rK   rÒ  z$AsyncQdrantRemote.create_vector_name¨  sF  è è € ð Ôñ +	ØˆLØ ˆMÝÐ,­fÔ.JÑKÔKð Ø(Ô.�Ý#Ô=ØœÝ'Ô8¸¼ÑFÔFð Ô-Ð9õ (2Ô'LØÔ.ñ(ô (ð (ð à”|Ð/õ (Ô8¸¼ÑFÔFÐFàð ñ  ô  ��õ Ð.µÔ0MÑNÔNð 	Ø(Ô/�Ý $Ô ?à”|Ð/õ (Ô8¸¼ÑFÔFÐFàà”|Ð/õ (Ô8¸¼ÑFÔFÐFàð!ñ !ô !�õ ˜h­Ô(<Ñ=Ô=ð•
Ô1°(Ñ;Ô;Ð;àð õ
 Ô2Ø /ØØ'Ø)Ø+ØØ&ðñ ô ˆGõ Ô3ØÔ'×8Ò8¸È$Ì-Ð8ÑXÔXÐXÐXÐXÐXÐXÐXÔ`ñô ð ð ”)Ô+×>Ò>Ø /Ø'ØØ!ØØ#5ð ?ñ ô ð ð ð ð ð ð ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   c              ‹   óœ  K  — | j         r‡t          |t          j        ¦  «        rt	          j        |¦  «        nd }t          j        |||||¬¦  «        }t          j	        | j
                             || j        ¬¦  «        ƒ d {V —†j        ¦  «        S | j        j                             |||||¬¦  «        ƒ d {V —†j        }	|	€
J d¦   «         ‚|	S )N)rç   r‹  r¼  r4   rŒ  r  )rç   r¼  r‹  rŒ  r4   z Delete vector name returned None)rb   r‚   r!   r¢  r   r£  r   ÚDeleteVectorNameRequestr   r¨  rÛ   ÚDeleteVectorNamer‰   r  r‹   r7  Údelete_vector_name)
r˜   rç   r¼  r‹  rŒ  r4   r;   rÔ  rµ  r  s
             rK   rØ  z$AsyncQdrantRemote.delete_vector_nameë  s%  è è € ð Ôð 	õ ˜h­Ô(<Ñ=Ô=ð•
Ô1°(Ñ;Ô;Ð;àð õ
 Ô2Ø /ØØ'ØØ&ðñ ô ˆGõ Ô3ØÔ'×8Ò8¸È$Ì-Ð8ÑXÔXÐXÐXÐXÐXÐXÐXÔ`ñô ð ð Ô%Ô5×HÒHØ /Ø'ØØ!Øð Iñ ô ð ð ð ð ð ð ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   c              ‹   ó  K  — | j         rK| j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —†j        }d„ |D ¦   «         S | j        j         	                    |¬¦  «        ƒ d {V —†j
        }|€
J d¦   «         ‚|S )Nr  r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   ©r   Úconvert_snapshot_description©rH   Úsnapshots     rK   rX   z4AsyncQdrantRemote.list_snapshots.<locals>.<listcomp>	  ó#   € Ð`Ð`Ð`È(•JÔ;¸HÑEÔEÐ`Ð`Ð`rM   ú'List snapshots API returned None result)rb   rÝ   r4  r   ÚListSnapshotsRequestr‰   Úsnapshot_descriptionsr‹   Úsnapshots_apiÚlist_snapshotsr  )r˜   rç   r;   Ú	snapshotss       rK   rä  z AsyncQdrantRemote.list_snapshots	  s×   è è € ð Ôð 	aàÔ)×.Ò.ÝÔ-¸oÐNÑNÔNØ œMð /ñ ô ð ð ð ð ð ð ô $ð ð aÐ`ÐV_Ð`Ñ`Ô`Ð`àÔ%Ô3×BÒBÐSbÐBÑcÔcÐcÐcÐcÐcÐcÐcÜ
ð 	ð Ð$Ð$Ð&OÑ$Ô$Ð$ØÐrM   c              ‹   ó  K  — | j         rS| j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —†j        }t          j        |¦  «        S | j	        j
                             ||¬¦  «        ƒ d {V —†j        S )Nr  r  )rç   r‹  )rb   rÝ   rt  r   ÚCreateSnapshotRequestr‰   Úsnapshot_descriptionr   rÜ  r‹   rã  Úcreate_snapshotr  )r˜   rç   r‹  r;   rÞ  s        rK   ré  z!AsyncQdrantRemote.create_snapshot!	  sÌ   è è € ð Ôð 	EàÔ)×0Ò0ÝÔ.¸ÐOÑOÔOØ œMð 1ñ ô ð ð ð ð ð ð ô #ð õ Ô:¸8ÑDÔDÐDàÔ%Ô3×CÒCØ /°dð Dñ ô ð ð ð ð ð ð ô ð		rM   Úsnapshot_namec              ‹   óè   K  — | j         r=| j                             t          j        ||¬¦  «        | j        ¬¦  «        ƒ d {V —† dS | j        j                             |||¬¦  «        ƒ d {V —†j	        S )N)rç   rê  r  T)rç   rê  r‹  )
rb   rÝ   ré  r   ÚDeleteSnapshotRequestr‰   r‹   rã  Údelete_snapshotr  )r˜   rç   rê  r‹  r;   s        rK   rí  z!AsyncQdrantRemote.delete_snapshot2	  sÈ   è è € ð Ôð 	ØÔ%×,Ò,ÝÔ*Ø$3À=ðñ ô ð œð	 -ñ ô ð ð ð ð ð ð ð ð �4àÔ%Ô3×CÒCØ /¸}ÐSWð Dñ ô ð ð ð ð ð ð ô ð		rM   c              ‹   ó  K  — | j         rI| j                             t          j        ¦   «         | j        ¬¦  «        ƒ d {V —†j        }d„ |D ¦   «         S | j        j         	                    ¦   «         ƒ d {V —†j
        }|€
J d¦   «         ‚|S )Nr  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   rÛ  rÝ  s     rK   rX   z9AsyncQdrantRemote.list_full_snapshots.<locals>.<listcomp>J	  rß  rM   z,List full snapshots API returned None result)rb   rÝ   ÚListFullr   ÚListFullSnapshotsRequestr‰   râ  r‹   rã  Úlist_full_snapshotsr  )r˜   r;   rå  s      rK   rò  z%AsyncQdrantRemote.list_full_snapshotsC	  sÄ   è è € ØÔð 	aàÔ)×2Ò2ÝÔ1Ñ3Ô3¸T¼]ð 3ñ ô ð ð ð ð ð ð ô $ð	 ð
 aÐ`ÐV_Ð`Ñ`Ô`Ð`ØÔ.Ô<×PÒPÑRÔRÐRÐRÐRÐRÐRÐRÔZˆ	ØÐ$Ð$Ð&TÑ$Ô$Ð$ØÐrM   c              ‹   ó  K  — | j         rQ| j                             t          j        ¦   «         | j        ¬¦  «        ƒ d {V —†j        }t          j        |¦  «        S | j	        j
                             |¬¦  «        ƒ d {V —†j        S )Nr  )r‹  )rb   rÝ   Ú
CreateFullr   ÚCreateFullSnapshotRequestr‰   rè  r   rÜ  r‹   rã  Úcreate_full_snapshotr  )r˜   r‹  r;   rè  s       rK   rö  z&AsyncQdrantRemote.create_full_snapshotO	  s®   è è € ð Ôð 	QàÔ)×4Ò4ÝÔ2Ñ4Ô4¸d¼mð 5ñ ô ð ð ð ð ð ð ô #ð	 !õ
 Ô:Ð;OÑPÔPÐPØÔ)Ô7×LÒLÐRVÐLÑWÔWÐWÐWÐWÐWÐWÐWÔ_Ð_rM   c              ‹   óä   K  — | j         r<| j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —† dS | j        j                             ||¬¦  «        ƒ d {V —†j	        S )N)rê  r  T)rê  r‹  )
rb   rÝ   Ú
DeleteFullr   ÚDeleteFullSnapshotRequestr‰   r‹   rã  Údelete_full_snapshotr  )r˜   rê  r‹  r;   s       rK   rú  z&AsyncQdrantRemote.delete_full_snapshot[	  s»   è è € ð Ôð 	ØÔ%×0Ò0ÝÔ.¸]ÐKÑKÔKÐUYÔUbð 1ñ ô ð ð ð ð ð ð ð ð �4àÔ%Ô3×HÒHØ+°$ð Iñ ô ð ð ð ð ð ð ô ð		rM   ÚlocationÚchecksumÚpriorityc           
   ‹   óŒ   K  — | j         j                             ||t          j        ||||¬¦  «        ¬¦  «        ƒ d {V —†j        S )N©rû  rý  rü  r2   )rç   r‹  Úsnapshot_recover)r‹   rã  Úrecover_from_snapshotr!   ÚSnapshotRecoverr  )r˜   rç   rû  r2   rü  rý  r‹  r;   s           rK   Úrecover_snapshotz"AsyncQdrantRemote.recover_snapshoti	  st   è è € ð Ô%Ô3×IÒIØ /ØÝ!'Ô!7Ø%°À8ÐU\ð"ñ "ô "ð Jñ ô ð ð ð ð ð ð ô ð	rM   Úshard_idc              ‹   óz   K  — | j         j                             ||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)rç   r  rà  )r‹   rã  Úlist_shard_snapshotsr  )r˜   rç   r  r;   rå  s        rK   r  z&AsyncQdrantRemote.list_shard_snapshots}	  sq   è è € ð Ô%Ô3×HÒHØ /¸(ð Iñ ô ð ð ð ð ð ð ô ð	 	ð
 Ð$Ð$Ð&OÑ$Ô$Ð$ØÐrM   c              ‹   ó`   K  — | j         j                             |||¬¦  «        ƒ d {V —†j        S )N)rç   r  r‹  )r‹   rã  Úcreate_shard_snapshotr  )r˜   rç   r  r‹  r;   s        rK   r  z'AsyncQdrantRemote.create_shard_snapshotˆ	  sV   è è € ð Ô%Ô3×IÒIØ /¸(Èð Jñ ô ð ð ð ð ð ð ô ð		rM   c              ‹   ób   K  — | j         j                             ||||¬¦  «        ƒ d {V —†j        S )N)rç   r  rê  r‹  )r‹   rã  Údelete_shard_snapshotr  )r˜   rç   r  rê  r‹  r;   s         rK   r
  z'AsyncQdrantRemote.delete_shard_snapshot‘	  s[   è è € ð Ô%Ô3×IÒIØ /Ø!Ø+Øð	 Jñ ô ð ð ð ð ð ð ô ð	rM   c              ‹   óŽ   K  — | j         j                             |||t          j        ||||¬¦  «        ¬¦  «        ƒ d {V —†j        S )Nrÿ  )rç   r  r‹  Úshard_snapshot_recover)r‹   rã  Úrecover_shard_from_snapshotr!   ÚShardSnapshotRecoverr  )	r˜   rç   r  rû  r2   rü  rý  r‹  r;   s	            rK   Úrecover_shard_snapshotz(AsyncQdrantRemote.recover_shard_snapshot¢	  sw   è è € ð Ô%Ô3×OÒOØ /Ø!ØÝ'-Ô'BØ%°À8ÐU\ð(ñ (ô (ð	 Pñ ô ð ð ð ð ð ð ô ð		rM   r
  Úshards_numberÚ	placementÚinitial_statec              ‹   óF  K  — | j         rÇt          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }| j	         
                    t          j        ||t          j
        ||||pg |¬¦  «        ¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†j        S | j        j                             ||t          j        |||||¬¦  «        ¬¦  «        ƒ d {V —†j        }	|	€
J d¦   «         ‚|	S )N)r
  r  rb  r  r  ©rç   r4   rµ  r  )rç   r4   Úcreate_sharding_keyzCreate shard key returned None)rb   r‚   r   r!   ÚShardKeyr   Úconvert_shard_keyÚReplicaStateÚconvert_replica_staterÙ   ÚCreateShardKeyr   ÚCreateShardKeyRequestr‰   r  r‹   Údistributed_apiÚcreate_shard_keyÚCreateShardingKey)
r˜   rç   r
  r  rb  r  r  r4   r;   r  s
             rK   r  z"AsyncQdrantRemote.create_shard_key¸	  sŒ  è è € ð Ôð $	Ý˜)Õ%8½¼Ñ%IÔ%IÑJÔJð DÝ&Ô8¸ÑCÔC�	Ý˜-­Ô)<Ñ=Ô=ð PÝ *Ô @ÀÑ OÔ O�àÔ+×:Ò:ÝÔ.Ø(7Ø 'Ý $Ô 3Ø&/Ø*7Ø/AØ&/ o°2Ø*7ð!ñ !ô !ð
ñ 
ô 
ð (/Ð':˜G˜GÀÄð ;ñ ô ð ð ð ð ð ð ô ðð$ Ô)Ô9×JÒJØ$3Ø#Ý(.Ô(@Ø"+Ø&3Ø+=Ø"+Ø&3ð)ñ )ô )ð Kñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ô ð ð Ð%Ð%Ð'GÑ%Ô%Ð%ØˆMrM   c           	   ‹   óÖ  K  — | j         r“t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t          j
        ||t          j        |¬¦  «        ¬¦  «        |�|n| j        ¬¦  «        ƒ d {V —†j        S | j        j                             ||t          j        |¬¦  «        ¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)r
  r  r  )rç   r4   Údrop_sharding_keyzDelete shard key returned None)rb   r‚   r   r!   r  r   r  rÙ   ÚDeleteShardKeyr   ÚDeleteShardKeyRequestr‰   r  r‹   r  Údelete_shard_keyÚDropShardingKey)r˜   rç   r
  r4   r;   r  s         rK   r#  z"AsyncQdrantRemote.delete_shard_keyé	  s<  è è € ð Ôð 	Ý˜)Õ%8½¼Ñ%IÔ%IÑJÔJð DÝ&Ô8¸ÑCÔC�	àÔ+×:Ò:ÝÔ.Ø(7Ø 'Ý $Ô 3¸iÐ HÑ HÔ Hðñ ô ð
 (/Ð':˜G˜GÀÄð ;ñ ô ð ð ð ð ð ð ô ð	ð Ô)Ô9×JÒJØ$3Ø#Ý&,Ô&<ÀyÐ&QÑ&QÔ&Qð Kñ ô ð ð ð ð ð ð ô
 ð ð Ð%Ð%Ð'GÑ%Ô%Ð%ØˆMrM   c              ƒ   ó  K  — | j         rL| j                             t          j        ¦   «         | j        ¬¦  «        ƒ d {V —†}t          j        |¦  «        S | j        j	         
                    ¦   «         ƒ d {V —†}|€
J d¦   «         ‚|S )Nr  zHealthcheck returned None)rb   rß   ÚHealthCheckr   ÚHealthCheckRequestr‰   r   Úconvert_health_check_replyrã   Úservice_apiÚroot)r˜   Úversion_infos     rK   ÚinfozAsyncQdrantRemote.info
  s²   è è € ØÔð 	GØ!%¤×!;Ò!;ÝÔ'Ñ)Ô)°4´=ð "<ñ "ô "ð ð ð ð ð ð ˆLõ Ô8¸ÑFÔFÐFØ!œYÔ2×7Ò7Ñ9Ô9Ð9Ð9Ð9Ð9Ð9Ð9ˆØÐ'Ð'Ð)DÑ'Ô'Ð'ØÐrM   Úcluster_operationc              ‹   ó`  K  — | j         �rjt          j        |¦  «        }i }t          |t          j        ¦  «        r||d<   nòt          |t          j        ¦  «        r||d<   nÒt          |t          j        ¦  «        r||d<   n²t          |t          j        ¦  «        r||d<   n’t          |t          j	        ¦  «        r||d<   nrt          |t          j
        ¦  «        r||d<   nRt          |t          j        ¦  «        r||d<   n2t          |t          j        ¦  «        r||d<   nt          d	|› �¦  «        ‚| j                             t	          j        d||d
œ|¤Ž|�|n| j        ¬¦  «        ƒ d {V —†j        S | j        j                             |||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )NÚ
move_shardÚreplicate_shardÚabort_transferÚdrop_replicar  r#  Úrestart_transferÚreplicate_pointszUnknown cluster operation: r^  r  )rç   Úcluster_operationsr4   z'Cluster collection update returned NonerG   )rb   r   Úconvert_cluster_operationsr‚   r   Ú	MoveShardÚReplicateShardÚAbortShardTransferÚReplicar  r!  ÚRestartTransferÚReplicatePointsrƒ   rÙ   ÚUpdateCollectionClusterSetupÚ#UpdateCollectionClusterSetupRequestr‰   r  rã   r  Úupdate_collection_cluster)r˜   rç   r-  r4   r;   Úgrpc_operationÚupdate_results          rK   Úcluster_collection_updatez+AsyncQdrantRemote.cluster_collection_update
  sO  è è € ð Ôñ 	Ý *Ô EÐFWÑ XÔ XÐØˆNÝÐ+­T¬^Ñ<Ô<ð SØ/@�˜|Ñ,Ð,ÝÐ-­tÔ/BÑCÔCð SØ4E�Ð0Ñ1Ð1ÝÐ-­tÔ/FÑGÔGð SØ3D�Ð/Ñ0Ð0ÝÐ-­t¬|Ñ<Ô<ð SØ1B�˜~Ñ.Ð.ÝÐ-­tÔ/BÑCÔCð 	SØ5F�Ð1Ñ2Ð2ÝÐ-­tÔ/BÑCÔCð SØ5F�Ð1Ñ2Ð2ÝÐ-­tÔ/CÑDÔDð SØ5F�Ð1Ñ2Ð2ÝÐ-­tÔ/CÑDÔDð SØ5F�Ð1Ñ2Ð2åÐ QÐ>OÐ QÐ QÑRÔRÐRàÔ+×HÒHÝÔ<ð Ø(7Àðð ØLZðð ð (/Ð':˜G˜GÀÄð	 Iñ ô ð ð ð ð ð ð ô ðð ”)Ô+×EÒEØ /Ø#4Øð Fñ ô ð ð ð ð ð ð ô
 ð 	ð Ð(Ð(Ð*SÑ(Ô(Ð(ØÐrM   c              ƒ   ót   K  — | j         j                             ¦   «         ƒ d {V —†j        }|€
J d¦   «         ‚|S )NzCluster status returned None)rã   r  Úcluster_statusr  )r˜   Ústatus_results     rK   rD  z AsyncQdrantRemote.cluster_status@
  sL   è è € Ø#œyÔ8×GÒGÑIÔIÐIÐIÐIÐIÐIÐIÔQˆØÐ(Ð(Ð*HÑ(Ô(Ð(ØÐrM   c              ƒ   ót   K  — | j         j                             ¦   «         ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nz"Recover current peer returned None)rã   r  Úrecover_current_peerr  )r˜   Úrecover_results     rK   rG  z&AsyncQdrantRemote.recover_current_peerE
  sL   è è € Ø $¤	Ô 9× NÒ NÑ PÔ PÐPÐPÐPÐPÐPÐPÔXˆØÐ)Ð)Ð+OÑ)Ô)Ð)ØÐrM   Úpeer_idÚforcec              ‹   ó|   K  — | j         j                             |||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)rI  rJ  r4   zRemove peer returned None)rã   r  Úremove_peerr  )r˜   rI  rJ  r4   r;   rA  s         rK   rL  zAsyncQdrantRemote.remove_peerJ
  sq   è è € ð ”)Ô+×7Ò7Ø u°gð 8ñ ô ð ð ð ð ð ð ô ð	 	ð
 Ð(Ð(Ð*EÑ(Ô(Ð(ØÐrM   c              ƒ   ó"  K  — | j         rN| j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —†}t          j        |¦  «        S | j        j	         
                    |¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nr  r  z%Collection cluster info returned None)rb   rÙ   ÚCollectionClusterInfor   ÚCollectionClusterInfoRequestr‰   r   Úconvert_collection_cluster_inforã   r  Úcollection_cluster_infor  )r˜   rç   Úcollection_infos      rK   rQ  z)AsyncQdrantRemote.collection_cluster_infoU
  sÝ   è è € ØÔð 	OØ$(Ô$9×$OÒ$OÝÔ1À/ÐRÑRÔRØœð %Pñ %ô %ð ð ð ð ð ð ˆOõ Ô=¸oÑNÔNÐNà”)Ô+×CÒCØ /ð Dñ ô ð ð ð ð ð ð ô ð	 	ð
 Ð*Ð*Ð,SÑ*Ô*Ð*ØÐrM   Úcompleted_limitc              ‹   óz   K  — | j         j                             ||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)rç   rS  zGet optimizations returned None)r=   r7  Úget_optimizationsr  )r˜   rç   rS  r;   r  s        rK   rU  z#AsyncQdrantRemote.get_optimizationsd
  sn   è è € ð ”)Ô+×=Ò=Ø /Àð >ñ ô ð ð ð ð ð ð ô ð	 	ð
 Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   c              ‹   óB  K  — | j         r^| j                             t          j        |¬¦  «        | j        ¬¦  «        ƒ d {V —†}t          j        d„ |j        D ¦   «         ¬¦  «        S | j	        j
                             |¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )Nr  r  c                 óf   — g | ].}t          j        t          j        |j        ¦  «        ¬ ¦  «        ‘Œ/S ))rš   )r!   ÚShardKeyDescriptionr   r  rš   )rH   Úsks     rK   rX   z5AsyncQdrantRemote.list_shard_keys.<locals>.<listcomp>w
  sE   € ð ð ð àõ Ô.µ:Ô3OÐPRÔPVÑ3WÔ3WÐXÑXÔXðð ð rM   )Ú
shard_keyszList shard keys returned None)rb   rÙ   ÚListShardKeysr   ÚListShardKeysRequestr‰   r!   ÚShardKeysResponserZ  rã   r  Úlist_shard_keysr  r(  s        rK   r^  z!AsyncQdrantRemote.list_shard_keyso
  sò   è è € ð Ôð 		Ø!Ô2×@Ò@ÝÔ)¸/ÐJÑJÔJÐTXÔTað Añ ô ð ð ð ð ð ð ˆHõ Ô+ðð à&Ô1ðñ ô ðñ ô ð ð ”)Ô+×;Ò;ÈOÐ;Ñ\Ô\Ð\Ð\Ð\Ð\Ð\Ð\Ü
ð 	ð Ð!Ð!Ð#BÑ!Ô!Ð!ØˆrM   Údetails_levelc              ‹   óz   K  — | j         j                             ||¬¦  «        ƒ d {V —†j        }|€
J d¦   «         ‚|S )N)r_  r4   zCluster telemetry returned None)rã   r  Úcluster_telemetryr  )r˜   r_  r4   r;   r  s        rK   ra  z#AsyncQdrantRemote.cluster_telemetry‚
  sn   è è € ð ”)Ô+×=Ò=Ø+°Wð >ñ ô ð ð ð ð ð ð ô ð	 	ð
 Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   )Nr+   r,   FNNNNNNNTNNr©   )r£   N)NNNNNræ   NTFNNNNN)NN)NNNNNræ   r*   TFNNNNNN)Nr*   ræ   NNNN)	Nræ   NNTFNNN)NTNNN)Nræ   FNNN)TNNNNN)TNNNN)TNNN)TFNNN)TNN)	NNNNNNNNN)NNNNNNNNNNNNNNN)r>   NFNNN)r‰  r>   Nr*   FNNN)
NNr‰  r>   Nr*   FNNN)NNTNN)T)NNNT)NNNNN)±Ú__name__Ú
__module__Ú__qualname__rŠ   r¹   rA  r�  ÚboolrQ  r   r   r   ra   Ústaticmethodr•   Úpropertyr«   Úfloatr°   Útupler·   rº   rÃ   rÈ   rÌ   rÐ   rÔ   r×   r   rË   rÙ   rÆ   rÛ   rÏ   rÝ   rÓ   rß   r    r   rã   r=   r†  rk  r  ÚSparseVectorr  Ú
NumpyArrayÚDocumentÚImageÚInferenceObjectrø   r  r  r
   ÚPayloadSelectorr  r  r  r   r%  r#  r4  ÚWithLookupInterfaceÚGroupsResultrF  ÚSearchMatrixPairsResponserP  ÚSearchMatrixOffsetsResponserX  rl  ÚRecordrr  ÚCountResultr}  r‡  rˆ  ÚPointsr¢  r¤  ÚUpdateResultr®  ÚPointVectorsr²  rÓ  r¹  rÏ  Úclassmethodrº  r!   rÜ  rã  rc  r¾  rí  ÚPayloadrð  rõ  rø  rþ  ÚUpdateOperationr  r  r  r&  r'  r/  r6  r8  ÚCollectionInfor<  rB  rM  rO  r\  rS  rU  r	   ÚSparseVectorParamsrX  rL  r`  ri  rk  rm  ro  rq  rh  rw  r   r&   ry  r   rˆ  r”  r�  ÚVectorStructr’  r›  r¶  r»  ÚVectorNameConfigrÒ  rØ  ÚSnapshotDescriptionrä  ré  rí  rò  rö  rú  ÚSnapshotPriorityr  r  r  r
  r  r  r  r  r#  ÚVersionInfor,  ÚClusterOperationsrB  ÚClusterStatusrD  rG  rL  rN  rQ  ÚOptimizationsResponserU  r]  r^  ÚDistributedTelemetryDatara  Ú__classcell__)r¡   s   @rK   r(   r(   ,   sˆ$  ø€ € € € € ØÐØÐð ØØØ!Ø!Ø"Ø!Ø"ØØ.2ØW[Ø$(Ø $Ø)-ðað aà�4‰Zðað �D‰jðað ð	að
 ðað �d‰{ðað �t‘ðað �d‘
ðað �t‘ðað �D‰jðað ˜3 ˜8”n tÑ+ðað & b¨# gÔ.°¸"¸iÈ¼nÐ:LÔ1MÑMÐPTÑTðað "ðað ˜‘:ðað �c˜3�h” $Ñ&ðað  ð!að að að að að aðF ðØðØ%)¨#¨s¨(¤^ðØ;>ðØILðà	ðð ð ñ „\ðð2 ð˜ð ð ð ñ „Xððð  e¨d¡lð ÀSð ÈTð ð ð ð ð. ð,˜ð ,  c¨D¡j°#°s¸T±zÀ3ÈÁ:Ð&MÔ Nð ,ð ,ð ,ñ „\ð,ð	/ Sð 	/ð 	/ð 	/ð 	/ðRð Rð Rð Rð*
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð 3ð ð ð ð ð ð	L $Ô"6ð 	Lð 	Lð 	Lñ „Xð	Lð ð	G˜Tœ_ð 	Gð 	Gð 	Gñ „Xð	Gð ð	J Ô 2ð 	Jð 	Jð 	Jñ „Xð	Jð ð	E˜4œ?ð 	Eð 	Eð 	Eñ „Xð	Eð ð#�i Ô/ð #ð #ð #ñ „Xð#ð ð#�i Ô/ð #ð #ð #ñ „Xð#ð( Ø ØAEØ,0Ø37ØØ!ØEIØ-2Ø(,Ø37Ø48Ø<@Ø"ð3ið iàðið Œ}Ø
ˆuŒ+ñà
ˆt�EŒ{Ô
ñð Ô
ñð Œ+ñ	ð
 Ô
ñð Œ.ñð Œ+ñð Ô
ñ ð ñ	ðið �T‰zðið ”. 4¨¬Ô#7Ñ7¸$Ñ>ðið ”l TÑ)ðið  Ô)¨DÑ0ð!ið" ð#ið$ �d‘
ð%ið& ˜X cœ]Ñ*¨UÔ-BÑBð'ið( ˜X cœ]Ñ*ð)ið*  ™ð+ið, Ô)¨DÑ0ð-ið. Ô*¨TÑ1ð/ið0 "Ô2°TÑ9ð1ið2 �t‘ð3ið4 ð5ið6 
Ô	ð7ið ið ið ið^ 59Ø"ð*ð *àð*ð ˜5Ô-Ô.ð*ð Ô*¨TÑ1ð	*ð
 �t‘ð*ð ð*ð 
ˆeÔ!Ô	"ð*ð *ð *ð *ðr Ø ØAEØ,0Ø37ØØØEIØ-2Ø(,Ø8<Ø37Ø48Ø<@Ø"ð7s'ð s'àðs'ð ðs'ð Œ}Ø
ˆuŒ+ñà
ˆt�EŒ{Ô
ñð Ô
ñð Œ+ñ	ð
 Ô
ñð Œ.ñð Œ+ñð Ô
ñ ð ñ	ð	s'ð �T‰zðs'ð ”. 4¨¬Ô#7Ñ7¸$Ñ>ðs'ð  ”l TÑ)ð!s'ð" Ô)¨DÑ0ð#s'ð$ ð%s'ð& ð's'ð( ˜X cœ]Ñ*¨UÔ-BÑBð)s'ð* ˜X cœ]Ñ*ð+s'ð,  ™ð-s'ð. Ô.°Ñ5ð/s'ð0 Ô)¨DÑ0ð1s'ð2 Ô*¨TÑ1ð3s'ð4 "Ô2°TÑ9ð5s'ð6 �t‘ð7s'ð8 ð9s'ð: 
Ô	ð;s'ð s'ð s'ð s'ðp -1ØØØ Ø48Ø<@Ø"ð2$ð 2$àð2$ð ”l TÑ)ð2$ð ð	2$ð
 ð2$ð �T‰zð2$ð Ô*¨TÑ1ð2$ð "Ô2°TÑ9ð2$ð �t‘ð2$ð ð2$ð 
Ô	(ð2$ð 2$ð 2$ð 2$ðn -1ØØØ Ø48Ø<@Ø"ð2$ð 2$àð2$ð ”l TÑ)ð2$ð ð	2$ð
 ð2$ð �T‰zð2$ð Ô*¨TÑ1ð2$ð "Ô2°TÑ9ð2$ð �t‘ð2$ð ð2$ð 
Ô	*ð2$ð 2$ð 2$ð 2$ðn .2ØØ)-Ø'+ØEIØ-2Ø48Ø<@Ø"ðLJð LJàðLJð ”| dÑ*ðLJð ð	LJð
 ”- $Ñ&ðLJð ” Ñ$ðLJð ˜X cœ]Ñ*¨UÔ-BÑBðLJð ˜X cœ]Ñ*ðLJð Ô*¨TÑ1ðLJð "Ô2°TÑ9ðLJð �t‘ðLJð ðLJð 
ˆt�E”LÔ! 5¤=°4Ñ#7Ð7Ô	8ðLJð LJð LJð LJðb -1ØØ<@Ø"Ø48ð,ð ,àð,ð ”l TÑ)ð,ð ð	,ð
 "Ô2°TÑ9ð,ð �t‘ð,ð Ô*¨TÑ1ð,ð ð,ð 
Ô	ð,ð ,ð ,ð ,ðd -1ØØØ"Ø48Ø<@ð4ð 4àð4ð ð4ð ”l TÑ)ð	4ð
 ð4ð ð4ð �t‘ð4ð Ô*¨TÑ1ð4ð "Ô2°TÑ9ð4ð ð4ð 
Ô	ð4ð 4ð 4ð 4ðt Ø/3Ø<@Ø-1Ø/3Ø"ð\ð \àð\ð ”ð\ð ð	\ð
 Ô%¨Ñ,ð\ð "Ô2°TÑ9ð\ð ”| dÑ*ð\ð Ô%¨Ñ,ð\ð �t‘ð\ð ð\ð 
Ô	ð\ð \ð \ð \ðD Ø/3Ø<@Ø-1Ø"ð0ð 0àð0ð ˜Ô+Ô,ð0ð ð	0ð
 Ô%¨Ñ,ð0ð "Ô2°TÑ9ð0ð ”| dÑ*ð0ð �t‘ð0ð ð0ð 
Ô	ð0ð 0ð 0ð 0ðn Ø/3Ø<@Ø"ð2ð 2àð2ð ˜#”ð2ð Ô$ð	2ð
 ð2ð Ô%¨Ñ,ð2ð "Ô2°TÑ9ð2ð �t‘ð2ð ð2ð 
Ô	ð2ð 2ð 2ð 2ðp FJØ-2Ø48Ø<@Ø"ð>ð >àð>ð �e”mÔ$ð>ð ˜X cœ]Ñ*¨UÔ-BÑBð	>ð
 ˜X cœ]Ñ*ð>ð Ô*¨TÑ1ð>ð "Ô2°TÑ9ð>ð �t‘ð>ð ð>ð 
ˆeŒlÔ	ð>ð >ð >ð >ð@ ð5ØÔ)ð5à	ˆtÔ" DÔ$9¸DÑ$@Ð@Ô	Að5ð 5ð 5ñ „[ð5ð> ðØÔ)ðØ?DÔ?UÐX\Ñ?\ðà	Ô	ðð ð ñ „[ðð> ð	Ø"Ô1ð	à	ˆdŒlÔ	ð	ð 	ð 	ñ „[ð	ð ð"ØÔ)ð"à	ˆt�FÔ*Ô+¨dÑ2°F´MÀDÑ4HÐHÔ	Ið"ð "ð "ñ „[ð"ð@ Ø/3Ø<@Ø"ð0ð 0àð0ð Ô-ð0ð ð	0ð
 Ô%¨Ñ,ð0ð "Ô2°TÑ9ð0ð �t‘ð0ð ð0ð 
Ô	ð0ð 0ð 0ð 0ðn ØØ/3Ø<@Ø"ð6ð 6àð6ð ”ð6ð Ô$ð	6ð
 �4‰Zð6ð ð6ð Ô%¨Ñ,ð6ð "Ô2°TÑ9ð6ð �t‘ð6ð ð6ð 
Ô	ð6ð 6ð 6ð 6ðz Ø/3Ø<@Ø"ð3ð 3àð3ð ”ð3ð Ô$ð	3ð
 ð3ð Ô%¨Ñ,ð3ð "Ô2°TÑ9ð3ð �t‘ð3ð ð3ð 
Ô	ð3ð 3ð 3ð 3ðt Ø/3Ø<@Ø"ð0ð 0àð0ð �sŒmð0ð Ô$ð	0ð
 ð0ð Ô%¨Ñ,ð0ð "Ô2°TÑ9ð0ð �t‘ð0ð ð0ð 
Ô	ð0ð 0ð 0ð 0ðl Ø/3Ø<@Ø"ð0ð 0àð0ð Ô-ð0ð ð	0ð
 Ô%¨Ñ,ð0ð "Ô2°TÑ9ð0ð �t‘ð0ð ð0ð 
Ô	ð0ð 0ð 0ð 0ðl Ø/3Ø"ð)ð )àð)ð $ EÔ$9Ô:ð)ð ð	)ð
 Ô%¨Ñ,ð)ð �t‘ð)ð ð)ð 
ˆeÔ Ô	!ð)ð )ð )ð )ð\ #ð"ð "à#+¨EÔ,AÔ#Bð"ð �t‘ð"ð ð	"ð
 
ð"ð "ð "ð "ðHØ"ðØ.1ðà	Ô	)ðð ð ð ð*¨#ð °%Ô2Rð ð ð ð ð$¨cð °eÔ6Oð ð ð ð ð&°Cð À3ð È5ÔK_ð ð ð ð ð °sð Àcð Èdð ð ð ð ð" @DØ?CØ9=Ø37ØCGØ"ØOSØ<@Ø)-ðOð OàðOð !Ô5¸Ñ<ðOð !Ô5¸Ñ<ð	Oð
 Ô/°$Ñ6ðOð Ô)¨DÑ0ðOð #Ô9¸DÑ@ðOð �t‘ðOð  ' s¨EÔ,DÐ'DÔEÈÑLðOð "Ô2°TÑ9ðOð ”- $Ñ&ðOð ðOð 
ðOð Oð Oð Oðd ;?ðð Ø"ðØ-0°4©ZðØJMðà	ðð ð ð ð& X\Ø#'Ø)-Ø/3Ø'+Ø37Ø?CØ15Ø?CØ"ØOSØ7;Ø<@Ø)-Ø59ð#`ð `àð`ð Ô*¨W°S¸%Ô:LÐ5LÔ-MÑMÐPTÑTð`ð ˜D‘jð	`ð
   $™Jð`ð #&¨¡*ð`ð  ™ð`ð Ô)¨DÑ0ð`ð !Ô5¸Ñ<ð`ð Ô'¨$Ñ.ð`ð #Ô5¸Ñ<ð`ð �t‘ð`ð  ' s¨EÔ,DÐ'DÔEÈÑLð`ð Ô-°Ñ4ð`ð "Ô2°TÑ9ð`ð  ”- $Ñ&ð!`ð" Ô+¨dÑ2ð#`ð$ ð%`ð& 
ð'`ð `ð `ð `ðJ X\Ø#'Ø)-Ø/3Ø'+Ø37Ø?CØ15Ø?CØ"ØOSØ7;Ø<@Ø)-Ø59ð#&
ð &
àð&
ð Ô*¨W°S¸%Ô:LÐ5LÔ-MÑMÐPTÑTð&
ð ˜D‘jð	&
ð
   $™Jð&
ð #&¨¡*ð&
ð  ™ð&
ð Ô)¨DÑ0ð&
ð !Ô5¸Ñ<ð&
ð Ô'¨$Ñ.ð&
ð #Ô5¸Ñ<ð&
ð �t‘ð&
ð  ' s¨EÔ,DÐ'DÔEÈÑLð&
ð Ô-°Ñ4ð&
ð "Ô2°TÑ9ð&
ð  ”- $Ñ&ð!&
ð" Ô+¨dÑ2ð#&
ð$ ð%&
ð& 
ð'&
ð &
ð &
ð &
ðP ð%  \Ô 2ð %ð %ð %ñ „Xð%ð Ø!ØØ<@Ø-1Ø/3ð6ð 6à"ð6ð ð6ð ð	6ð
 ð6ð �d‘
ð6ð ð6ð "Ô2°TÑ9ð6ð ”| dÑ*ð6ð Ô%¨Ñ,ð6ð 
ð6ð 6ð 6ð 6ðx ØØ!ØØØ<@Ø-1Ø/3ð
ð 
àð
ð ˜Ô*Ô+ð
ð ð	
ð
 ð
ð �d‘
ð
ð ð
ð ð
ð "Ô2°TÑ9ð
ð ”| dÑ*ð
ð Ô%¨Ñ,ð
ð ð
ð 
ð
ð 
ð 
ð 
ðB 48Ø.2ØØØ!ØØØ<@Ø-1Ø/3ð
ð 
àð
ð �c˜5Ô+Ð+Ô,¨uÔ/?Ñ?À(È5ÔK]ÔB^Ñ^ð
ð ˜$˜s C˜xœ.Ô)¨DÑ0ð	
ð
 �e”mÔ$ tÑ+ð
ð ð
ð ð
ð �d‘
ð
ð ð
ð ð
ð "Ô2°TÑ9ð
ð ”| dÑ*ð
ð Ô%¨Ñ,ð
ð ð
ð 
ð
ð 
ð 
ð 
ðF 8<Ø59ØØ/3Ø"ðOð OàðOð ðOð Ô-°Ñ4ð	Oð
 Ô+¨dÑ2ðOð ðOð Ô%¨Ñ,ðOð �t‘ðOð ðOð 
Ô	ðOð Oð Oð Oðj Ø/3Ø"ðð àðð ðð ð	ð
 Ô%¨Ñ,ðð �t‘ðð ðð 
Ô	ðð ð ð ðJ Ø/3Ø"ðAð AàðAð ðAð "Ô2ð	Að
 ðAð Ô%¨Ñ,ðAð �t‘ðAð ðAð 
Ô	ðAð Að Að AðN Ø/3Ø"ð#ð #àð#ð ð#ð ð	#ð
 Ô%¨Ñ,ð#ð �t‘ð#ð ð#ð 
Ô	ð#ð #ð #ð #ðJØ"ðØ.1ðà	ˆeÔ'Ô	(ðð ð ð ð$ 26ðð Ø"ðØ*.ðØADðà	Ô	" TÑ	)ðð ð ð ð$ FJðð Ø"ðØ36ðØ>BðØUXðà	�‰ðð ð ð ð"
°#ð 
¸$¸uÔ?XÔ:Yð 
ð 
ð 
ð 
ð  ð
`ð 
`Øð
`Ø+.ð
`à	Ô	"ð
`ð 
`ð 
`ð 
`ð 04ðð Ø ðØ(,ðØ?Bðà	�‰ðð ð ð ð$ #Ø#Ø26Øðð àðð ðð �t‘ð	ð
 ˜‘*ðð Ô(¨4Ñ/ðð ðð ðð 
�‰ðð ð ð ð(	Ø"ð	Ø.1ð	Ø=@ð	à	ˆeÔ'Ô	(ð	ð 	ð 	ð 	ð AEðð Ø"ðØ.1ðØ9=ðØPSðà	Ô	" TÑ	)ðð ð ð ð ðð àðð ðð ð	ð
 ðð ðð 
�‰ðð ð ð ð, #Ø#Ø26Øðð àðð ðð ð	ð
 �t‘ðð ˜‘*ðð Ô(¨4Ñ/ðð ðð ðð 
�‰ðð ð ð ð4 %)Ø)-Ø&*Ø37Ø"ð/ð /àð/ð ”>ð/ð ˜T‘zð	/ð
   $™Jð/ð ˜”9˜tÑ#ð/ð Ô)¨DÑ0ð/ð �t‘ð/ð ð/ð 
ð/ð /ð /ð /ðj #ð	ð àðð ”>ðð �t‘ð	ð
 ðð 
ðð ð ð ð>˜EÔ-ð ð ð ð ð #ð	,ð ,àð,ð !Ô2ð,ð �t‘ð	,ð
 ð,ð 
ð,ð ,ð ,ð ,ð\ eÔ&9ð ð ð ð ð
¨Dð ð ð ð ð NRð	ð 	Øð	Ø#'¨$¡;ð	Ø@CÀdÁ
ð	Ø]`ð	à	ð	ð 	ð 	ð 	ð¸Sð ÀUÔE`ð ð ð ð ð  CGð	ð 	Ø"ð	Ø58¸4±Zð	ØRUð	à	Ô	$ð	ð 	ð 	ð 	ðØ"ðØ.1ðà	Ô	 ðð ð ð ð( GKð	ð 	Ø  4™Zð	Ø9<¸t¹ð	ØVYð	à	Ô	'ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	rM   r(   )AÚimportlib.metadatar~   rq   r€   Úmultiprocessingr   Ú	threadingr   Útypingr   r   r   r   r	   r
   r   r   rv   r   r   Úurllib3.utilr   r   Úurllib.parser   Ú$qdrant_client.common.client_warningsr   r   Úqdrant_clientÚqdrant_client._pydantic_compatr   Úqdrant_client.authr   Úqdrant_client.async_client_baser   Ú"qdrant_client.common.version_checkr   r   Úqdrant_client.connectionr   rÀ   Úqdrant_client.conversionsr   r†  Ú&qdrant_client.conversions.common_typesr   Ú$qdrant_client.conversions.conversionr   r   r   Úqdrant_client.httpr   r    r!   Úqdrant_client.context_headersr"   Ú qdrant_client.parallel_processorr#   Ú$qdrant_client.uploader.grpc_uploaderr$   Ú$qdrant_client.uploader.rest_uploaderr%   Úqdrant_client.uploader.uploaderr&   r(   rG   rM   rK   ú<module>rž     sc  ðð Ð Ð Ð Ø €€€Ø €€€Ø 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø Ð Ð Ð Ð Ð Ø XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XØ €€€Ø Ð Ð Ð Ð Ð Ø 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ø  Ð  Ð  Ð  Ð  Ð  Ø PÐ PÐ PÐ PÐ PÐ PÐ PÐ PØ &Ð &Ð &Ð &Ð &Ð &Ø 4Ð 4Ð 4Ð 4Ð 4Ð 4Ø )Ð )Ð )Ð )Ð )Ð )Ø ;Ð ;Ð ;Ð ;Ð ;Ð ;Ø PÐ PÐ PÐ PÐ PÐ PÐ PÐ PØ EÐ EÐ EÐ EÐ EÐ EØ ;Ð ;Ð ;Ð ;Ð ;Ð ;Ø FÐ FÐ FÐ FÐ FÐ Fðð ð ð ð ð ð ð ð ð ð
 AÐ @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ø GÐ GÐ GÐ GÐ GÐ GØ ?Ð ?Ð ?Ð ?Ð ?Ð ?Ø BÐ BÐ BÐ BÐ BÐ BØ BÐ BÐ BÐ BÐ BÐ BØ 8Ð 8Ð 8Ð 8Ð 8Ð 8ð_)ð _)ð _)ð _)ð _)˜ñ _)ô _)ð _)ð _)ð _)rM   