§
     �’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.m/Z/m0Z0 d dl1m2Z2m3Z3m4Z4 d dl5m6Z6 d dl7m8Z8 d dl9m: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)Ú
QdrantBase)Úis_compatibleÚget_server_version)Úget_channel)Úcommon_types)Úget_args_subscribed)Ú
GrpcToRestÚ
RestToGrpcÚ!grpc_payload_schema_to_field_type)Ú	ApiClientÚSyncApisÚmodels)Ú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 )ÒÚQdrantRemoteé   é   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                 ó¨  •—  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 | _?        d | _@        d | _A        d | _B        d| _C        |rVt‰          | jE        | j/        | j        | j0         F                    d2¦  «        | j1        fd4¬5¦  «         G                    ¦   «          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      úIC:\Projects\DSCons\.venv\Lib\site-packages\qdrant_client\qdrant_remote.pyú
<dictcomp>z)QdrantRemote.__init__.<locals>.<dictcomp>“   s   € ÐRÐRÐR¡t q¨!˜a ÐRÐRÐRó    Ú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)QdrantRemote.__init__.<locals>.<listcomp>¤   s!   € ÐWÐWÐW±.°+¸q�[ IÒ-ÐWÐWÐWrM   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   )HÚ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Ú_aio_grpc_points_clientÚ_aio_grpc_collections_clientÚ_aio_grpc_snapshots_clientÚ_aio_grpc_root_clientÚ_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QdrantRemote.__init__1   sº  ø€ ð$ 	�‰ŒÔÐ"Ð"˜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ÐÝð7ñô ð ð
 ð 	Ø�~Š~˜kÑ*Ô*ð !ð !˜3�j�j�å'¨™nœnˆJØ%/¤_°j´oÐ"ˆDŒJ˜œ
àÔ ð 1Ø(Ô/°7Ò:�”Ø)Ô0�”à'+¤zÐ;˜œ˜°tˆDŒJàŒ|ð / 
¤ð /Ý ðAØ!ðAð AØ/9¬ðAð Añô ð ð ”ð /Ø)œ�”àŒ|Ð#4Ð4Ð4Ý Ð!B°D´LÐ!BÐ!BÑCÔCÐCð 5ð Ð, ˆDŒJØˆDŒJð #*Ð"5�DŒI�gÑÔÐ¸4ð 	ð  ˆŒØ$7ˆÔ!à—’˜H dÑ+Ô+ˆØˆ>ØŒzÐ7Ð7Ð7õ œ°dÐVWÐXÑXÔX��Ø”Ð,åœ°d´oÐFÑFÔF�øØŒ_Ð(Ýð?Ø )ð?ð ?Ø6<ð?ð ?ñô ð ð
 —
’
˜7 EÑ*Ô*ˆØˆÔØRÐR¨v¯zªz¸*ÀbÑ/IÔ/I×/OÒ/OÑ/QÔ/QÐRÑRÔRˆÔàð 	8Ø%Ÿmšm™oœoð 8ð 8‘
��UØ*/�Ô" 3Ñ'ØÔ"×)Ò)¨3°¨,Ñ7Ô7Ð7Ð7àÐØŒ|˜vÒ%Ð%ÝØJÝ(Ø ðñ ô ð õ ÐWÐWÀDÔDVÐWÑWÔWÑXÔXð	à Ô 2Ð2Ð2å!ð&å(Ø ð	ñ ô ð ð -4ˆDÔ˜yÑ)ØÔ×%Ò% y°'Ð&:Ñ;Ô;Ð;å"Ô+×3Ò3°OÑDÔDˆÝ!Ô0Ñ2Ô2ˆØN nÐNÐN¸nÐNÐNˆ
Ø˜4Ô-Ð-Ð-ÝðQØBLðQð Qð Qñô ð ð
 Ð#Ð(AÀ\Ð(QÐ(QÝØmÐ_iÐmÐmÐmÝ$Øðñ ô ð ð
 ,6ˆÔ˜<Ñ(Ø8BˆÔÐ4Ñ5ð 06¯zªzÐ:LÈdÑ/SÔ/SÐØÐ'µ
Ð;KÍ[Ñ0YÔ0YÐ'ÝðNÝ59Ð:JÑ5KÔ5KðNð Nñô ð ð �{Ô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Ñ#å3;ð 4
ð 4
Ø”ð4
àŒoð4
ð 4
ˆÔð
 	ÔÔ"×1Ò1Õ2IÑJÔJÐJà68ˆÔØFJˆÔ%ØPTˆÔ*ØLPˆÔ(ØDHˆÔ#Ø,-ˆÔ$à?CˆÔ$ØIMˆÔ)ØEIˆÔ'Ø=AˆÔ"à"ˆŒàð 
	ÝØÔ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!QdrantRemote._check_compatibility
  s$  € ð	Ý&Ô/×7Ò7¸ÑHÔHˆNÝ/°¸,ÈÈgÑVÔVˆNà!ð ÝðLå(Ø ð	ñ ô ð ð ð õ # >°>ÑBÔBð Ýð^°^ð ^ð ^Ø-ð^ð ^ð ^õ )Ø ðñ ô ð ð ð ðð øõ ð 	ð 	ð 	ÝðHå$Øð	ñ ô ð ð ð ð ð	øøøs   ‚A
B  Á.B  Â !B%Â$B%c                 ó   — | j         S ©N)r˜   ©rœ   s    rK   ÚclosedzQdrantRemote.closed)  s
   € àŒ|ÐrM   Ú
grpc_gracec                 ót  — t          | d¦  «        r^t          | j        ¦  «        dk    rF| j        D ]>}	 |                     ¦   «          Œ# t          $ r t          dt          d¬¦  «         Y Œ;w xY w	 | j                             ¦   «          n'# t          $ r t          dt          d¬¦  «         Y nw xY wd| _	        d S )NrŽ   r   zKUnable 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   ÚRuntimeWarningr‹   rª   r˜   )rœ   r°   r;   Úchannels       rK   r³   zQdrantRemote.close-  s  € Ý�4Ð-Ñ.Ô.ð 		µ3°tÔ7NÑ3OÔ3OÐRSÒ3SÐ3SØÔ2ð ð �ðØ—M’M‘O”O�O�OøÝ%ð ð ð Ý Ø mÝ!/Ø#$ðñ ô ð ð ð ðøøøð	ØÔ×%Ò%Ñ'Ô'Ð'Ð'øÝð 	ð 	ð 	ÝØhÝ'Øðñ ô ð ð ð ð	øøøð ˆŒˆˆs#   ³AÁ!A,Á+A,Á0B
 Â
!B.Â-B.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QdrantRemote._parse_urlD  sF   € å% c™NœNˆàÔØÔØÔØÔð	&
Ñ"ˆ��d˜Fð �t˜T 6Ð)Ð)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 QdrantRemote._get_grpc_pool_sizeO  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˜   ÚRuntimeErrorrj   rŽ   Úranger¼   r   rm   rc   re   rx   rd   r†   rt   r{   rª   )rœ   Úchannel_poolrW   r¶   Úes        rK   Ú_init_grpc_channelzQdrantRemote._init_grpc_channel[  s
  € ØŒ<ð 	`ÝÐ^Ñ_Ô_Ð_ð	RØˆLå�4Ô*Ñ+Ô+¨qÒ0Ð0Ý˜t×7Ò7Ñ9Ô9Ñ:Ô:ð 1ð 1�AÝ)Ø!œZØ!œ_Ø œKØ!%Ô!3Ø $Ô 2Ø$(Ô$:ð -1Ô,Eð
ñ 
ô 
�Gð !×'Ò'¨Ñ0Ô0Ð0Ð0ð +7�Ô'Ð'Ð'ð! 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   z9QdrantRemote._init_grpc_points_client.<locals>.<listcomp>x  s/   € ð )
ð )
ð )
Ø)0�DŒO˜GÑ$Ô$ð)
ð )
ð )
rM   )rÅ   rŽ   r�   r®   s    rK   Ú_init_grpc_points_clientz%QdrantRemote._init_grpc_points_clientv  s>   € Ø×ÒÑ!Ô!Ð!ð)
ð )
Ø48Ô4Kð)
ñ )
ô )
ˆÔ%Ð%Ð%rM   c                 óZ   — |                       ¦   «          d„ | j        D ¦   «         | _        d S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   ÚCollectionsStubrÉ   s     rK   rX   z>QdrantRemote._init_grpc_collections_client.<locals>.<listcomp>~  s0   € ð .
ð .
ð .
Ø.5�DÔ  Ñ)Ô)ð.
ð .
ð .
rM   )rÅ   rŽ   r�   r®   s    rK   Ú_init_grpc_collections_clientz*QdrantRemote._init_grpc_collections_client|  s>   € Ø×ÒÑ!Ô!Ð!ð.
ð .
Ø9=Ô9Pð.
ñ .
ô .
ˆÔ*Ð*Ð*rM   c                 óZ   — |                       ¦   «          d„ | j        D ¦   «         | _        d S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   ÚSnapshotsStubrÉ   s     rK   rX   z<QdrantRemote._init_grpc_snapshots_client.<locals>.<listcomp>„  s0   € ð ,
ð ,
ð ,
Ø,3�DÔ˜wÑ'Ô'ð,
ð ,
ð ,
rM   )rÅ   rŽ   r‘   r®   s    rK   Ú_init_grpc_snapshots_clientz(QdrantRemote._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   z7QdrantRemote._init_grpc_root_client.<locals>.<listcomp>Š  s/   € ð '
ð '
ð '
Ø)0�DŒO˜GÑ$Ô$ð'
ð '
ð '
rM   )rÅ   rŽ   r’   r®   s    rK   Ú_init_grpc_root_clientz#QdrantRemote._init_grpc_root_clientˆ  s>   € Ø×ÒÑ!Ô!Ð!ð'
ð '
Ø48Ô4Kð'
ñ '
ô '
ˆÔ#Ð#Ð#rM   c                 ó\   — | j         }| j         dz   |                      ¦   «         z  | _         |S )Nr>   )r“   r¼   )rœ   Úcurrent_indexs     rK   Ú_next_grpc_clientzQdrantRemote._next_grpc_clientŽ  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QdrantRemote.grpc_collections•  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QdrantRemote.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QdrantRemote.grpc_snapshots­  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QdrantRemote.grpc_root¹  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QdrantRemote.restÅ  ó   € ð Ô"Ð"rM   c                 ó   — | j         S rã   rä   r®   s    rK   r=   zQdrantRemote.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                 óÆ  — | j         �rI|�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„ |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#         $                    ||||¬¦  «        }|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   z-QdrantRemote.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   z-QdrantRemote.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QdrantRemote.query_points×  sv  € ð8 Ôñ _	ØÐ Ý"Ô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]Ñ%^Ô%^Ð"à&*Ô&6×&<Ò&<ÝÔ Ø$3ØØ%Ø'ØØ!Ø!-Ø!-Ø(Ø$3ØØ +Ø#Ø'9Ø%0ðñ ô ð" $+Ð#6˜˜¸D¼Mð% '=ñ 'ô 'ˆ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ð  œ9Ô/×<Ò<Ø /Ø'ØØ+ð	 =ñ ô ˆLð 3?Ô2EˆFØÐ%Ð%Ð'=Ñ%Ô%Ð%ØˆMrM   Úrequestsc                 óÎ  ‡— | j         r•ˆfd„|D ¦   «         }t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t          j
        ‰|||¬¦  «        |�|n| j        ¬¦  «        }d„ |j        D ¦   «         S | j        j                             ‰||t          j        |¬¦  «        ¬¦  «        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   z3QdrantRemote.query_batch_points.<locals>.<listcomp>]  sR   ø€ ð ð ð ð õ " !¥VÔ%8Ñ9Ô9ð•JÔ4°Q¸ÑHÔHÐHàð	ð ð 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   z>QdrantRemote.query_batch_points.<locals>.<listcomp>.<listcomp>u  s#   € ÐUÐUÐUÀS�JÔ;¸CÑ@Ô@ÐUÐUÐUrM   r
  )r!   r"  r!  )rH   r/  s     rK   rX   z3QdrantRemote.query_batch_points.<locals>.<listcomp>s  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   r6  zQdrantRemote.query_batch_pointsT  s?  ø€ ð Ôð %	ðð ð ð ð "ðñ ô ˆHõ ˜+Õ':½6Ô;QÑ'RÔ'RÑSÔSð OÝ(ÔAÀ+ÑNÔN�à04Ô0@×0KÒ0KÝÔ%Ø$3Ø!)Ø%0Ø#ð	ñ ô ð $+Ð#6˜˜¸D¼Mð 1Lñ 1ô 1ˆHðð ð "œð	ñ ô ð ð ;?¼)Ô:N×:aÒ:aØ /Ø'ØÝ$*Ô$<ÀhÐ$OÑ$OÔ$Oð	 ;bñ ;ô ;ô
 ð ð Ð'Ð'Ð)DÑ'Ô'Ð'ØˆOrM   Úgroup_byÚ
group_sizeÚwith_lookupc                 óš  — | 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        ¬¦  «        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&         '                    ||||¬¦  «        }|€
J d¦   «         ‚|j        S )Nc                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   rù   rü   s     rK   rX   z4QdrantRemote.query_points_groups.<locals>.<listcomp>©  rþ   rM   rÿ   )Ú
collectionré   rê   rì   r  rï   rò   rñ   r  ró   rë   r:  r;  r<  rô   r4   rö   r  r  )r  rì   rê   rë   r  r  ró   rï   r:  r;  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é   r:  rê   rë   rì   rí   rî   rï   r;  rñ   rò   ró   r<  rô   rõ   rö   r4   r;   r!  r  r*  s                         rK   rH  z QdrantRemote.query_points_groupsƒ  sN  € ð< Ôñ d	'ØÐ Ý"Ô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]Ñ%^Ô%^Ð"à/3Ô/?×/KÒ/KÝÔ%ð ð ð Ø$3 Oðà˜%ðð &˜Xðð (˜<ð	ð
  ˜%ðð ". ðð ". ðð )˜=ðð %4 Oðð  ˜%ðð &˜Xðð  *˜zðð !, ðð !, ðð $˜Gðð  (:Ð'9ð!ð" &1 [ð#ð& $+Ð#6˜˜¸D¼Mð) 0Lñ 0ô 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ð"  œ9Ô/×CÒCØ /Ø'ØØ%2ð	 Dñ ô ˆLð  Ð+Ð+Ð-TÑ+Ô+Ð+ØÔ&Ð&rM   Úsamplec	                 ó  — | 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        ¬¦  «        }
t!          j        |
j        ¦  «        S t          |t          j        ¦  «        rt!          j        |¬¦  «        }| j        j                             |||t          j        |||||¬¦  «        ¬¦  «        j        }|€
J d¦   «         ‚|S )Nrÿ   ©ré   r  rI  rï   rë   r4   r  rö   r  ©r  rï   rI  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ï   rI  rë   rõ   rö   r4   r;   ÚresponseÚsearch_matrix_results               rK   rR  z QdrantRemote.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�àÔ'×9Ò9ÝÔ'Ø$3Ø'Ø!ØØØ#Ø%0Ø'9ð	ñ 	ô 	ð $+Ð#6˜˜¸D¼Mð :ñ ô ˆHõ Ô9¸(¼/ÑJÔJÐJå�l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLà#Ô2Ô=×QÒQØ+Ø#ØÝ"(Ô"<Ø,ØØØØ#ð#ñ #ô #ð	  Rñ  
ô  
ô ð 	ð $Ð/Ð/Ð1[Ñ/Ô/Ð/à#Ð#rM   c	                 ó  — | 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        ¬¦  «        }
t!          j        |
j        ¦  «        S t          |t          j        ¦  «        rt!          j        |¬¦  «        }| j        j                             |||t          j        |||||¬¦  «        ¬¦  «        j        }|€
J d¦   «         ‚|S )Nrÿ   rK  r  rL  rM  z*Search matrix offsets returned None result)rb   r‚   r!   r  r   r  r   r  r  r  r  rÝ   ÚSearchMatrixOffsetsr   rP  r‰   r   Úconvert_search_matrix_offsetsr!  r‹   r&  Úsearch_matrix_offsetsrS  rT  s               rK   rZ  z"QdrantRemote.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�àÔ'×;Ò;ÝÔ'Ø$3Ø'Ø!ØØØ#Ø%0Ø'9ð	ñ 	ô 	ð $+Ð#6˜˜¸D¼Mð <ñ ô ˆHõ Ô;¸H¼OÑLÔLÐLå�l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLà#Ô2Ô=×SÒSØ+Ø#ØÝ"(Ô"<Ø,ØØØØ#ð#ñ #ô #ð	  Tñ  
ô  
ô ð 	ð $Ð/Ð/Ð1]Ñ/Ô/Ð/à#Ð#rM   Úscroll_filterÚorder_byc                 ó`  — | 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„ |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%        |||||||	¬¦  «        |
¬¦  «        j        }|€
J d¦   «         ‚|j&        |j        fS )	Nrÿ   )
ré   r  r\  rð   rò   rñ   rï   r  rö   r4   r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   ©r   Úconvert_retrieved_point©rH   Úpoints     rK   rX   z'QdrantRemote.scroll.<locals>.<listcomp>«  s#   € ÐVÐVÐVÀ%•JÔ6°uÑ=Ô=ÐVÐVÐVrM   Únext_page_offset)r  rï   r\  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_idrc  ÚPointIdÚOrderByÚconvert_order_byr#  r$  r‹   Ú
points_apiÚscroll_pointsÚScrollRequestr  )rœ   ré   r[  rï   r\  rð   rñ   rò   rõ   rö   r4   r;   r(  Úscroll_results                 rK   ÚscrollzQdrantRemote.scrollw  s!  € ð Ôñ J	HÝ˜&Õ"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�à'+Ô'7×'>Ò'>ÝÔ!Ø$3Ø(Ø%Ø!Ø!-Ø!-ØØ%0Ø'9Ø#ðñ ô ð $+Ð#6˜˜¸D¼Mð (?ñ (ô (ˆCð  WÐVÈ3Ì:ÐVÑVÔVà—<’<Ð 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�ð Ô#Ô.×<Ò<Ø$3Ø +Ý#)Ô#7Ø,Ø#Ø!)Ø%Ø%1Ø$0Ø"4ð$ñ $ô $ð $ð =ñ ô ô ð ð  !Ð,Ð,Ð.VÑ,Ô,Ð,à Ô'¨Ô)GÐGÐGrM   Úcount_filterÚexactc           
      óú  — | 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        ¬¦  «        j        }t#          j        |¦  «        S t          |t          j        ¦  «        rt#          j        |¬¦  «        }| j        j                             |t          j        |||¬¦  «        ||¬¦  «        j        }	|	€
J d¦   «         ‚|	S )Nrÿ   )ré   r  rv  rö   r4   r  r  )r  rv  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‹   rp  Úcount_pointsÚCountRequest)
rœ   ré   ru  rv  rö   r4   rõ   r;   rU  Úcount_results
             rK   ÚcountzQdrantRemote.countÑ  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Ø'ØØ'9Ø#Ø%0ðñ ô ð $+Ð#6˜˜¸D¼Mð .ñ 
ô 
ô ð õ Ô2°8Ñ<Ô<Ð<å�l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLàÔ*Ô5×BÒBØ+Ý Ô-Ø#ØØ,ðñ ô ð
 $Øð Cñ 	
ô 	
ô ð 	ð Ð'Ð'Ð)LÑ'Ô'Ð'ØÐrM   rž   Úfacet_filterc	                 ó  — | 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        ¬¦  «        }
t!          j        d„ |
j        D ¦   «         ¬¦  «        S t          |t          j        ¦  «        rt'          j        |¬¦  «        }| j        j                             |||t          j        |||||¬¦  «        ¬¦  «        j        }|€
J d¦   «         ‚|S )	Nrÿ   )ré   rž   r  rï   rv  r4   r  rö   r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_facet_value_hitr  s     rK   rX   z&QdrantRemote.facet.<locals>.<listcomp>'  s#   € ÐWÐWÐWÀ#•jÔ8¸Ñ=Ô=ÐWÐWÐWrM   )Úhits)r  rž   rï   r  rv  )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‹   rp  ÚfacetÚFacetRequestr!  )rœ   ré   rž   r€  rï   rv  r4   rõ   rö   r;   rU  Úfacet_results               rK   rŠ  zQdrantRemote.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ØØ'ØØØ#Ø%0Ø'9ð	ñ 	ô 	ð $+Ð#6˜˜¸D¼Mð .ñ ô ˆHõ Ô&ØWÐWÈÌÐWÑWÔWðñ ô ð õ �l¥D¤KÑ0Ô0ð 	IÝ%Ô4¸<ÐHÑHÔHˆLàÔ*Ô5×;Ò;Ø+Ø#ØÝ Ô-Ø,ØØØ#Øðñ ô ð	 <ñ 
ô 
ô ð 	ð Ð'Ð'Ð)LÑ'Ô'Ð'àÐrM   r  ÚwaitÚorderingÚupdate_filterÚupdate_modec	                 ó.  ‡‡— | 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        ¬¦  «        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                              ||‰||¬
¦  «        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   rf  ÚidsÚpayloadsÚconvert_payload)rH   Úidxr  Úvectors_batchs     €€rK   rX   z'QdrantRemote.upsert.<locals>.<listcomp>N  s€   ø€ ð ð ð ð õ Ô$Ý%Ô?ÀÄ
È3ÄÑPÔPØ -¨cÔ 2ð  &œÐ:õ 'Ô6°v´ÀsÔ7KÑLÔLÐLà!%ðñ ô ðð ð rM   c                 ón   — g | ]2}t          |t          j        ¦  «        rt          j        |¦  «        n|‘Œ3S rG   )r‚   r!   r–  r   Úconvert_point_structra  s     rK   rX   z'QdrantRemote.upsert.<locals>.<listcomp>[  sO   € ð ð ð ð õ & e­VÔ-?Ñ@Ô@ð#�
Ô7¸Ñ>Ô>Ð>à"ð	ð ð 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�  ra  s     rK   rX   z'QdrantRemote.upsert.<locals>.<listcomp>…  sO   € ð ð ð ð õ & e­TÔ-=Ñ>Ô>ð#�
Ô7¸Ñ>Ô>Ð>à"ð	ð ð 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‹   rp  Úupsert_points)rœ   ré   r  r�  rŽ  rö   r�  r�  r4   r;   Úgrpc_resultÚhttp_resultr›  s     `         @rK   ÚupsertzQdrantRemote.upsert=  sò  øø€ ð Ôñ \	Ý˜&¥&¤,Ñ/Ô/ð Ý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�àÔ*×1Ò1ÝÔ!Ø$3ØØ!Ø%Ø'9Ø"/Ø#Ø +ð	ñ 	ô 	ð œð 2ñ ô ô ð ð Ð*Ð*Ð,IÑ*Ô*Ð*ÝÔ3°KÑ@Ô@Ð@å˜-­¬Ñ5Ô5ð OÝ *Ô 9ÀÐ NÑ NÔ N�å˜&¥$Ñ'Ô'ð ðð ð "(ðñ ô �õ  Ô*Ø!Ø0Ø"/Ø +ð	ñ ô �õ ˜&¥&¤,Ñ/Ô/ð ÝÔ+Ø Ø0Ø"/Ø +ð	ñ ô �ð Ô-Ô8×FÒFØ /ØØ(.Ø!Øð Gñ ô ô ð ð Ð*Ð*Ð,IÑ*Ô*Ð*ØÐrM   c                 óò  — | 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        ¬¦  «        j        }	|	€
J d¦   «         ‚t#          j        |	¦  «        S t          |t          j	        ¦  «        rt#          j
        |¬¦  «        }| j        j                             ||t          j        |||¬¦  «        ||¬¦  «        j        S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_point_vectorsra  s     rK   rX   z/QdrantRemote.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‹   rp  r´  )
rœ   ré   r  r�  rŽ  rö   r�  r4   r;   r®  s
             rK   r´  zQdrantRemote.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�àÔ*×8Ò8ÝÔ'Ø$3ØØ!Ø%Ø'9Ø"/Ø#ðñ ô ð œð 9ñ ô ô ð ð Ð*Ð*Ð,IÑ*Ô*Ð*ÝÔ3°KÑ@Ô@Ð@å˜-­¬Ñ5Ô5ð OÝ *Ô 9ÀÐ NÑ NÔ N�àÔ&Ô1×@Ò@Ø /ØÝ%Ô3Ø!Ø0Ø"/ð ñ  ô  ð
 "Øð Añ 
ô 
ô ð
rM   r”  c                 ó¸  — | j         r÷|                      |¦  «        \  }	}
|p|
}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }| j
                             t          j        ||t          j        |¬¦  «        |	|||¬¦  «        | j        ¬¦  «        j        }|€
J d¦   «         ‚t#          j        |¦  «        S |                      |¦  «        \  }}| j        j                             ||||t/          t          j        ||||¬¦  «        ¬¦  «        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‹   rp  r»  r   )rœ   ré   r”  r  r�  rŽ  rö   r4   r;   r¹  Úopt_shard_key_selectorr®  Ú_pointsÚ_filters                 rK   r»  zQdrantRemote.delete_vectorsÜ  s“  € ð Ôð *	Ø6:×6YÒ6YÐZ`Ñ6aÔ6aÑ3ˆOÐ3Ø!3Ð!MÐ7MÐå˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�åÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"àÔ*×8Ò8ÝÔ'Ø$3ØÝ Ô0Ø%ðñ ô ð %4Ø%Ø'9Ø#ð
ñ 
ô 
ð œð 9ñ ô ô ð ð Ð*Ð*Ð,QÑ*Ô*Ð*åÔ3°KÑ@Ô@Ð@à#×KÒKÈFÑSÔSÑˆG�WØÔ&Ô1×@Ò@Ø /ØØ!ØÝ(ÝÔ(Ø"Ø"Ø"Ø0ð ñ  ô  ð Añ ô ô ðrM   r—  c                 óv  — | j         �r,t          |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        ¬¦  «        j        }	|	€
J d¦   «         ‚d„ |	D ¦   «         S t          |t          j        ¦  «        rt'          j        |¦  «        }d„ |D ¦   «         }| j        j                             ||t          j        ||||¬¦  «        |¬¦  «        j        }
|
€
J d	¦   «         ‚|
S )
Nc                 óˆ   — g | ]?}t          |t          t          j        ¦  «        ¦  «        rt	          j        |¦  «        n|‘Œ@S rG   ©r‚   r   r!   re  r   rf  ©rH   rš  s     rK   rX   z)QdrantRemote.retrieve.<locals>.<listcomp>"  sX   € ð ð ð ð õ " #Õ':½6Ô;QÑ'RÔ'RÑSÔSð•JÔ8¸Ñ=Ô=Ð=àð	ð ð 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)QdrantRemote.retrieve.<locals>.<listcomp>B  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   rm  r   rl  rÇ  s     rK   rX   z)QdrantRemote.retrieve.<locals>.<listcomp>H  sK   € ð ð ð àõ 6@ÀÅTÄ\Ñ5RÔ5RÐ[•Ô,¨SÑ1Ô1Ð1ÐX[ðð ð 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‹   rp  Ú
get_pointsÚPointRequest)rœ   ré   r—  rñ   rò   rõ   rö   r4   r;   r!  r¯  s              rK   ÚretrievezQdrantRemote.retrieve  s  € ð Ôñ ;	Ý˜,Õ(;½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]Ñ%^Ô%^Ð"àÔ%×)Ò)Ý”Ø$3ØØ!-Ø!-Ø%0Ø'9Ø#ðñ ô ð $+Ð#6˜˜¸D¼Mð *ñ ô ô ð ð Ð%Ð%Ð'FÑ%Ô%Ð%àTÐTÈVÐTÑTÔTÐTõ ˜,­Ô(@ÑAÔAð VÝ)ÔGÈÑUÔU�ðð àðñ ô ˆCð
 Ô-Ô8×CÒCØ /Ø'Ý$Ô1ØØ!-Ø ,Ø0ð	ñ ô ð  ð Dñ 
ô 
ô ð ð Ð*Ð*Ð,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   z?QdrantRemote._try_argument_to_grpc_selector.<locals>.<listcomp>c  sX   € ð ð ð ð  õ  *¨#Õ/BÅ6ÔCYÑ/ZÔ/ZÑ[Ô[ð%�JÔ@ÀÑEÔEÐEà!$ð	ð ð 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¼  z+QdrantRemote._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ØÐ 2Ð2Ð2rM   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   z?QdrantRemote._try_argument_to_rest_selector.<locals>.<listcomp>„  óK   € ð ð ð àõ 6@ÀÅTÄ\Ñ5RÔ5RÐ[•Ô,¨SÑ1Ô1Ð1ÐX[ðð ð 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_selectorz+QdrantRemote._try_argument_to_rest_selector}  sY  € õ �f�dÑ#Ô#ð 	Rðð à!ðñ ô ˆGõ (ÝÔ#ØØ,ðñ ô ˆ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_listz,QdrantRemote._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   zHQdrantRemote._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À  z4QdrantRemote._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                 óT  — | j         rÕ|                      |¦  «        \  }}|p|}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||||||¬¦  «        | j        ¬¦  «        j        ¦  «        S |                      ||¦  «        }| j        j                             |||||¬¦  «        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‹   rp  Údelete_points©
rœ   ré   r¹  r�  rŽ  rö   r4   r;   rÁ  r!  s
             rK   ÚdeletezQdrantRemote.deleteÍ  si  € ð Ôð %	Ø6:×6YÒ6YØñ7ô 7Ñ3ˆOÐ3ð "4Ð!MÐ7MÐå˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�åÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"åÔ3ØÔ ×'Ò'ÝÔ%Ø(7Ø!Ø.Ø!)Ø+=Ø 'ðñ ô ð !œMð (ñ 
ô 
ô ñô ð ð #×AÒAØÐ!3ñô ˆOð 15Ô0CÔ0N×0\Ò0\Ø /ØØ /Ø!Øð 1]ñ 1ô 1ô ð ð Ð%Ð%Ð'DÑ%Ô%Ð%ØˆMrM   r•  c	                 ó®  — | j         ré|                      |¦  «        \  }
}|p|}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||t          j        |¦  «        |
||||¬¦  «        | j        ¬¦  «        j        ¦  «        S |                      |¦  «        \  }}| j        j                             ||||t          j        |||||¬¦  «        ¬¦  «        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‹   rp  rò  )rœ   ré   r•  r  rž   r�  rŽ  rö   r4   r;   r¹  rÁ  rÂ  rÃ  r!  s                  rK   rò  zQdrantRemote.set_payloadþ  s�  € ð Ôð )	Ø6:×6YÒ6YÐZ`Ñ6aÔ6aÑ3ˆOÐ3Ø!3Ð!MÐ7MÐå˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�åÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"åÔ3ØÔ ×+Ò+ÝÔ)Ø(7Ø!Ý *Ô :¸7Ñ CÔ CØ(7Ø!)Ø+=ØØ 'ð	ñ 	ô 	ð !œMð ,ñ ô ô ñô ð ð   $×KÒKÈFÑSÔSÑˆG�WØ04Ô0CÔ0N×0ZÒ0ZØ /ØØ!ØÝ"Ô-Ø#Ø"Ø"Ø0Øðñ ô ð 1[ñ 1ô 1ô ð ð Ð%Ð%Ð'BÑ%Ô%Ð%ØˆMrM   c                 óª  — | j         rè|                      |¦  «        \  }	}
|p|
}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||t          j        |¦  «        |	|||¬¦  «        | j        ¬¦  «        j        ¦  «        S |                      |¦  «        \  }}| j        j                             ||||t          j        ||||¬¦  «        ¬¦  «        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‹   rp  Úoverwrite_payloadró  )rœ   ré   r•  r  r�  rŽ  rö   r4   r;   r¹  rÁ  rÂ  rÃ  r!  s                 rK   r÷  zQdrantRemote.overwrite_payload5  sŠ  € ð Ôð '	Ø6:×6YÒ6YÐZ`Ñ6aÔ6aÑ3ˆOÐ3Ø!3Ð!MÐ7MÐå˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�åÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"åÔ3ØÔ ×1Ò1ÝÔ)Ø(7Ø!Ý *Ô :¸7Ñ CÔ CØ(7Ø!)Ø+=Ø 'ðñ ô ð !œMð 2ñ ô ô ñô ð ð  $×KÒKÈFÑSÔSÑˆG�WØ04Ô0CÔ0N×0`Ò0`Ø /ØØ!ØÝ"Ô-Ø#Ø"Ø"Ø0ð	ñ ô ð 1añ 1ô 1ô ð ð Ð%Ð%Ð'HÑ%Ô%Ð%ØˆMrM   Úkeysc                 ó†  — | j         rÖ|                      |¦  «        \  }	}
|p|
}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||||	|||¬¦  «        | j        ¬¦  «        j        ¦  «        S |                      |¦  «        \  }}| j        j                             ||||t          j        ||||¬¦  «        ¬¦  «        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‹   rp  rú  )rœ   ré   rø  r  r�  rŽ  rö   r4   r;   r¹  rÁ  rÂ  rÃ  r!  s                 rK   rú  zQdrantRemote.delete_payloadi  s  € ð Ôð &	Ø6:×6YÒ6YÐZ`Ñ6aÔ6aÑ3ˆOÐ3Ø!3Ð!MÐ7MÐÝ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�åÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"åÔ3ØÔ ×.Ò.ÝÔ,Ø(7Ø!Ø!Ø(7Ø!)Ø+=Ø 'ðñ ô ð !œMð /ñ ô ô ñô ð ð  $×KÒKÈFÑSÔSÑˆG�WØ04Ô0CÔ0N×0]Ò0]Ø /ØØ!ØÝ%Ô3ØØ"Ø"Ø0ð	 ñ  ô  ð 1^ñ 1ô 1ô ð ð Ð%Ð%Ð'EÑ%Ô%Ð%ØˆMrM   c                 óT  — | j         rÕ|                      |¦  «        \  }}|p|}t          |t          j        ¦  «        rt          j        |¦  «        }t          |t          t          j        ¦  «        ¦  «        rt          j	        |¦  «        }t          j        | j                             t          j        ||||||¬¦  «        | j        ¬¦  «        j        ¦  «        S |                      ||¦  «        }| j        j                             |||||¬¦  «        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‹   rp  Úclear_payloadrî  s
             rK   r   zQdrantRemote.clear_payloadœ  si  € ð Ôð %	Ø6:×6YÒ6YØñ7ô 7Ñ3ˆOÐ3ð "4Ð!MÐ7MÐå˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�åÐ,Õ.AÅ&ÔBYÑ.ZÔ.ZÑ[Ô[ð _Ý%/Ô%JÐK]Ñ%^Ô%^Ð"åÔ3ØÔ ×-Ò-ÝÔ+Ø(7Ø!Ø.Ø!)Ø+=Ø 'ðñ ô ð !œMð .ñ 
ô 
ô ñô ð ð #×AÒAØÐ!3ñô ˆOð 15Ô0CÔ0N×0\Ò0\Ø /ØØ!ØØ /ð 1]ñ 1ô 1ô ð ð Ð%Ð%Ð'DÑ%Ô%Ð%ØˆMrM   Úupdate_operationsc           
      ó¦  — | j         r�d„ |D ¦   «         }t          |t          j        ¦  «        rt	          j        |¦  «        }d„ | j                             t          j	        |||||¬¦  «        | j
        ¬¦  «        j        D ¦   «         S | j        j                             ||||t          j        |¬¦  «        ¬¦  «        j        }|€
J d¦   «         ‚|S )Nc                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_update_operation©rH   Ú	operations     rK   rX   z4QdrantRemote.batch_update_points.<locals>.<listcomp>×  s0   € ð !ð !ð !ØCL•
Ô3°IÑ>Ô>ð!ð !ð !rM   c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   rª  )rH   r!  s     rK   rX   z4QdrantRemote.batch_update_points.<locals>.<listcomp>Þ  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‹   rp  Úbatch_updateÚUpdateOperations)rœ   ré   r  r�  rŽ  r4   r;   r!  s           rK   Úbatch_update_pointsz QdrantRemote.batch_update_pointsÍ  s$  € ð Ôð 	ð!ð !ØPað!ñ !ô !Ðõ ˜(¥FÔ$8Ñ9Ô9ð GÝ%Ô<¸XÑFÔF�ðð à"Ô.×:Ò:ÝÔ*Ø(7Ø!Ø#4Ø!)Ø 'ðñ ô ð !œMð ;ñ 	ô 	ô ðñ ô ð ð 7;Ô6IÔ6T×6aÒ6aØ /ØØ!ØÝ"(Ô"9ÐEVÐ"WÑ"WÔ"Wð 7bñ 7ô 7ô ð ð Ð%Ð%Ð'JÑ%Ô%Ð%ØˆMrM   Úchange_aliases_operationsc                 óJ  — | j         rJd„ |D ¦   «         }| j                             t          j        ||¬¦  «        |�|n| j        ¬¦  «        j        S d„ |D ¦   «         }| j        j         	                    |t          j        |¬¦  «        ¬¦  «        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:QdrantRemote.update_collection_aliases.<locals>.<listcomp>ý  sO   € ð (ð (ð (ð õ & iµÔ1EÑFÔFð#•JÔ7¸	ÑBÔBÐBà"ð	(ð (ð (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:QdrantRemote.update_collection_aliases.<locals>.<listcomp>  sO   € ð $
ð $
ð $
ð õ ˜i­Ô)=Ñ>Ô>ð•
Ô3°IÑ>Ô>Ð>àð	$
ð $
ð $
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&QdrantRemote.update_collection_aliasesö  s  € ð Ôð 	ð(ð (ð ";ð(ñ (ô (Ð$ð Ô(×6Ò6ÝÔ"Ø#Ø4ðñ ô ð $+Ð#6˜˜¸D¼Mð 7ñ ô ô ðð$
ð $
ð 7ð$
ñ $
ô $
Ð ð #œiÔ3×BÒBØÝ%+Ô%BØ0ð&ñ &ô &ð Cñ 
ô 
ô
 ð 	ð Ð!Ð!Ð#AÑ!Ô!Ð!ØˆrM   c                 ó&  — | j         rX| j                             t          j        |¬¦  «        | j        ¬¦  «        j        }t          j        d„ |D ¦   «         ¬¦  «        S | j	        j
                             |¬¦  «        j        }|€
J d¦   «         ‚|S )N©ré   r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   ©r   Úconvert_alias_description©rH   Údescriptions     rK   rX   z7QdrantRemote.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;   rU  r!  s        rK   r)  z#QdrantRemote.get_collection_aliases  sÂ   € ð Ôð 		ØÔ,×BÒBÝÔ1À/ÐRÑRÔRØœð Cñ ô ô ð õ Ô3ðð ØYaðñ ô ðñ ô ð ð ŒIÔ!×8Ò8ÈÐ8ÑYÔYÔ`ð 	ð Ð!Ð!Ð#IÑ!Ô!Ð!ØˆrM   c                 ó  — | j         rV| j                             t          j        ¦   «         | j        ¬¦  «        j        }t          j        d„ |D ¦   «         ¬¦  «        S | j	        j
                             ¦   «         j        }|€
J d¦   «         ‚|S )Nr  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   r  r!  s     rK   rX   z,QdrantRemote.get_aliases.<locals>.<listcomp>8  r#  rM   r$  zGet aliases returned None)rb   rÛ   ÚListAliasesr   ÚListAliasesRequestr‰   r%  rˆ  r(  r=   r  Úget_collections_aliasesr!  ©rœ   r;   rU  r!  s       rK   Úget_aliaseszQdrantRemote.get_aliases2  s²   € ØÔð 	ØÔ,×8Ò8ÝÔ'Ñ)Ô)°4´=ð 9ñ ô äð õ Ô3ðð ØYaðñ ô ðñ ô ð ð ŒIÔ!×9Ò9Ñ;Ô;ÔBð 	ð Ð!Ð!Ð#>Ñ!Ô!Ð!ØˆrM   c                 ó  — | j         rV| j                             t          j        ¦   «         | j        ¬¦  «        j        }t          j        d„ |D ¦   «         ¬¦  «        S | j	        j
                             ¦   «         j        }|€
J d¦   «         ‚|S )Nr  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   )r   Úconvert_collection_descriptionr!  s     rK   rX   z0QdrantRemote.get_collections.<locals>.<listcomp>H  s3   € ð ð ð à#õ Ô=¸kÑJÔJðð ð rM   )ÚcollectionszGet collections returned None)rb   rÛ   ÚListr   ÚListCollectionsRequestr‰   r5  rˆ  ÚCollectionsResponser=   Úcollections_apiÚget_collectionsr!  r0  s       rK   r:  zQdrantRemote.get_collectionsB  s²   € ØÔð 		ØÔ,×1Ò1ÝÔ+Ñ-Ô-°t´}ð 2ñ ô äð õ Ô,ðð à'/ðñ ô ðñ ô ð ð ŒIÔ%×5Ò5Ñ7Ô7Ô>ð 	ð Ð!Ð!Ð#BÑ!Ô!Ð!ØˆrM   c                 ó  — | j         rKt          j        | j                             t          j        |¬¦  «        | j        ¬¦  «        j        ¦  «        S | j	        j
                             |¬¦  «        j        }|€
J d¦   «         ‚|S )Nr  r  zGet collection returned None)rb   r   Úconvert_collection_inforÛ   rÍ  r   ÚGetCollectionInfoRequestr‰   r!  r=   r9  Úget_collection©rœ   ré   r;   r!  s       rK   r>  zQdrantRemote.get_collectionT  sŸ   € ØÔð 	ÝÔ5ØÔ%×)Ò)ÝÔ1À/ÐRÑRÔRØ œMð *ñ ô ô ñ	ô ð ð /3¬iÔ.G×.VÒ.VØ+ð /Wñ /
ô /
ä
ð 	ð Ð!Ð!Ð#AÑ!Ô!Ð!ØˆrM   c                 óü   — | j         r>| j                             t          j        |¬¦  «        | j        ¬¦  «        j        j        S | j        j	         
                    |¬¦  «        j        }|€
J d¦   «         ‚|j        S )Nr  r  zCollection exists returned None)rb   rÛ   ÚCollectionExistsr   ÚCollectionExistsRequestr‰   r!  Úexistsr=   r9  Úcollection_existsr?  s       rK   rD  zQdrantRemote.collection_existsb  s”   € ØÔð 	ØÔ(×9Ò9ÝÔ,¸_ÐMÑMÔMØœð :ñ ô ô ”Vðð
 59´IÔ4M×4_Ò4_Ø+ð 5`ñ 5
ô 5
ä
ð 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØŒ}ÐrM   Úoptimizers_configÚcollection_paramsÚvectors_configÚhnsw_configÚquantization_configÚsparse_vectors_configÚstrict_mode_configrN   c                 óä  — | 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        ¬¦  «        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        |||||||	|
¬¦  «        |¬¦  «        j        }|€
J d¦   «         ‚|S )N)
ré   rE  r  rG  rH  rI  rJ  rK  r4   rN   r  )rE  r  r”  rH  rI  Úsparse_vectorsrK  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=   r9  rN  )rœ   ré   rE  rF  rG  rH  rI  r4   rJ  rK  rN   r;   r!  s                rK   rN  zQdrantRemote.update_collectiono  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Ñ?Ô?�àÔ(×/Ò/ÝÔ%Ø$3Ø&7Ø,Ø#1Ø +Ø(;Ø*?Ø'9Ø#Ø%ðñ ô ð $+Ð#6˜˜¸D¼Mð 0ñ ô ô ðõ  Ð'­Ô)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Ðà"œiÔ7×IÒIØÝ$Ô5Ø"3Ø(Ø&Ø'Ø$7Ø4Ø#5Ø!ð	ñ 	ô 	ð ð Jñ 
ô 
ô ð 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   c                 óô   — | j         r>| j                             t          j        ||¬¦  «        |�|n| j        ¬¦  «        j        S | j        j         	                    ||¬¦  «        j        }|€
J d¦   «         ‚|S )N©ré   r4   r  zDelete collection returned None)
rb   rÛ   rë  r   ÚDeleteCollectionr‰   r!  r=   r9  Údelete_collection)rœ   ré   r4   r;   r!  s        rK   rb  zQdrantRemote.delete_collectionÊ  sž   € ð Ôð 	ØÔ(×/Ò/ÝÔ%°oÈwÐWÑWÔWØ#*Ð#6˜˜¸D¼Mð 0ñ ô ô ðð
 #œiÔ7×IÒIØ Wð Jñ 
ô 
ä
ð 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   Úshard_numberÚreplication_factorÚwrite_consistency_factorÚon_disk_payloadÚ
wal_configÚsharding_methodc                 ó¦  — | j         �r;t          |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        ¬¦  «        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          !                    |||¬¦  «        j        }|€
J d¦   «         ‚|S )Nré   rH  rg  rE  rc  rf  r4   rG  rd  re  rI  rJ  rh  rK  rN   r•  r  )r”  rc  rd  re  rf  rH  rE  rg  rI  rM  rh  rK  rN   r•  )ré   Úcreate_collectionr4   zCreate collection returned NonerG   )"rb   r‚   r!   ÚVectorParamsrS  r   Úconvert_vectors_configrU  rV  rO  rP  ÚWalConfigDiffÚconvert_wal_config_diffr   ÚQuantizationConfigÚconvert_quantization_configrY  ÚShardingMethodÚconvert_sharding_methodrZ  r[  r™  ÚPayloadStorageParamsÚconvert_payload_storage_paramsr   ÚCreateCollectionrÛ   ÚCreater‰   r!  r   r=   r9  rj  )rœ   ré   rG  rc  rd  re  rf  rH  rE  rg  rI  r4   rJ  rh  rK  rN   r•  r;   rj  Úcreate_collection_requestr!  s                        rK   rj  zQdrantRemote.create_collectionÙ  sÙ  € ð( Ôñ 6	aÝ˜.­6Ô+>ÅÐ*EÑFÔFð SÝ!+Ô!BÀ>Ñ!RÔ!R�å˜+¥vÔ'<Ñ=Ô=ð OÝ(ÔAÀ+ÑNÔN�åÐ+­VÔ-HÑIÔIð aÝ$.Ô$MÐN_Ñ$`Ô$`Ð!å˜*¥fÔ&:Ñ;Ô;ð LÝ'Ô?À
ÑKÔK�
åØ#Ý�Ô2Ñ3Ô3ñô ð bõ '1Ô&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ð!ð "˜ð!ð   ˜ð!!Ðð$ Ô(×/Ò/Ð0AÈ4Ì=Ð/ÑYÔYÔ`Ð`å�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ØØð%
ñ %
ô %
Ð!ð" #œiÔ7×IÒIØ+Ø7Øð Jñ 
ô 
ô ð	 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   c                 óz   — |                       ||¬¦  «         |                      |||||||||	|
||||||¬¦  «        S )Nr  )ré   rG  rc  rd  re  rf  rH  rE  rg  rI  r4   rJ  rh  rK  rN   r•  )rb  rj  )rœ   ré   rG  rc  rd  re  rf  rH  rE  rg  rI  r4   rJ  rh  rK  rN   r•  r;   s                     rK   Úrecreate_collectionz QdrantRemote.recreate_collectionK  sj   € ð( 	×Ò˜¸ÐÑ@Ô@Ð@à×%Ò%Ø+Ø)Ø%Ø1Ø%=Ø+Ø#Ø/Ø!Ø 3ØØ"7Ø+Ø1ØØð! &ñ 
ô 
ð 	
rM   c                 ó,   — | j         rt          S t          S r­   )rb   r$   r%   r®   s    rK   Ú_updater_classzQdrantRemote._updater_classt  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ˆ   r{  r›   Úprocessr#   Úunordered_map)rœ   r|  ré   r}  r~  r  r�  rö   r�  r�  r„  Úupdater_kwargsÚupdaterrW   Úpools                  rK   Ú_upload_collectionzQdrantRemote._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Œ  ©	r|  ré   r}  r~  r  r�  rö   r�  r�  )r{  Úiterate_records_batchesrŠ  )rœ   ré   r  rŒ  r~  r  r}  r�  rö   r�  r�  r;   r|  s                rK   Úupload_pointszQdrantRemote.upload_pointsµ  sl   € ð  Ô.×FÒFØ zð Gñ 
ô 
Ðð 	×ÒØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 ñ 
	
ô 
	
ð 
	
ð 
	
ð 
	
rM   c                 ó~   — | j                              ||||¬¦  «        }|                      ||||||	|
||¬¦	  «	         d S )N)r”  r•  r—  rŒ  r�  )r{  Úiterate_batchesrŠ  )rœ   ré   r”  r•  r—  rŒ  r~  r  r}  r�  rö   r�  r�  r;   r|  s                  rK   Úupload_collectionzQdrantRemote.upload_collectionÓ  sr   € ð   Ô.×>Ò>ØØØØ!ð	 ?ñ 
ô 
Ðð 	×ÒØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 ñ 
	
ô 
	
ð 
	
ð 
	
ð 
	
rM   Ú
field_nameÚfield_schemaÚ
field_typec           	      óü  — |�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(        ¬¦  «        j)        ¦  «        S t          |t          ¦  «        rtI          j        |¦  «        }t          |t          j        ¦  «        rtI          j        |¦  «        }| j*        j+         ,                    |t	          j'        ||¬¦  «        |||¬	¦  «        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_typerC  Ú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!QdrantRemote.create_payload_indexö  sG  € ð Ð!ÝØLÝ+ØØ.ð	ñ ô ð ð &ˆLàÔñ ;	Ø!%ÐÝ˜,­Ô(@ÑAÔAð TÝ)ÔEÀlÑSÔS�å˜,­Ñ,Ô,ð Ý)ÔEÝÔ,¨\Ñ:Ô:ñ ô  �õ ˜,­Ñ,Ô,ð Oõ
  AÀÑ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ØÔ ×1Ò1°'À4Ä=Ð1ÑQÔQÔXñô ð õ �l¥CÑ(Ô(ð 	PÝ%ÔAÀ,ÑOÔOˆLå�l¥DÔ$;Ñ<Ô<ð 	RÝ%ÔCÀLÑQÔQˆLà,0Ô,?Ô,K×,^Ò,^Ø+Ý%Ô6Ø%°Lð ñ  ô  ð ØØð -_ñ -
ô -
ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   c                 ó   — | j         rQt          j        |||||¬¦  «        }t          j        | j                             || j        ¬¦  «        j        ¦  «        S | j	        j
                             |||||¬¦  «        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!QdrantRemote.delete_payload_indexY	  sÀ   € ð Ôð 
	ÝÔ5Ø /Ø%ØØ!Øðñ ô ˆGõ Ô3ØÔ ×1Ò1°'À4Ä=Ð1ÑQÔQÔXñô ð ð -1Ô,?Ô,K×,^Ò,^Ø+Ø!ØØØð -_ñ -
ô -
ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   Úvector_nameÚvector_name_configc           	      óª  — | 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        ¬¦  «        j        ¦  «        S | j        j                             ||||||¬¦  «        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=   r9  Úcreate_vector_name)rœ   ré   r¾  r¿  r�  rŽ  r4   r;   rÆ  rÇ  ÚcfgÚgrpc_orderingr·  r!  s                 rK   rÔ  zQdrantRemote.create_vector_namex	  s  € ð Ôñ 1	ØˆLØ ˆMÝÐ,­fÔ.JÑKÔKð Ø(Ô.�Ý#Ô=ØœÝ'Ô8¸¼ÑFÔFð Ô1Ð=õ #Ô=¸cÔ>TÑUÔUÐUà!ð œ<Ð3õ #Ô3°C´LÑAÔAÐAà!ð ñ  ô  ��õ Ð.µÔ0MÑNÔNð Ø(Ô/�Ý $Ô ?ð œ<Ð3õ #Ô3°C´LÑAÔAÐAà!ð œ<Ð3õ #Ô3°C´LÑAÔAÐAà!ð!ñ !ô !�õ ˜h­Ô(<Ñ=Ô=ð•
Ô1°(Ñ;Ô;Ð;àð õ
 Ô2Ø /ØØ'Ø)Ø+ØØ&ðñ ô ˆGõ Ô3ØÔ ×1Ò1°'À4Ä=Ð1ÑQÔQÔXñô ð ð -1¬IÔ,E×,XÒ,XØ+Ø#ØØØØ1ð -Yñ -
ô -
ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   c                 ó€  — | j         r�t          |t          j        ¦  «        rt	          j        |¦  «        nd }t          j        |||||¬¦  «        }t          j	        | j
                             || j        ¬¦  «        j        ¦  «        S | j        j                             |||||¬¦  «        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‹   r9  Údelete_vector_name)
rœ   ré   r¾  r�  rŽ  r4   r;   rÖ  r·  r!  s
             rK   rÚ  zQdrantRemote.delete_vector_nameÀ	  sñ   € ð Ôð 	õ ˜h­Ô(<Ñ=Ô=ð•
Ô1°(Ñ;Ô;Ð;àð õ
 Ô2Ø /ØØ'ØØ&ðñ ô ˆGõ Ô3ØÔ ×1Ò1°'À4Ä=Ð1ÑQÔQÔXñô ð ð -1Ô,?Ô,O×,bÒ,bØ+Ø#ØØØð -cñ -
ô -
ô ð 	ð Ð!Ð!Ð#EÑ!Ô!Ð!ØˆrM   c                 ó   — | j         rE| j                             t          j        |¬¦  «        | j        ¬¦  «        j        }d„ |D ¦   «         S | j        j         	                    |¬¦  «        j
        }|€
J d¦   «         ‚|S )Nr  r  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   ©r   Úconvert_snapshot_description©rH   Úsnapshots     rK   rX   z/QdrantRemote.list_snapshots.<locals>.<listcomp>ë	  ó#   € Ð`Ð`Ð`È(•JÔ;¸HÑEÔEÐ`Ð`Ð`rM   ú'List snapshots API returned None result)rb   rß   r6  r   ÚListSnapshotsRequestr‰   Úsnapshot_descriptionsr‹   Úsnapshots_apiÚlist_snapshotsr!  )rœ   ré   r;   Ú	snapshotss       rK   ræ  zQdrantRemote.list_snapshotsä	  s©   € ð Ôð 	aØÔ+×0Ò0ÝÔ)¸/ÐJÑJÔJÐTXÔTað 1ñ ô ä#ð ð aÐ`ÐV_Ð`Ñ`Ô`Ð`àÔ'Ô5×DÒDØ+ð Eñ 
ô 
ä
ð 	ð Ð$Ð$Ð&OÑ$Ô$Ð$ØÐrM   c                 óö   — | j         rM| j                             t          j        |¬¦  «        | j        ¬¦  «        j        }t          j        |¦  «        S | j	        j
                             ||¬¦  «        j        S )Nr  r  )ré   r�  )rb   rß   rv  r   ÚCreateSnapshotRequestr‰   Úsnapshot_descriptionr   rÞ  r‹   rå  Úcreate_snapshotr!  )rœ   ré   r�  r;   rà  s        rK   rë  zQdrantRemote.create_snapshotó	  s‰   € ð Ôð 	EØÔ*×1Ò1ÝÔ*¸?ÐKÑKÔKÐUYÔUbð 2ñ ô ä"ð õ Ô:¸8ÑDÔDÐDàÔ"Ô0×@Ò@Ø+°$ð Añ 
ô 
ä
ð	rM   Úsnapshot_namec                 óÌ   — | j         r7| j                             t          j        ||¬¦  «        | j        ¬¦  «         dS | j        j                             |||¬¦  «        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QdrantRemote.delete_snapshot 
  s‰   € ð Ôð 	ØÔ×&Ò&ÝÔ*Ø$3À=ðñ ô ð œð	 'ñ ô ð ð �4àÔ"Ô0×@Ò@Ø+Ø'Øð Añ 
ô 
ô ð		rM   c                 óø   — | j         rC| j                             t          j        ¦   «         | j        ¬¦  «        j        }d„ |D ¦   «         S | j        j         	                    ¦   «         j
        }|€
J d¦   «         ‚|S )Nr  c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rG   rÝ  rß  s     rK   rX   z4QdrantRemote.list_full_snapshots.<locals>.<listcomp>
  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 QdrantRemote.list_full_snapshots
  s‘   € ØÔð 	aØÔ+×4Ò4ÝÔ-Ñ/Ô/Øœð 5ñ ô ô $ð ð aÐ`ÐV_Ð`Ñ`Ô`Ð`àÔ'Ô5×IÒIÑKÔKÔRˆ	ØÐ$Ð$Ð&TÑ$Ô$Ð$ØÐrM   c                 óð   — | j         rK| j                             t          j        ¦   «         | j        ¬¦  «        j        }t          j        |¦  «        S | j	        j
                             |¬¦  «        j        S )Nr  )r�  )rb   rß   Ú
CreateFullr   ÚCreateFullSnapshotRequestr‰   rê  r   rÞ  r‹   rå  Úcreate_full_snapshotr!  )rœ   r�  r;   rê  s       rK   rø  z!QdrantRemote.create_full_snapshot
  sv   € ØÔð 	QØ#'Ô#6×#AÒ#AÝÔ.Ñ0Ô0¸$¼-ð $Bñ $ô $ä"ð !õ Ô:Ð;OÑPÔPÐPàÔ"Ô0×EÒEÈ4ÐEÑPÔPÔWÐWrM   c                 óÈ   — | j         r6| j                             t          j        |¬¦  «        | j        ¬¦  «         dS | j        j                             ||¬¦  «        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!QdrantRemote.delete_full_snapshot'
  sx   € ð Ôð 	ØÔ×*Ò*ÝÔ.¸]ÐKÑKÔKØœð +ñ ô ð ð �4àÔ"Ô0×EÒEØ'¨dð Fñ 
ô 
ä
ð	rM   ÚlocationÚchecksumÚpriorityc           
      ó|   — | j         j                             ||t          j        ||||¬¦  «        ¬¦  «        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QdrantRemote.recover_snapshot5
  sT   € ð Ô"Ô0×FÒFØ+ØÝ#Ô3Ø!Ø!Ø!Øð	ñ ô ð Gñ 	
ô 	
ô ð		rM   Úshard_idc                 ój   — | j         j                             ||¬¦  «        j        }|€
J d¦   «         ‚|S )N)ré   r  râ  )r‹   rå  Úlist_shard_snapshotsr!  )rœ   ré   r  r;   rç  s        rK   r  z!QdrantRemote.list_shard_snapshotsJ
  sP   € ð Ô'Ô5×JÒJØ+Øð Kñ 
ô 
ô ð 	ð Ð$Ð$Ð&OÑ$Ô$Ð$ØÐrM   c                 óP   — | j         j                             |||¬¦  «        j        S )N)ré   r  r�  )r‹   rå  Úcreate_shard_snapshotr!  )rœ   ré   r  r�  r;   s        rK   r
  z"QdrantRemote.create_shard_snapshotT
  s6   € ð Ô"Ô0×FÒFØ+ØØð Gñ 
ô 
ô ð		rM   c                 óR   — | j         j                             ||||¬¦  «        j        S )N)ré   r  rì  r�  )r‹   rå  Údelete_shard_snapshotr!  )rœ   ré   r  rì  r�  r;   s         rK   r  z"QdrantRemote.delete_shard_snapshot]
  s9   € ð Ô"Ô0×FÒFØ+ØØ'Øð	 Gñ 
ô 
ô
 ð	rM   c                 ó~   — | j         j                             |||t          j        ||||¬¦  «        ¬¦  «        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#QdrantRemote.recover_shard_snapshotl
  sW   € ð Ô"Ô0×LÒLØ+ØØÝ#)Ô#>Ø!Ø!Ø!Øð	$ñ $ô $ð	 Mñ 

ô 

ô ð
	rM   r  Úshards_numberÚ	placementÚinitial_statec                 ó*  — | j         rÁt          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }t          |t          j        ¦  «        rt          j        |¦  «        }| j	         
                    t          j        ||t          j
        ||||pg |¬¦  «        ¬¦  «        |�|n| j        ¬¦  «        j        S | j        j                             ||t          j        |||||¬¦  «        ¬¦  «        j        }	|	€
J d¦   «         ‚|	S )N)r  r  rd  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  rd  r  r  r4   r;   r!  s
             rK   r  zQdrantRemote.create_shard_keyƒ
  sL  € ð Ôð "	Ý˜)Õ%8½¼Ñ%IÔ%IÑJÔJð DÝ&Ô8¸ÑCÔC�	å˜-­Ô)<Ñ=Ô=ð PÝ *Ô @ÀÑ OÔ O�àÔ(×7Ò7ÝÔ*Ø$3Ø#Ý Ô/Ø"+Ø&3Ø+=Ø"+ /¨rØ&3ðñ ô ð
ñ 
ô 
ð $+Ð#6˜˜¸D¼Mð 8ñ ô ô ðð Ô(Ô8×IÒIØ /ØÝ$*Ô$<Ø'Ø"/Ø'9Ø'Ø"/ð%ñ %ô %ð Jñ 
ô 
ô ð ð Ð%Ð%Ð'GÑ%Ô%Ð%ØˆMrM   c           	      óº  — | j         r�t          |t          t          j        ¦  «        ¦  «        rt          j        |¦  «        }| j                             t          j
        ||t          j        |¬¦  «        ¬¦  «        |�|n| j        ¬¦  «        j        S | j        j                             ||t          j        |¬¦  «        ¬¦  «        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QdrantRemote.delete_shard_key²
  s
  € ð Ôð 	Ý˜)Õ%8½¼Ñ%IÔ%IÑJÔJð DÝ&Ô8¸ÑCÔC�	àÔ(×7Ò7ÝÔ*Ø$3Ø#Ý Ô/Ø"+ðñ ô ðñ ô ð $+Ð#6˜˜¸D¼Mð 8ñ 	ô 	ô ð	ð Ô(Ô8×IÒIØ /ØÝ"(Ô"8Ø'ð#ñ #ô #ð Jñ ô ô ð ð Ð%Ð%Ð'GÑ%Ô%Ð%ØˆMrM   c                 óô   — | j         rF| j                             t          j        ¦   «         | j        ¬¦  «        }t          j        |¦  «        S | j        j	         
                    ¦   «         }|€
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QdrantRemote.infoÒ
  s~   € ØÔð 	GØœ>×5Ò5ÝÔ'Ñ)Ô)°4´=ð 6ñ ô ˆLõ Ô8¸ÑFÔFÐFØ”yÔ,×1Ò1Ñ3Ô3ˆØÐ'Ð'Ð)DÑ'Ô'Ð'ØÐrM   Úcluster_operationc                 óD  — | j         �rdt          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        ¬¦  «        j        S | j        j                             |||¬¦  «        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&QdrantRemote.cluster_collection_updateÜ
  s  € ð Ôñ 	Ý *Ô 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àÔ(×EÒEÝÔ8ð Ø$3¸Wðð ØHVðð ð $+Ð#6˜˜¸D¼Mð	 Fñ ô ô
 ðð œ	Ô1×KÒKØ+Ð@QÐ[bð Lñ 
ô 
ä
ð 	ð Ð(Ð(Ð*SÑ(Ô(Ð(ØÐrM   c                 ód   — | j         j                             ¦   «         j        }|€
J d¦   «         ‚|S )NzCluster status returned None)rå   r  Úcluster_statusr!  )rœ   Ústatus_results     rK   rF  zQdrantRemote.cluster_status  s6   € àœ	Ô1×@Ò@ÑBÔBÔIˆØÐ(Ð(Ð*HÑ(Ô(Ð(ØÐrM   c                 ód   — | j         j                             ¦   «         j        }|€
J d¦   «         ‚|S )Nz"Recover current peer returned None)rå   r  Úrecover_current_peerr!  )rœ   Úrecover_results     rK   rI  z!QdrantRemote.recover_current_peer  s6   € àœÔ2×GÒGÑIÔIÔPˆØÐ)Ð)Ð+OÑ)Ô)Ð)ØÐrM   Úpeer_idÚforcec                 ól   — | j         j                             |||¬¦  «        j        }|€
J d¦   «         ‚|S )N)rK  rL  r4   zRemove peer returned None)rå   r  Úremove_peerr!  )rœ   rK  rL  r4   r;   rC  s         rK   rN  zQdrantRemote.remove_peer  sQ   € ð œ	Ô1×=Ò=ØØØð >ñ 
ô 
ô ð	 	ð
 Ð(Ð(Ð*EÑ(Ô(Ð(ØÐrM   c                 ó  — | j         rH| j                             t          j        |¬¦  «        | j        ¬¦  «        }t          j        |¦  «        S | j        j	         
                    |¬¦  «        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   rS  z$QdrantRemote.collection_cluster_info"  s›   € ØÔð 	OØ"Ô3×IÒIÝÔ1À/ÐRÑRÔRØœð Jñ ô ˆOõ Ô=¸oÑNÔNÐNØœ)Ô3×KÒKØ+ð Lñ 
ô 
ä
ð 	ð Ð*Ð*Ð,SÑ*Ô*Ð*ØÐrM   Úcompleted_limitc                 ój   — | j         j                             ||¬¦  «        j        }|€
J d¦   «         ‚|S )N)ré   rU  zGet optimizations returned None)r=   r9  Úget_optimizationsr!  )rœ   ré   rU  r;   r!  s        rK   rW  zQdrantRemote.get_optimizations/  sM   € ð ”Ô*×<Ò<Ø+Ø+ð =ñ 
ô 
ô ð 	ð Ð!Ð!Ð#DÑ!Ô!Ð!ØˆrM   c                 ó&  — | j         rX| j                             t          j        |¬¦  «        | j        ¬¦  «        }t          j        d„ |j        D ¦   «         ¬¦  «        S | j	        j
                             |¬¦  «        j        }|€
J d¦   «         ‚|S )Nr  r  c                 óf   — g | ].}t          j        t          j        |j        ¦  «        ¬ ¦  «        ‘Œ/S ))rž   )r!   ÚShardKeyDescriptionr   r  rž   )rH   Úsks     rK   rX   z0QdrantRemote.list_shard_keys.<locals>.<listcomp>H  sL   € ð ð ð ð õ Ô.Ý&Ô8¸¼Ñ@Ô@ðñ ô ðð ð rM   )Ú
shard_keyszList shard keys returned None)rb   rÛ   ÚListShardKeysr   ÚListShardKeysRequestr‰   r!   ÚShardKeysResponser\  rå   r  Úlist_shard_keysr!  r*  s        rK   r`  zQdrantRemote.list_shard_keys=  sÅ   € ð
 Ôð 	ØÔ,×:Ò:ÝÔ)¸/ÐJÑJÔJØœð ;ñ ô ˆHõ Ô+ðð ð 'Ô1ð	ñ ô ðñ ô ð ð ”Ô*×:Ò:Ø+ð ;ñ 
ô 
ä
ð 	ð Ð!Ð!Ð#BÑ!Ô!Ð!ØˆrM   Údetails_levelc                 ój   — | j         j                             ||¬¦  «        j        }|€
J d¦   «         ‚|S )N)ra  r4   zCluster telemetry returned None)rå   r  Úcluster_telemetryr!  )rœ   ra  r4   r;   r!  s        rK   rc  zQdrantRemote.cluster_telemetryU  sM   € ð ”Ô*×<Ò<Ø'Øð =ñ 
ô 
ô ð 	ð Ð!Ð!Ð#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»   rC  rŸ  ÚboolrS  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ˆ  rm  r  ÚSparseVectorr  Ú
NumpyArrayÚDocumentÚImageÚInferenceObjectrú   r  r  r
   ÚPayloadSelectorr  r  r  r"  r'  r%  r6  ÚWithLookupInterfaceÚGroupsResultrH  ÚSearchMatrixPairsResponserR  ÚSearchMatrixOffsetsResponserZ  rn  ÚRecordrt  ÚCountResultr  r‰  rŠ  ÚPointsr¤  r¦  ÚUpdateResultr°  ÚPointVectorsr´  rÕ  r»  rÑ  Úclassmethodr¼  r!   rÞ  rå  re  rÀ  rï  ÚPayloadrò  r÷  rú  r   ÚUpdateOperationr  r  r  r(  r)  r1  r8  r:  ÚCollectionInfor>  rD  rO  rQ  r^  rU  rW  r	   ÚSparseVectorParamsrZ  rN  rb  rk  rm  ro  rq  rs  rj  ry  r   r&   r{  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.  ÚClusterOperationsrD  ÚClusterStatusrF  rI  rN  rP  rS  ÚOptimizationsResponserW  r_  r`  ÚDistributedTelemetryDatarc  Ú__classcell__)r¥   s   @rK   r(   r(   -   s¬$  ø€ € € € € ØÐØÐð ØØØ!Ø!Ø"Ø!Ø"ØØ.2ØW[Ø$(Ø $Ø)-ðWð Wà�4‰ZðWð �D‰jðWð ð	Wð
 ðWð �d‰{ðWð �t‘ðWð �d‘
ðWð �t‘ðWð �D‰jðWð ˜3 ˜8”n tÑ+ðWð & b¨# gÔ.°¸"¸iÈ¼nÐ:LÔ1MÑMÐPTÑTðWð "ðWð ˜‘:ðWð �c˜3�h” $Ñ&ðWð  ð!Wð Wð Wð Wð Wð Wðr ðØðØ%)¨#¨s¨(¤^ðØ;>ðØILðà	ðð ð ñ „\ðð< ð˜ð ð ð ñ „Xððð  ¨¡ð ¸sð Àtð ð ð ð ð. ð*˜ð *  c¨D¡j°#°s¸T±zÀ3ÈÁ:Ð&MÔ Nð *ð *ð *ñ „\ð*ð
/ Sð 
/ð 
/ð 
/ð 
/ðRð Rð Rð Rð6
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð 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ð ð#�h˜yÔ)ð #ð #ð #ñ „Xð#ð ð#�h˜yÔ)ð #ð #ð #ñ „Xð#ð( Ø ØAEØ,0Ø37ØØ!ØEIØ-2Ø(,Ø37Ø48Ø<@Ø"ð3{ð {àð{ð Œ}Ø
ˆuŒ+ñà
ˆt�EŒ{Ô
ñð Ô
ñð Œ+ñ	ð
 Ô
ñð Œ.ñð Œ+ñð Ô
ñ ð ñ	ð{ð �T‰zð{ð ”. 4¨¬Ô#7Ñ7¸$Ñ>ð{ð ”l TÑ)ð{ð  Ô)¨DÑ0ð!{ð" ð#{ð$ �d‘
ð%{ð& ˜X cœ]Ñ*¨UÔ-BÑBð'{ð( ˜X cœ]Ñ*ð){ð*  ™ð+{ð, Ô)¨DÑ0ð-{ð. Ô*¨TÑ1ð/{ð0 "Ô2°TÑ9ð1{ð2 �t‘ð3{ð4 ð5{ð6 
Ô	ð7{ð {ð {ð {ðB 59Ø"ð-ð -àð-ð ˜5Ô-Ô.ð-ð Ô*¨TÑ1ð	-ð
 �t‘ð-ð ð-ð 
ˆeÔ!Ô	"ð-ð -ð -ð -ðx Ø ØAEØ,0Ø37ØØØEIØ-2Ø(,Ø8<Ø37Ø48Ø<@Ø"ð7B'ð B'àðB'ð ðB'ð Œ}Ø
ˆuŒ+ñà
ˆt�EŒ{Ô
ñð Ô
ñð Œ+ñ	ð
 Ô
ñð Œ.ñð Œ+ñð Ô
ñ ð ñ	ð	B'ð �T‰zðB'ð ”. 4¨¬Ô#7Ñ7¸$Ñ>ðB'ð  ”l TÑ)ð!B'ð" Ô)¨DÑ0ð#B'ð$ ð%B'ð& ð'B'ð( ˜X cœ]Ñ*¨UÔ-BÑBð)B'ð* ˜X cœ]Ñ*ð+B'ð,  ™ð-B'ð. Ô.°Ñ5ð/B'ð0 Ô)¨DÑ0ð1B'ð2 Ô*¨TÑ1ð3B'ð4 "Ô2°TÑ9ð5B'ð6 �t‘ð7B'ð8 ð9B'ð: 
Ô	ð;B'ð B'ð B'ð B'ðN -1ØØØ Ø48Ø<@Ø"ð6$ð 6$àð6$ð ”l TÑ)ð6$ð ð	6$ð
 ð6$ð �T‰zð6$ð Ô*¨TÑ1ð6$ð "Ô2°TÑ9ð6$ð �t‘ð6$ð ð6$ð 
Ô	(ð6$ð 6$ð 6$ð 6$ðv -1ØØØ Ø48Ø<@Ø"ð6$ð 6$àð6$ð ”l TÑ)ð6$ð ð	6$ð
 ð6$ð �T‰zð6$ð Ô*¨TÑ1ð6$ð "Ô2°TÑ9ð6$ð �t‘ð6$ð ð6$ð 
Ô	*ð6$ð 6$ð 6$ð 6$ðv .2ØØ)-Ø'+ØEIØ-2Ø48Ø<@Ø"ðXHð XHàðXHð ”| dÑ*ðXHð ð	XHð
 ”- $Ñ&ðXHð ” Ñ$ðXHð ˜X cœ]Ñ*¨UÔ-BÑBðXHð ˜X cœ]Ñ*ðXHð Ô*¨TÑ1ðXHð "Ô2°TÑ9ðXHð �t‘ðXHð ðXHð 
ˆt�E”LÔ! 5¤=°4Ñ#7Ð7Ô	8ðXHð XHð XHð XHðz -1ØØ<@Ø"Ø48ð/ð /àð/ð ”l TÑ)ð/ð ð	/ð
 "Ô2°TÑ9ð/ð �t‘ð/ð Ô*¨TÑ1ð/ð ð/ð 
Ô	ð/ð /ð /ð /ðj -1ØØØ"Ø48Ø<@ð9ð 9àð9ð ð9ð ”l TÑ)ð	9ð
 ð9ð ð9ð �t‘ð9ð Ô*¨TÑ1ð9ð "Ô2°TÑ9ð9ð ð9ð 
Ô	ð9ð 9ð 9ð 9ð~ Ø/3Ø<@Ø-1Ø/3Ø"ðhð hàðhð ”ðhð ð	hð
 Ô%¨Ñ,ðhð "Ô2°TÑ9ðhð ”| dÑ*ðhð Ô%¨Ñ,ðhð �t‘ðhð ðhð 
Ô	ðhð hð hð hð\ Ø/3Ø<@Ø-1Ø"ð3ð 3àð3ð ˜Ô+Ô,ð3ð ð	3ð
 Ô%¨Ñ,ð3ð "Ô2°TÑ9ð3ð ”| dÑ*ð3ð �t‘ð3ð ð3ð 
Ô	ð3ð 3ð 3ð 3ðt Ø/3Ø<@Ø"ð5ð 5àð5ð ˜#”ð5ð Ô$ð	5ð
 ð5ð Ô%¨Ñ,ð5ð "Ô2°TÑ9ð5ð �t‘ð5ð ð5ð 
Ô	ð5ð 5ð 5ð 5ðv FJØ-2Ø48Ø<@Ø"ðFð FàðFð �e”mÔ$ðFð ˜X cœ]Ñ*¨UÔ-BÑBð	Fð
 ˜X cœ]Ñ*ðFð Ô*¨TÑ1ðFð "Ô2°TÑ9ðFð �t‘ðFð ðFð 
ˆeŒlÔ	ðFð Fð Fð FðP ð3ØÔ)ð3à	ˆtÔ" DÔ$9¸DÑ$@Ð@Ô	Að3ð 3ð 3ñ „[ð3ðB ð!àÔ$ð!ð "Ô2°TÑ9ð!ð 
Ô	ð	!ð !ð !ñ „[ð!ðF ðØ"Ô1ðà	ˆdŒlÔ	ðð ð ñ „[ðð ð ØÔ)ð à	ˆt�FÔ*Ô+¨dÑ2°F´MÀDÑ4HÐHÔ	Ið ð  ð  ñ „[ð ðB Ø/3Ø<@Ø"ð/ð /àð/ð Ô-ð/ð ð	/ð
 Ô%¨Ñ,ð/ð "Ô2°TÑ9ð/ð �t‘ð/ð ð/ð 
Ô	ð/ð /ð /ð /ðl ØØ/3Ø<@Ø"ð5ð 5àð5ð ”ð5ð Ô$ð	5ð
 �4‰Zð5ð ð5ð Ô%¨Ñ,ð5ð "Ô2°TÑ9ð5ð �t‘ð5ð ð5ð 
Ô	ð5ð 5ð 5ð 5ðx Ø/3Ø<@Ø"ð2ð 2àð2ð ”ð2ð Ô$ð	2ð
 ð2ð Ô%¨Ñ,ð2ð "Ô2°TÑ9ð2ð �t‘ð2ð ð2ð 
Ô	ð2ð 2ð 2ð 2ðr Ø/3Ø<@Ø"ð1ð 1àð1ð �sŒmð1ð Ô$ð	1ð
 ð1ð Ô%¨Ñ,ð1ð "Ô2°TÑ9ð1ð �t‘ð1ð ð1ð 
Ô	ð1ð 1ð 1ð 1ðn Ø/3Ø<@Ø"ð/ð /àð/ð Ô-ð/ð ð	/ð
 Ô%¨Ñ,ð/ð "Ô2°TÑ9ð/ð �t‘ð/ð ð/ð 
Ô	ð/ð /ð /ð /ðj Ø/3Ø"ð'ð 'àð'ð $ EÔ$9Ô:ð'ð ð	'ð
 Ô%¨Ñ,ð'ð �t‘ð'ð ð'ð 
ˆeÔ Ô	!ð'ð 'ð 'ð 'ðX #ð&ð &à#+¨EÔ,AÔ#Bð&ð �t‘ð&ð ð	&ð
 
ð&ð &ð &ð &ðPØ"ðØ.1ðà	Ô	)ðð ð ð ð( Cð ¨EÔ,Lð ð ð ð ð ¨ð °Ô0Ið ð ð ð ð$¨cð ¸Sð ÀUÔEYð ð ð ð ð°ð Àð Èð ð ð ð ð  @DØ?CØ9=Ø37ØCGØ"ØOSØ<@Ø)-ðYð YàðYð !Ô5¸Ñ<ðYð !Ô5¸Ñ<ð	Yð
 Ô/°$Ñ6ðYð Ô)¨DÑ0ðYð #Ô9¸DÑ@ðYð �t‘ðYð  ' s¨EÔ,DÐ'DÔEÈÑLðYð "Ô2°TÑ9ðYð ”- $Ñ&ðYð ðYð 
ðYð Yð Yð Yðx ;?ðð Ø"ðØ-0°4©ZðØJMðà	ðð ð ð ð$ X\Ø#'Ø)-Ø/3Ø'+Ø37Ø?CØ15Ø?CØ"ØOSØ7;Ø<@Ø)-Ø59ð#pð pàðpð Ô*¨W°S¸%Ô:LÐ5LÔ-MÑMÐPTÑTðpð ˜D‘jð	pð
   $™Jðpð #&¨¡*ðpð  ™ðpð Ô)¨DÑ0ðpð !Ô5¸Ñ<ðpð Ô'¨$Ñ.ðpð #Ô5¸Ñ<ðpð �t‘ðpð  ' s¨EÔ,DÐ'DÔEÈÑLðpð Ô-°Ñ4ðpð "Ô2°TÑ9ðpð  ”- $Ñ&ð!pð" Ô+¨dÑ2ð#pð$ ð%pð& 
ð'pð pð pð pð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ð#'
ð$ ð%'
ð& 
ð''
ð '
ð '
ð '
ðR ð%  \Ô 2ð %ð %ð %ñ „Xð%ð Ø!ØØ<@Ø-1Ø/3ð8ð 8à"ð8ð ð8ð ð	8ð
 ð8ð �d‘
ð8ð ð8ð "Ô2°TÑ9ð8ð ”| dÑ*ð8ð Ô%¨Ñ,ð8ð 
ð8ð 8ð 8ð 8ð| ØØ!ØØØ<@Ø-1Ø/3ð
ð 
àð
ð ˜Ô*Ô+ð
ð ð	
ð
 ð
ð �d‘
ð
ð ð
ð ð
ð "Ô2°TÑ9ð
ð ”| dÑ*ð
ð Ô%¨Ñ,ð
ð ð
ð 
ð
ð 
ð 
ð 
ðD 48Ø.2ØØØ!ØØØ<@Ø-1Ø/3ð!
ð !
àð!
ð �c˜5Ô+Ð+Ô,¨uÔ/?Ñ?À(È5ÔK]ÔB^Ñ^ð!
ð ˜$˜s C˜xœ.Ô)¨DÑ0ð	!
ð
 �e”mÔ$ tÑ+ð!
ð ð!
ð ð!
ð �d‘
ð!
ð ð!
ð ð!
ð "Ô2°TÑ9ð!
ð ”| dÑ*ð!
ð Ô%¨Ñ,ð!
ð ð!
ð 
ð!
ð !
ð !
ð !
ðN 8<Ø59ØØ/3Ø"ðað aàðað ðað Ô-°Ñ4ð	að
 Ô+¨dÑ2ðað ðað Ô%¨Ñ,ðað �t‘ðað ðað 
Ô	ðað að að aðN Ø/3Ø"ðð àðð ðð ð	ð
 Ô%¨Ñ,ðð �t‘ðð ðð 
Ô	ðð ð ð ðH Ø/3Ø"ðFð FàðFð ðFð "Ô2ð	Fð
 ðFð Ô%¨Ñ,ðFð �t‘ðFð ðFð 
Ô	ðFð Fð Fð FðX Ø/3Ø"ð"ð "àð"ð ð"ð ð	"ð
 Ô%¨Ñ,ð"ð �t‘ð"ð ð"ð 
Ô	ð"ð "ð "ð "ðHØ"ðØ.1ðà	ˆeÔ'Ô	(ðð ð ð ð  26ðð Ø"ðØ*.ðØADðà	Ô	" TÑ	)ðð ð ð ð FJðð Ø"ðØ36ðØ>BðØUXðà	�‰ðð ð ð ð$
¨Cð 
°D¸Ô9RÔ4Sð 
ð 
ð 
ð 
ðXð X¨ð XÀð XÈÔHað Xð Xð Xð Xð 04ðð Ø ðØ(,ðØ?Bðà	�‰ðð ð ð ð$ #Ø#Ø26Øðð àðð ðð �t‘ð	ð
 ˜‘*ðð Ô(¨4Ñ/ðð ðð ðð 
�‰ðð ð ð ð*Ø"ðØ.1ðØ=@ðà	ˆeÔ'Ô	(ðð ð ð ð AEðð Ø"ðØ.1ðØ9=ðØPSðà	Ô	" TÑ	)ðð ð ð ð ðð àðð ðð ð	ð
 ðð ðð 
�‰ðð ð ð ð( #Ø#Ø26Øðð àðð ðð ð	ð
 �t‘ðð ˜‘*ðð Ô(¨4Ñ/ðð ðð ðð 
�‰ðð ð ð ð6 %)Ø)-Ø&*Ø37Ø"ð-ð -àð-ð ”>ð-ð ˜T‘zð	-ð
   $™Jð-ð ˜”9˜tÑ#ð-ð Ô)¨DÑ0ð-ð �t‘ð-ð ð-ð 
ð-ð -ð -ð -ðf #ð	ð àðð ”>ðð �t‘ð	ð
 ðð 
ðð ð ð ð@�eÔ'ð ð ð ð ð #ð	(ð (àð(ð !Ô2ð(ð �t‘ð	(ð
 ð(ð 
ð(ð (ð (ð (ðT Ô 3ð ð ð ð ð dð ð ð ð ð "Ø"ð	ð àðð �d‰{ðð �t‘ð	ð
 ðð 
ðð ð ð ð °sð ¸uÔ?Zð ð ð ð ð  '+ðð àðð ˜t™ðð ð	ð
 
Ô	$ðð ð ð ðàðð ðð 
Ô	 ð	ð ð ð ð4 %)Ø"ðð à˜T‘zðð �t‘ðð ð	ð
 
Ô	'ðð ð ð ð ð ð ð rM   r(   )@Ú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.client_baser   Ú"qdrant_client.common.version_checkr   r   Úqdrant_client.connectionr   Ú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      sŠ  ðØ Ð Ð Ð Ø €€€Ø €€€Ø 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø Ð Ð Ð Ð Ð ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð €€€Ø Ð Ð Ð Ð Ð Ø 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ø  Ð  Ð  Ð  Ð  Ð  à PÐ PÐ PÐ PÐ PÐ PÐ PÐ PØ &Ð &Ð &Ð &Ð &Ð &Ø 4Ð 4Ð 4Ð 4Ð 4Ð 4Ø )Ð )Ð )Ð )Ð )Ð )Ø 0Ð 0Ð 0Ð 0Ð 0Ð 0Ø PÐ PÐ PÐ PÐ PÐ PÐ PÐ PØ 0Ð 0Ð 0Ð 0Ð 0Ð 0Ø ;Ð ;Ð ;Ð ;Ð ;Ð ;Ø FÐ FÐ FÐ FÐ FÐ Fðð ð ð ð ð ð ð ð ð ð
 ;Ð :Ð :Ð :Ð :Ð :Ð :Ð :Ð :Ð :Ø AÐ AÐ AÐ AÐ AÐ AØ ?Ð ?Ð ?Ð ?Ð ?Ð ?Ø BÐ BÐ BÐ BÐ BÐ BØ BÐ BÐ BÐ BÐ BÐ BØ 8Ð 8Ð 8Ð 8Ð 8Ð 8ðt,ð t,ð t,ð t,ð t,�:ñ t,ô t,ð t,ð t,ð t,rM   