Ë
    BêñiÆº ã                   óv  — d dl Zd dlZd dlZd dlZd dlmZ d dlmZ d dl	m
Z
mZmZmZmZmZmZmZ d dlZd dlmZ d dlmZmZ d dlmZ d dlmZmZ d d	lmZ d d
lmZ d dl m!Z! d dl"m#Z# d dl$m%Z%m&Z& d dl'm(Z( d dl)m*Z+ d dl,m-Z- d dl.m/Z/m0Z0m1Z1 d dl2m3Z3m4Z4m5Z5 d dl6m7Z7 d dl8m9Z9 d dl:m;Z; d dl<m=Z=  G d„ de#«      Z>y)é    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)Ú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jB                  fd&„«       Z"edejF                  fd'„«       Z$ede%e&   fd(„«       Z'ede%e&   fd)„«       Z(	 	 	 	 	 	 	 	 	 	 	 	 	 	 d²d*ed+e)jT                  e+e   z  e+e+e      z  e)jX                  z  e)jZ                  z  e)j\                  z  e)j^                  z  e)j`                  z  e)jb                  z  dz  d,edz  d-e)jd                  e+e)jd                     z  dz  d.e)jf                  dz  d/e)jh                  dz  d0ed1edz  d2ee5e   z  e)jl                  z  d3ee5e   z  d4edz  d5e)jn                  dz  d6e)jp                  dz  d7e)jr                  dz  dedz  de	de)jt                  f"d8„Z;	 	 d³d*ed9e5e)jx                     d6e)jp                  dz  dedz  de	de+e)jt                     fd:„Z=	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d´d*ed;ed+e)jT                  e+e   z  e+e+e      z  e)jX                  z  e)jZ                  z  e)j\                  z  e)j^                  z  e)j`                  z  e)jb                  z  dz  d,edz  d-e)jd                  e+e)jd                     z  dz  d.e)jf                  dz  d/e)jh                  dz  d0ed<ed2ee5e   z  e)jl                  z  d3ee5e   z  d4edz  d=e)j|                  dz  d5e)jn                  dz  d6e)jp                  dz  d7e)jr                  dz  dedz  de	de)j~                  f&d>„Z@	 	 	 	 	 	 	 dµd*ed.e)jf                  dz  d0ed?ed,edz  d6e)jp                  dz  d7e)jr                  dz  dedz  de	de)j‚                  fd@„ZB	 	 	 	 	 	 	 dµd*ed.e)jf                  dz  d0ed?ed,edz  d6e)jp                  dz  d7e)jr                  dz  dedz  de	de)j†                  fdA„ZD	 	 	 	 	 	 	 	 	 d¶d*edBe)jf                  dz  d0edCe)jŠ                  dz  d1e)jT                  dz  d2ee5e   z  e)jl                  z  d3ee5e   z  d6e)jp                  dz  d7e)jr                  dz  dedz  de	dee+e)jŒ                     e)jT                  dz  f   fdD„ZG	 	 	 	 	 d·d*edEe)jf                  dz  dFed7e)jr                  dz  dedz  d6e)jp                  dz  de	de)j�                  fdG„ZI	 	 	 	 	 	 d¸d*edHedIe)jf                  dz  d0edFededz  d6e)jp                  dz  d7e)jr                  dz  de	de)j”                  fdJ„ZK	 	 	 	 	 	 d¹d*edKe)j˜                  dLedMe)jš                  dz  d7e)jr                  dz  dNe)jf                  dz  dOe)jœ                  dz  dedz  de	de)jž                  fdP„ZP	 	 	 	 	 dºd*edKe5e)j¢                     dLedMe)jš                  dz  d7e)jr                  dz  dNe)jf                  dz  dedz  de	de)jž                  fdQ„ZR	 	 	 	 d»d*edRe5e   dKe)j¦                  dLedMe)jš                  dz  d7e)jr                  dz  dedz  de	de)jž                  fdS„ZT	 	 	 	 	 d¼d*edTe5e)jT                     d2ee5e   z  e)jl                  z  d3ee5e   z  d6e)jp                  dz  d7e)jr                  dz  dedz  de	de+e)jŒ                     fdU„ZUeVdKe)j¦                  deej¦                  ejr                  dz  f   fdV„«       ZWeVdKe)j¦                  d7e)jr                  dz  deXj¦                  fdW„«       ZYeVdXej¦                  de+ejT                     fdY„«       ZZeVdKe)j¦                  dee+eXj¶                     dz  eXjf                  dz  f   fdZ„«       Z\	 	 	 	 d»d*edXe)j¦                  dLedMe)jš                  dz  d7e)jr                  dz  dedz  de	de)jž                  fd[„Z]	 	 	 	 	 d·d*ed\e)j¼                  dKe)j¦                  dHedz  dLedMe)jš                  dz  d7e)jr                  dz  dedz  de	de)jž                  fd]„Z_	 	 	 	 d»d*ed\e)j¼                  dKe)j¦                  dLedMe)jš                  dz  d7e)jr                  dz  dedz  de	de)jž                  fd^„Z`	 	 	 	 d»d*ed_e5e   dKe)j¦                  dLedMe)jš                  dz  d7e)jr                  dz  dedz  de	de)jž                  fd`„Za	 	 	 	 d»d*edXe)j¦                  dLedMe)jš                  dz  d7e)jr                  dz  dedz  de	de)jž                  fda„Zb	 	 	 d½d*edbe5e)jÆ                     dLedMe)jš                  dz  dedz  de	de+e)jž                     fdc„Zd	 d°dde5e)jÊ                     dedz  de	defde„Zfd*ede	de)jÎ                  fdf„Zhde	de)jÎ                  fdg„Zide	de)jÔ                  fdh„Zkd*ede	de)jØ                  fdi„Zmd*ede	defdj„Zn	 	 	 	 	 	 	 	 	 d¾d*edke)jÞ                  dz  dle)jà                  dz  dme)jâ                  dz  dne)jä                  dz  doe)jæ                  dz  dedz  dpetee)jê                  f   dz  dqe)jì                  dz  dre)j¼                  dz  de	defds„Zw	 d°d*ededz  de	defdt„Zx	 	 	 	 	 	 	 	 	 	 	 	 	 	 d¿d*edme)jò                  etee)jò                  f   z  dz  duedz  dvedz  dwedz  dxedz  dne)jä                  dz  dke)jÞ                  dz  dye)jô                  dz  doe)jö                  dz  dedz  dpetee)jê                  f   dz  dze)jø                  dz  dqe)jì                  dz  dre)j¼                  dz  de	def"d{„Z}	 	 	 	 	 	 	 	 	 	 	 	 	 	 d¿d*edme)jò                  etee)jò                  f   z  dz  duedz  dvedz  dwedz  dxedz  dne)jä                  dz  dke)jÞ                  dz  dye)jô                  dz  doe)jö                  dz  dedz  dpetee)jê                  f   dz  dze)jø                  dz  dqe)jì                  dz  dre)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  dLed7e)jr                  dz  dNe)jf                  dz  dOe)jœ                  dz  ddfd‚„Zƒ	 	 	 	 	 	 	 	 dÁd*edKe‚e)�j                     dƒed€ed�edz  dedLed7e)jr                  dz  dNe)jf                  dz  dOe)jœ                  dz  de	ddfd„„Z…	 	 	 	 	 	 	 	 	 	 dÂd*edReee)j\                  f   e)j\                  z  e‚e)�j                     z  d\e‚ee	e	f      dz  dTe‚e)jT                     dz  dƒed€ed�edz  dedLed7e)jr                  dz  dNe)jf                  dz  dOe)jœ                  dz  de	ddfd…„Z‡	 	 	 	 	 dÃd*ed†ed‡e)�j                  dz  dˆe)�j                  dz  dLedMe)jš                  dz  dedz  de	de)jž                  fd‰„Z‰	 	 	 d½d*ed†edLedMe)jš                  dz  dedz  de	de)jž                  fdŠ„ZŠd*ede	de+e)�j                     fd‹„ZŒ	 dÄd*edLede	de)�j                  dz  fdŒ„Z�	 dÄd*ed�edLede	dedz  f
dŽ„ZŽde	de+e)�j                     fd�„Z�dÄdLede	de)�j                  fd�„Z�	 dÄd�edLe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  dLe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dLede	de)�j                  dz  f
d˜„Z•	 dÄd*ed–ed�edLe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  dLede	dedz  fdš„Z—	 	 	 	 	 dÆd*ed›e)�j0                  dœedz  dvedz  d�e+e   dz  dže)�j2                  dz  dedz  de	defdŸ„Zš	 d°d*ed›e)�j0                  dedz  de	def
d „Z›de)�j8                  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)�jH                  fd©„Z¥	 d°d*edªedz  de	de)�jL                  fd«„Z§d*ede	de)�jP                  fd¬„Z©	 	 d³d­edz  dedz  de	de)�jT                  fd®„Z«ˆ xZ¬S )ÇÚQdrantRemoteé   é   NÚurlÚportÚ	grpc_portÚprefer_grpcÚhttpsÚapi_keyÚprefixÚtimeoutÚhostÚgrpc_optionsÚauth_token_providerÚcheck_compatibilityÚ	pool_sizeÚheadersÚkwargsc                 ó�  •— t        ‰!| �  d4i |¤Ž || _        || _        |
xs i | _        |�|n|d u| _        | j
                  rdnd| _        d | _        |�t        d|«      }|| _        |xs d| _	        t        | j                  «      dkD  r&| j                  d   dk7  rd| j                  › �| _	        |�|	�t        d|› d|	› �«      ‚|	�-|	j                  d	«      s|	j                  d
«      rt        d«      ‚|�r
|j                  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                  › �«      ‚|	xs d| _        || _        |�t)        j*                  |«      nd }|| _        || _        |j1                  dd «      }|€S| j                   dv rt3        j4                  d d¬«      }nJ| j                  �>t3        j4                  | j                  ¬«      }n| j                  �t        d|› d|› �«      ‚|j1                  dd«      }g | _        |j1                  di «      j9                  «       D ��ci c]  \  }}||“Œ
 c}}| _        |rD|j9                  «       D ]1  \  }}|| j:                  |<   | j6                  j=                  ||f«       Œ3 |�˜| j                  dk(  rt?        dt@        d¬«       tC        | j6                  D ��cg c]
  \  }}|dk(  ‘Œ c}}«      sd| j:                  v rtE        dt@        d¬«       || j:                  d<   | j6                  j=                  d|f«       tF        jH                  jK                  d «      }tM        jN                  «       }d!|› d"|› �}d#| j:                  v rtE        d$|› d%�«       |
�d&|
v rtE        d'|› d%�t@        d¬«       || j:                  d#<   || j                  d&<   |j1                  d(d «      }|�'tQ        |tR        «      stU        d)tW        |«      › �«      ‚|tR        jX                  k(  rt        d*«      ‚|| _-        | j"                  �| j                   › d+| j"                  › �n| j                   }| j                  › d,|› �}t]        || j                  «      | _/        | j:                  |d-œ|¥| _0        |�|| j`                  d<   |�|| j`                  d.<   || _1        n| jd                  | _1        | j.                  �E| j                  dk(  rt?        d/t@        d¬«       tg        | j.                  «      } | | j`                  d0<   ti        d4d1| j^                  i| j`                  ¤Ž| _5        g | _6        d | _7        d | _8        d | _9        d | _:        d| _;        d | _<        d | _=        d | _>        d | _?        d| _@        |rbtƒ        | j„                  | j^                  | j:                  | j`                  j‡                  d0«      | jb                  fd2¬3«      j‰                  «        y y c c}}w c c}}w )5Nr.   Ú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:   r.   zUnknown scheme: Úlimits)r>   z	127.0.0.1)Úmax_connectionsÚmax_keepalive_connections)r@   z>`pool_size` and `limits` are mutually exclusive. `pool_size`: z, `limit`: Úhttp2FÚmetadataz,Api key is used with an insecure connection.é   ©ÚmessageÚcategoryÚ
stacklevelzapi-keyz``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://)r7   rB   r1   z8Auth token provider is used with an insecure connection.Úauthr2   T)ÚtargetÚargsÚdaemon© )EÚsuperÚ__init__Ú_prefer_grpcÚ
_grpc_portÚ_grpc_optionsÚ_httpsÚ_schemeÚ
_pool_sizeÚmaxÚ_prefixÚlenÚ
ValueErrorÚ
startswithr   r2   r+   Ú_hostÚ_portÚschemeÚpathÚmathÚceilÚ_api_keyÚ_auth_token_providerÚpopÚhttpxÚLimitsÚ_grpc_headersÚitemsÚ_rest_headersÚappendr   ÚUserWarningÚanyr   Ú	importlibrC   ÚversionÚplatformÚpython_versionÚ
isinstancer   Ú	TypeErrorÚtypeÚDeflateÚ_grpc_compressionr   Úrest_uriÚ
_rest_argsÚ_timeoutÚDEFAULT_GRPC_TIMEOUTr   r    Úopenapi_clientÚ_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,   r-   r.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   Ú
parsed_urlrz   r?   rB   ÚkÚvÚkeyÚvalueÚheader_nameÚ_Úclient_versionrr   Ú
user_agentrJ   ÚaddressÚbase_urlÚbearer_authÚ	__class__s"                                    €ú]/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/qdrant_client/qdrant_remote.pyrR   zQdrantRemote.__init__1   sµ  ø€ ô$ 	‰ÑÑ"˜6Ò"Ø'ˆÔØ#ˆŒØ)Ò/¨RˆÔØ$Ð0‘e°gÀTÐ6IˆŒØ"&§+¢+‘w°6ˆŒð '+ˆŒàÐ Ü˜A˜yÓ)ˆIØ'ˆDŒOà’| ˆŒÜˆt�|‰|Ó˜qÒ  T§\¡\°!¡_¸Ò%;Ø˜tŸ|™|˜nÐ-ˆDŒLàˆ?˜tÐ/ÜÐJÈ3È%ÈzÐZ^ÐY_Ð`ÓaÐaàÐ §¡°Ô!;¸t¿¹ÈzÔ?ZÜð6óð ò
 Ø�~‰~˜kÔ*ð ˜3˜%�j�ä'¨›nˆJØ%/§_¡_°j·o±oÐ"ˆDŒJ˜œ
à× Ò Ø(×/Ñ/°7Ñ:�”Ø)×0Ñ0�”à'+§z¢z˜Ÿš°tˆDŒJà�|Š| 
§¢Ü ðØ!˜U ,¨z¯©Ð.?ðAóð ð —’Ø)Ÿ™�”à�|‰|Ð#4Ñ4Ü Ð#3°D·L±L°>Ð!BÓCÐCàÒ, ˆDŒJØˆDŒJð #*Ð"5ŒD�I‰I�gÔ¸4ð 	ð  ˆŒØ$7ˆÔ!à—‘˜H dÓ+ˆØˆ>Ø�z‰zÐ7Ñ7ô Ÿ™°dÐVWÔX‘Ø—‘Ð,äŸ™°d·o±oÔF‘Ø�_‰_Ð(Üð Ø )˜{¨+°f°Xð?óð ð
 —
‘
˜7 EÓ*ˆØˆÔØ/5¯z©z¸*ÀbÓ/I×/OÑ/OÓ/Q×R¡t q¨!˜a ™dÓRˆÔáØ%Ÿm™m›oò 8‘
��UØ*/�×"Ñ" 3Ñ'Ø×"Ñ"×)Ñ)¨3°¨,Õ7ð8ð ÐØ�|‰|˜vÒ%ÜØJÜ(Ø õô ÀD×DVÑDV×W±.°+¸q�[ IÓ-ÓWÔXØ × 2Ñ 2Ñ2ä!ð&ä(Ø õ	ð -4ˆD×Ñ˜yÑ)Ø×Ñ×%Ñ% y°'Ð&:Ô;ä"×+Ñ+×3Ñ3°OÓDˆÜ!×0Ñ0Ó2ˆØ% nÐ%5°X¸nÐ=MÐNˆ
Ø˜4×-Ñ-Ñ-ÜðBØBLÀÈRðQôð
 Ð#Ð(AÀ\Ñ(QÜØ^Ð_iÐ^jÐjlÐmÜ$Øõð
 ,6ˆ×Ñ˜<Ñ(Ø8Bˆ×ÑÐ4Ñ5ð 06¯z©zÐ:LÈdÓ/SÐØÐ'´
Ð;KÌ[Ô0YÜð5Ü59Ð:JÓ5KÐ4LðNóð ð œ{×2Ñ2Ò2ÜØxóð ð "2ˆÔà26·*±*Ð2H�T—Z‘Z�L  $§*¡* Ñ.ÈdÏjÉjˆØ—l‘l�^ 3 w iÐ0ˆÜ ¨$¯,©,Ó7ˆŒà&*×&8Ñ&8À5ÑSÈFÐSˆŒàÐØ(.ˆD�O‰O˜HÑ%àÐØ)1ˆD�O‰O˜IÑ&Ø$ˆD�Mà ×5Ñ5ˆDŒMà×$Ñ$Ð0Ø�|‰|˜vÒ%ÜØVÜ(Ø õô % T×%>Ñ%>Ó?ˆKØ&1ˆD�O‰O˜FÑ#ä3;ñ 4
Ø—‘ð4
à�o‰oñ4
ˆÔð
 79ˆÔØFJˆÔ%ØPTˆÔ*ØLPˆÔ(ØDHˆÔ#Ø,-ˆÔ$à?CˆÔ$ØIMˆÔ)ØEIˆÔ'Ø=AˆÔ"à"ˆŒáÜØ×0Ñ0à—M‘MØ×&Ñ&Ø—O‘O×'Ñ'¨Ó/Ø—M‘Mð	ð ô	÷ ‰e�gð ùóS Sùó" Xs   Ë;Z<Î[
rx   Úrest_headersrL   Úreturnc                 ó  — 	 t         j                  j                  d«      }t        | |||«      }|st	        dt
        d¬«       y t        ||«      st	        d|› d|› d�t
        d¬«       y y # t        $ r t	        dt
        d¬«       Y y w xY w)NrI   z‚Failed to obtain server version. Unable to check client-server compatibility. Set check_compatibility=False to skip version check.é   rE   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.)ro   rC   rp   r   r   rm   r   Ú	Exception)rx   rš   rL   r1   r“   Úserver_versions         r™   rˆ   z!QdrantRemote._check_compatibility  s«   € ð	Ü&×/Ñ/×7Ñ7¸ÓHˆNÜ/°¸,ÈÈgÓVˆNá!ÜðLä(Ø ö	ô # >°>ÔBÜØ4°^Ð4Dð EØ-Ð.ð /^ð^ô )Ø öð Cøô ò 	ÜðHä$Ø÷	ð	ús   ‚AA+ Á%A+ Á+B	ÂB	c                 ó   — | j                   S ©N)r‡   ©r‹   s    r™   ÚclosedzQdrantRemote.closed'  s   € à�|‰|Ðó    Ú
grpc_gracec                 óf  — t        | d«      r:t        | j                  «      dkD  r"| j                  D ]  }	 |j                  «        Œ 	 | j                  j                  «        d| _	        y # t        $ r t        dt        d¬«       Y ŒVw xY w# t        $ r t        dt        d¬«       Y d| _	        y w xY w)Nr}   r   zKUnable to close grpc_channel. Connection was interrupted on the server siderD   rE   zNUnable to close http connection. Connection was interrupted on the server sideT)
Úhasattrr[   r}   ÚcloseÚAttributeErrorr   ÚRuntimeWarningr|   rž   r‡   )r‹   r¥   r8   Úchannels       r™   r¨   zQdrantRemote.close+  s¯   € Ü�4Ð-Ô.´3°t×7NÑ7NÓ3OÐRSÒ3SØ×2Ñ2ò �ðØ—M‘M•Oðð	Ø×Ñ×%Ñ%Ô'ð ˆ�øô! &ò Ü Ø mÜ!/Ø#$÷ðûô ò 	ÜØhÜ'Øöð ˆ�ð	ús#   µA*ÁB Á*BÂBÂB0Â/B0c                 óŠ   — t        | «      }|j                  |j                  |j                  |j                  f\  }}}}||||fS r¡   )r   r`   r2   r+   ra   )r*   Úparse_resultr`   r2   r+   r0   s         r™   Ú
_parse_urlzQdrantRemote._parse_urlB  sP   € ä% c›Nˆà×ÑØ×ÑØ×ÑØ×Ñð	&
Ñ"ˆ��d˜Fð �t˜T 6Ð)Ð)r¤   c                 óJ   — | 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.
        )rX   ÚDEFAULT_GRPC_POOL_SIZEr¢   s    r™   Ú_get_grpc_pool_sizez QdrantRemote._get_grpc_pool_sizeM  s$   € ð �?‰?Ð&Ø—?‘?Ð"à×.Ñ.Ð.r¤   c           
      óÄ  — | j                   rt        d«      ‚	 g }t        | j                  «      dk(  r�t	        | j                  «       «      D ]k  }t        | j                  | j                  | j                  | j                  | j                  | j                  | j                  ¬«      }|j                  |«       Œm || _        y y # t        $ r}t        d|› �«      ‚d }~ww xY w)Nz=Client was closed. Please create a new QdrantClient instance.r   )r2   r+   ÚsslrC   ÚoptionsÚcompressionr4   z+Error initializing the grpc connection(s): )r‡   ÚRuntimeErrorr[   r}   Úranger±   r   r^   rT   rV   ri   rU   rw   re   rl   rž   )r‹   Úchannel_poolr’   r«   Úes        r™   Ú_init_grpc_channelzQdrantRemote._init_grpc_channelY  sÛ   € Ø�<Š<ÜÐ^Ó_Ð_ð	RØˆLä�4×*Ñ*Ó+¨qÒ0Ü˜t×7Ñ7Ó9Ó:ò 1�AÜ)Ø!ŸZ™ZØ!Ÿ_™_Ø ŸK™KØ!%×!3Ñ!3Ø $× 2Ñ 2Ø$(×$:Ñ$:ð -1×,EÑ,Eô
�Gð !×'Ñ'¨Õ0ð1ð +7�Õ'ð! 1øô" ò 	RÜÐ!LÈQÈCÐPÓQÐQûð	Rús   ™B(C Ã	CÃCÃCc                 ó’   — | j                  «        | j                  D �cg c]  }t        j                  |«      ‘Œ c}| _        y c c}w r¡   )rº   r}   r   Ú
PointsStubr~   ©r‹   r«   s     r™   Ú_init_grpc_points_clientz%QdrantRemote._init_grpc_points_clientt  s:   € Ø×ÑÔ!à48×4KÑ4Kö)
Ø)0ŒD�O‰O˜GÕ$ò)
ˆÕ%ùò )
ó   ŸAc                 ó’   — | j                  «        | j                  D �cg c]  }t        j                  |«      ‘Œ c}| _        y c c}w r¡   )rº   r}   r   ÚCollectionsStubr   r½   s     r™   Ú_init_grpc_collections_clientz*QdrantRemote._init_grpc_collections_clientz  s<   € Ø×ÑÔ!à9=×9PÑ9Pö.
Ø.5ŒD× Ñ  Õ)ò.
ˆÕ*ùò .
r¿   c                 ó’   — | j                  «        | j                  D �cg c]  }t        j                  |«      ‘Œ c}| _        y c c}w r¡   )rº   r}   r   ÚSnapshotsStubr€   r½   s     r™   Ú_init_grpc_snapshots_clientz(QdrantRemote._init_grpc_snapshots_client€  s<   € Ø×ÑÔ!à7;×7NÑ7Nö,
Ø,3ŒD×Ñ˜wÕ'ò,
ˆÕ(ùò ,
r¿   c                 ó’   — | j                  «        | j                  D �cg c]  }t        j                  |«      ‘Œ c}| _        y c c}w r¡   )rº   r}   r   Ú
QdrantStubr�   r½   s     r™   Ú_init_grpc_root_clientz#QdrantRemote._init_grpc_root_client†  s:   € Ø×ÑÔ!à48×4KÑ4Kö'
Ø)0ŒD�O‰O˜GÕ$ò'
ˆÕ#ùò '
r¿   c                 óh   — | j                   }| j                   dz   | j                  «       z  | _         |S )Nr;   )r‚   r±   )r‹   Úcurrent_indexs     r™   Ú_next_grpc_clientzQdrantRemote._next_grpc_clientŒ  s9   € Ø×4Ñ4ˆà×(Ñ(¨1Ñ,Ø×$Ñ$Ó&ñ('ˆÔ$ð Ðr¤   c                 ó�   — | j                   €| j                  «        | 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    r™   Úgrpc_collectionszQdrantRemote.grpc_collections“  sH   € ð ×-Ñ-Ð5Ø×.Ñ.Ô0Ø×1Ñ1Ð=Ð=Ð=Ø×1Ñ1°$×2HÑ2HÓ2JÑKÐKr¤   c                 ó�   — | j                   €| j                  «        | 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    r™   Úgrpc_pointszQdrantRemote.grpc_pointsŸ  sH   € ð ×(Ñ(Ð0Ø×)Ñ)Ô+Ø×,Ñ,Ð8Ð8Ð8Ø×,Ñ,¨T×-CÑ-CÓ-EÑFÐFr¤   c                 ó�   — | j                   €| j                  «        | 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    r™   Úgrpc_snapshotszQdrantRemote.grpc_snapshots«  sH   € ð ×+Ñ+Ð3Ø×,Ñ,Ô.Ø×/Ñ/Ð;Ð;Ð;Ø×/Ñ/°×0FÑ0FÓ0HÑIÐIr¤   c                 ó�   — | j                   €| j                  «        | 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    r™   Ú	grpc_rootzQdrantRemote.grpc_root·  sH   € ð ×&Ñ&Ð.Ø×'Ñ'Ô)Ø×*Ñ*Ð6Ð6Ð6Ø×*Ñ*¨4×+AÑ+AÓ+CÑDÐDr¤   c                 ó   — | j                   S ©ztREST Client

        Returns:
            An instance of raw REST API client, generated from OpenAPI schema
        ©r|   r¢   s    r™   ÚrestzQdrantRemote.restÃ  ó   € ð ×"Ñ"Ð"r¤   c                 ó   — | j                   S rÕ   rÖ   r¢   s    r™   r:   zQdrantRemote.httpÌ  rØ   r¤   Úcollection_nameÚqueryÚusingÚprefetchÚquery_filterÚsearch_paramsÚlimitÚoffsetÚwith_payloadÚwith_vectorsÚscore_thresholdÚlookup_fromÚconsistencyÚshard_key_selectorc                 ó�  — | j                   �r’|�t        j                  |«      }t        |t        j
                  «      rt        j                  |«      g}t        |t        «      r>|D �cg c]3  }t        |t        j
                  «      rt        j                  |«      n|‘Œ5 }}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.                  j1                  t3        j4                  |||||||
|	|||||||¬«      |�|n| j6                  ¬«      }|j8                  D �cg c]  }t;        j<                  |«      ‘Œ }}t	        j>                  |¬«      S t        |t2        j                  «      rt;        j                  |¬«      }t        |t2        j                  «      rt;        j                  |«      }t        |	t2        j@                  «      rt;        jB                  |	«      }	t        |t2        j"                  «      rt;        j$                  |«      }t	        jD                  ||||||||||
|	|¬«      }| jF                  jH                  jK                  ||||¬«      }|j8                  }|€J d«       ‚|S c c}w c c}w )N©Úmodel)rÚ   rÛ   rÝ   Úfilterrà   rá   rã   râ   Úparamsrä   rÜ   rå   r1   rç   Úread_consistency©r1   ©Úpoints)Ú	shard_keyrÝ   rÛ   rÜ   rë   rì   rä   rà   rá   Úwith_vectorrâ   rå   )rÚ   ræ   r1   Úquery_requestzSearch returned None)&rS   r   Úconvert_queryrs   r!   ÚPrefetchÚconvert_prefetch_queryÚ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   ÚQueryPointsrz   Úresultr   Úconvert_scored_pointÚQueryResponseÚ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ç   r1   r8   ÚpÚresÚhitÚscored_pointsró   Úquery_resultr  s                           r™   r  zQdrantRemote.query_pointsÕ  s6  € ð8 ×ÓØÐ Ü"×0Ñ0°Ó7�ä˜(¤F§O¡OÔ4Ü&×=Ñ=¸hÓGÐH�ä˜(¤DÔ)ð &öàô =GÀqÌ&Ï/É/Ô<Z”J×5Ñ5°aÔ8Ð`aÑað�ð ô
 ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�ä˜-¬×)<Ñ)<Ô=Ü *× @Ñ @ÀÓ O�ä˜,Ô(;¼F×<WÑ<WÓ(XÔYÜ)×HÑHÈÓV�ä˜,Ô(;¼F×<MÑ<MÓ(NÔOÜ)×>Ñ>¸|ÓL�ä˜+¤v×'<Ñ'<Ô=Ü(×@Ñ@ÀÓM�ä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"à&*×&6Ñ&6×&<Ñ&<Ü× Ñ Ø$3ØØ%Ø'ØØ!Ø!-Ø!-Ø(Ø$3ØØ +Ø#Ø'9Ø%0ôð" $+Ð#6™¸D¿M¹Mð% '=ó 'ˆCð* NQÏZÉZÖXÀcœZ×<Ñ<¸SÕAÐXˆMÐXÜ×'Ñ'¨}Ô=Ð=ô ˜,¬¯©Ô4Ü)×8Ñ8¸|ÔL�ä˜-¬×):Ñ):Ô;Ü *× @Ñ @ÀÓ O�ä˜,¬×(@Ñ(@ÔAÜ)×GÑGÈÓU�ä˜+¤t×':Ñ':Ô;Ü(×@Ñ@ÀÓM�ä"×/Ñ/Ø,Ø!ØØØ#Ø$Ø /ØØØ(Ø)Ø'ôˆMð  Ÿ9™9×/Ñ/×<Ñ<Ø /Ø'ØØ+ð	 =ó ˆLð 3?×2EÑ2EˆFØÐ%Ð=Ð'=Ó=Ð%ØˆMùòoùò^ Ys   Á)8N>É,OÚrequestsc                 ó  — | j                   �r|D �cg c]4  }t        |t        j                  «      rt	        j
                  ||«      n|‘Œ6 }}t        |t        t        j                  «      «      rt	        j                  |«      }| j                  j                  t        j                  ||||¬«      |�|n| j                  ¬«      }|j                  D ��cg c]C  }t        j                  |j                  D �cg c]  }t!        j"                  |«      ‘Œ c}¬«      ‘ŒE c}}S | j$                  j&                  j)                  |||t        j*                  |¬«      ¬«      j                  }	|	€J d«       ‚|	S c c}w c c}w c c}}w )N)rÚ   r  rí   r1   rî   rï   )Úsearches)rÚ   ræ   r1   Úquery_request_batchzQuery batch returned None)rS   rs   r!   r  r   Úconvert_query_requestr   r  r  rÏ   Ú
QueryBatchr   ÚQueryBatchPointsrz   r  r
  r   r	  r:   r  Úquery_batch_pointsÚQueryRequestBatch)
r‹   rÚ   r  ræ   r1   r8   ÚrÚgrpc_resr  Úhttp_ress
             r™   r  zQdrantRemote.query_batch_pointsR  s{  € ð ×Óð "öð ô " !¤V×%8Ñ%8Ô9ô ×4Ñ4°Q¸ÔHàñðˆHð ô ˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�à04×0@Ñ0@×0KÑ0KÜ×%Ñ%Ø$3Ø!)Ø%0Ø#ô	ð $+Ð#6™¸D¿M¹Mð 1Ló 1ˆHð "Ÿ™÷	ð ô ×$Ñ$ØLMÏHÉHÖUÀSœJ×;Ñ;¸CÕ@ÒUöóð ð ;?¿)¹)×:NÑ:N×:aÑ:aØ /Ø'ØÜ$*×$<Ñ$<ÀhÔ$Oð	 ;bó ;÷
 ‰fð ð Ð'ÐDÐ)DÓDÐ'ØˆOùòIùò0 Vùós   ’9E4Ã"E>Ã8E9Ä
E>Å9E>Úgroup_byÚ
group_sizeÚwith_lookupc                 ó.  — | j                   �ræ|�t        j                  |«      }t        |t        j
                  «      rt        j                  |«      g}t        |t        «      r>|D �cg c]3  }t        |t        j
                  «      rt        j                  |«      n|‘Œ5 }}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        j0                  |«      }t        |t        t        j2                  «      «      rt        j4                  |«      }| j6                  j9                  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        jB                  |«      S t        |t(        j                  «      rtA        j                  |¬«      }t        |t(        j                  «      rtA        j                  |«      }t        |
t(        jD                  «      rtA        jF                  |
«      }
t        |t(        j*                  «      rtA        j,                  |«      }t	        jH                  ||||||||||	||
||¬«      }| jJ                  jL                  jO                  ||||¬«      }|€J d«       ‚|j>                  S c c}w )Nré   )Ú
collectionrÚ   rÛ   rÝ   rë   rà   rã   râ   rì   rä   rÜ   r!  r"  r#  rå   r1   rç   rí   rî   )rñ   rÝ   rÛ   rÜ   rë   rì   rä   rà   r!  r"  rò   râ   r#  rå   )rÚ   ræ   r1   Úquery_groups_requestz%Query points groups API returned NonerP   )(rS   r   rô   rs   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ÚQueryPointGroupsrz   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ç   r1   r8   r  r  ró   r  s                          r™   r.  z QdrantRemote.query_points_groups�  sÈ  € ð< ×ÓØÐ Ü"×0Ñ0°Ó7�ä˜(¤F§O¡OÔ4Ü&×=Ñ=¸hÓGÐH�ä˜(¤DÔ)ð &öàô =GÀqÌ&Ï/É/Ô<Z”J×5Ñ5°aÔ8Ð`aÑað�ð ô
 ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�ä˜-¬×)<Ñ)<Ô=Ü *× @Ñ @ÀÓ O�ä˜,Ô(;¼F×<WÑ<WÓ(XÔYÜ)×HÑHÈÓV�ä˜,Ô(;¼F×<MÑ<MÓ(NÔOÜ)×>Ñ>¸|ÓL�ä˜+¤v×'8Ñ'8Ô9Ü(×<Ñ<¸[ÓI�ä˜+¤sÔ+Ü"Ÿo™o¸ÔE�ä˜+¤v×'<Ñ'<Ô=Ü(×@Ñ@ÀÓM�ä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"à/3×/?Ñ/?×/KÑ/KÜ×%Ñ%ò Ù$3ðáðñ &ðñ (ð	ñ
  ðñ ".ðñ ".ðñ )ðñ %4ðñ  ðñ &ðñ  *ðñ !,ðñ !,ðñ $ðñ  (:ð!ñ" &1ð#ð& $+Ð#6™¸D¿M¹Mð) 0Ló 0÷* ‰fð+ ô, ×3Ñ3°FÓ;Ð;ä˜,¬¯©Ô4Ü)×8Ñ8¸|ÔL�ä˜-¬×):Ñ):Ô;Ü *× @Ñ @ÀÓ O�ä˜,¬×(@Ñ(@ÔAÜ)×GÑGÈÓU�ä˜+¤t×':Ñ':Ô;Ü(×@Ñ@ÀÓM�ä"×5Ñ5Ø,Ø!ØØØ#Ø$Ø /ØØ!Ø%Ø(Ø)Ø'Ø'ôˆMð"  Ÿ9™9×/Ñ/×CÑCØ /Ø'ØØ%2ð	 Dó ˆLð  Ð+ÐTÐ-TÓTÐ+Ø×&Ñ&Ð&ùòys   Á)8PÚsamplec	                 ó2  — | j                   �rt        |t        j                  «      rt	        j
                  |¬«      }t        |t        t        j                  «      «      rt	        j                  |«      }t        |t        t        j                  «      «      rt	        j                  |«      }| j                  j                  t        j                  ||||||||¬«      |�|n| j                  ¬«      }
t!        j"                  |
j$                  «      S t        |t        j                  «      rt!        j
                  |¬«      }| j&                  j(                  j+                  |||t        j,                  |||||¬«      ¬«      j$                  }|€J d«       ‚|S )Nré   ©rÚ   rë   r/  rà   rÜ   r1   rí   rç   rî   ©rñ   rà   r/  rÜ   rë   ©rÚ   ræ   r1   Úsearch_matrix_requestz(Search matrix pairs returned None result)rS   rs   r!   rø   r   rù   r   r  r  r  r  rÏ   ÚSearchMatrixPairsr   ÚSearchMatrixPointsrz   r   Úconvert_search_matrix_pairsr  r|   r  Úsearch_matrix_pairsÚSearchMatrixRequest©r‹   rÚ   rÞ   rà   r/  rÜ   ræ   rç   r1   r8   ÚresponseÚsearch_matrix_results               r™   r8  z QdrantRemote.search_matrix_pairs  sl  € ð ×ÓÜ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�à×'Ñ'×9Ñ9Ü×'Ñ'Ø$3Ø'Ø!ØØØ#Ø%0Ø'9ô	ð $+Ð#6™¸D¿M¹Mð :ó ˆHô ×9Ñ9¸(¿/¹/ÓJÐJä�l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà#×2Ñ2×=Ñ=×QÑQØ+Ø#ØÜ"(×"<Ñ"<Ø,ØØØØ#ô#ð	  Ró  
÷ ‰&ð 	ð $Ð/Ð[Ð1[Ó[Ð/à#Ð#r¤   c	                 ó2  — | j                   �rt        |t        j                  «      rt	        j
                  |¬«      }t        |t        t        j                  «      «      rt	        j                  |«      }t        |t        t        j                  «      «      rt	        j                  |«      }| j                  j                  t        j                  ||||||||¬«      |�|n| j                  ¬«      }
t!        j"                  |
j$                  «      S t        |t        j                  «      rt!        j
                  |¬«      }| j&                  j(                  j+                  |||t        j,                  |||||¬«      ¬«      j$                  }|€J d«       ‚|S )Nré   r1  rî   r2  r3  z*Search matrix offsets returned None result)rS   rs   r!   rø   r   rù   r   r  r  r  r  rÏ   ÚSearchMatrixOffsetsr   r6  rz   r   Úconvert_search_matrix_offsetsr  r|   r  Úsearch_matrix_offsetsr9  r:  s               r™   r@  z"QdrantRemote.search_matrix_offsets=  sl  € ð ×ÓÜ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�à×'Ñ'×;Ñ;Ü×'Ñ'Ø$3Ø'Ø!ØØØ#Ø%0Ø'9ô	ð $+Ð#6™¸D¿M¹Mð <ó ˆHô ×;Ñ;¸H¿O¹OÓLÐLä�l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà#×2Ñ2×=Ñ=×SÑSØ+Ø#ØÜ"(×"<Ñ"<Ø,ØØØØ#ô#ð	  Tó  
÷ ‰&ð 	ð $Ð/Ð]Ð1]Ó]Ð/à#Ð#r¤   Ú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&                  j)                  t+        j,                  |||||||||	|
¬«
      |
�|
n| j.                  ¬«      }|j0                  D �cg c]  }t3        j4                  |«      ‘Œ c}|j7                  d«      r t3        j8                  |j:                  «      fS d fS t        |t*        j<                  «      rt3        j8                  |«      }t        |t*        j                  «      rt3        j                  |¬«      }t        |t*        j>                  «      rt3        j@                  |«      }t        |t*        jB                  «      rt3        jD                  |«      }| jF                  jH                  jK                  ||t        jL                  |||||||	¬«      |
¬«      j0                  }|€J d«       ‚|jN                  |j:                  fS c c}w )Nré   )
rÚ   rë   rB  rá   rã   râ   rà   rí   rç   r1   rî   Únext_page_offset)rë   rà   rB  rá   râ   rò   rñ   )rÚ   ræ   Úscroll_requestr1   z&Scroll points API returned None result)(rS   rs   r   r!   ÚExtendedPointIdr   Úconvert_extended_point_idrø   rù   rü   rý   rþ   rÿ   r  r  r  r  ÚOrderByInterfaceÚconvert_order_by_interfacerÏ   ÚScrollr   ÚScrollPointsrz   r  r   Úconvert_retrieved_pointÚHasFieldÚconvert_point_idrD  ÚPointIdÚOrderByÚconvert_order_byr  r  r|   Ú
points_apiÚscroll_pointsÚScrollRequestrð   )r‹   rÚ   rA  rà   rB  rá   râ   rã   ræ   rç   r1   r8   r  ÚpointÚscroll_results                  r™   ÚscrollzQdrantRemote.scrollu  sÏ  € ð ×ÓÜ˜&Ô"5´f×6LÑ6LÓ"MÔNÜ#×=Ñ=¸fÓE�ä˜-¬¯©Ô7Ü *× 9Ñ 9ÀÔ N�ä˜,Ô(;¼F×<WÑ<WÓ(XÔYÜ)×HÑHÈÓV�ä˜,Ô(;¼F×<MÑ<MÓ(NÔOÜ)×>Ñ>¸|ÓL�ä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä˜(Ô$7¼×8OÑ8OÓ$PÔQÜ%×@Ñ@ÀÓJ�à'+×'7Ñ'7×'>Ñ'>Ü×!Ñ!Ø$3Ø(Ø%Ø!Ø!-Ø!-ØØ%0Ø'9Ø#ôð $+Ð#6™¸D¿M¹Mð (?ó (ˆCð  LOÏ:É:ÖVÀ%”J×6Ñ6°uÕ=ÒVà—<‘<Ð 2Ô3ô ×+Ñ+¨C×,@Ñ,@ÓAðð ð ðð ô ˜&¤$§,¡,Ô/Ü#×4Ñ4°VÓ<�ä˜-¬¯©Ô5Ü *× 9Ñ 9ÀÔ N�ä˜(¤D§L¡LÔ1Ü%×6Ñ6°xÓ@�ä˜,¬×(@Ñ(@ÔAÜ)×GÑGÈÓU�ð ×#Ñ#×.Ñ.×<Ñ<Ø$3Ø +Ü#)×#7Ñ#7Ø,Ø#Ø!)Ø%Ø%1Ø$0Ø"4ô$ð $ð =ó ÷ ‘&ð ð  !Ð,ÐVÐ.VÓVÐ,à ×'Ñ'¨×)GÑ)GÐGÐGùòI Ws   Ç$M!Ú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                  j                  t        j                  ||||||¬«      |�|n| j                  ¬«      j                   }t#        j$                  |«      S t        |t        j                  «      rt#        j
                  |¬«      }| j&                  j(                  j+                  |t        j,                  |||¬«      ||¬«      j                   }	|	€J d«       ‚|	S )Nré   )rÚ   rë   rY  rç   r1   rí   rî   )rë   rY  rñ   )rÚ   Úcount_requestræ   r1   z!Count points returned None result)rS   rs   r!   rø   r   rù   r   r  r  r  r  rÏ   ÚCountr   ÚCountPointsrz   r  r   Úconvert_count_resultr|   rR  Úcount_pointsÚCountRequest)
r‹   rÚ   rX  rY  rç   r1   ræ   r8   r;  Úcount_results
             r™   ÚcountzQdrantRemote.countÏ  sh  € ð ×ÓÜ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�à×'Ñ'×-Ñ-Ü× Ñ Ø$3Ø'ØØ'9Ø#Ø%0ôð $+Ð#6™¸D¿M¹Mð .ó 
÷ ‰fð ô ×2Ñ2°8Ó<Ð<ä�l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà×*Ñ*×5Ñ5×BÑBØ+Ü ×-Ñ-Ø#ØØ,ôð
 $Øð Có 	
÷ ‰&ð 	ð Ð'ÐLÐ)LÓLÐ'ØÐr¤   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                  j                  t        j                  ||||||||¬«      |�|n| j                  ¬«      }
t!        j"                  |
j$                  D �cg c]  }t'        j(                  |«      ‘Œ c}¬«      S t        |t        j                  «      rt'        j
                  |¬«      }| j*                  j,                  j/                  |||t        j0                  |||||¬«      ¬«      j2                  }|€J d«       ‚|S c c}w )Nré   )rÚ   r�   rë   rà   rY  r1   rí   rç   rî   )Úhits)rñ   r�   rà   rë   rY  )rÚ   ræ   r1   Úfacet_requestz!Facet points returned None result)rS   rs   r!   rø   r   rù   r   r  r  r  r  rÏ   ÚFacetr   ÚFacetCountsrz   ÚtypesÚFacetResponsere  r   Úconvert_facet_value_hitr|   rR  ÚfacetÚFacetRequestr  )r‹   rÚ   r�   rc  rà   rY  r1   ræ   rç   r8   r;  r  Úfacet_results                r™   rl  zQdrantRemote.facet   sŽ  € ð ×ÓÜ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�à×'Ñ'×-Ñ-Ü× Ñ Ø$3ØØ'ØØØ#Ø%0Ø'9ô	ð $+Ð#6™¸D¿M¹Mð .ó ˆHô ×&Ñ&ØIQÏÉÖWÀ#”j×8Ñ8¸Õ=ÒWôð ô �l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà×*Ñ*×5Ñ5×;Ñ;Ø+Ø#ØÜ ×-Ñ-Ø,ØØØ#Øôð	 <ó 
÷ ‰&ð 	ð Ð'ÐLÐ)LÓLÐ'àÐùò) Xs   ÄF;rð   ÚwaitÚorderingÚupdate_filterÚupdate_modec	                 ó  — | j                   �r]t        |t        j                  «      rÅt	        j
                  |j                  t        |j                  «      «      }
t        t        |j                  «      «      D �cg c]k  }t        j                  t	        j                  |j                  |   «      |
|   |j                  �"t	        j                  |j                  |   «      nd ¬«      ‘Œm }}t        |t        «      r>|D �cg c]3  }t        |t        j                  «      rt	        j                   |«      n|‘Œ5 }}t        |t        j"                  «      rt	        j$                  |«      }t        |t'        t        j(                  «      «      rt	        j*                  |«      }t        |t        j,                  «      rt	        j.                  |¬«      }t        |t        j0                  «      rt	        j2                  |«      }| j4                  j7                  t        j8                  ||||||||¬«      | j:                  ¬«      j<                  }|€J d«       ‚t?        j@                  |«      S t        |t        j,                  «      rt?        j.                  |¬«      }t        |t        «      rW|D �cg c]3  }t        |t        j                  «      rt?        j                   |«      n|‘Œ5 }}t        jB                  ||||¬«      }t        |t        j                  «      rt        jD                  ||||¬«      }| jF                  jH                  jK                  |||||¬«      j<                  }|€J d«       ‚|S c c}w c c}w c c}w )	N)ÚidÚvectorsÚpayloadré   )rÚ   ro  rð   rp  rç   rq  r1   rr  rî   úUpsert returned None result)rð   rñ   rq  rr  )Úbatchrñ   rq  rr  )rÚ   ro  Úpoint_insert_operationsrp  r1   )&rS   rs   r!   ÚBatchr   Úconvert_batch_vector_structru  r[   Úidsr·   r   ÚPointStructrG  ÚpayloadsÚconvert_payloadr÷   Úconvert_point_structÚWriteOrderingÚconvert_write_orderingr   r  r  rø   rù   Ú
UpdateModeÚconvert_update_moderÏ   ÚUpsertÚUpsertPointsrz   r  r   Úconvert_update_resultÚ
PointsListÚPointsBatchr|   rR  Úupsert_points)r‹   rÚ   rð   ro  rp  rç   rq  rr  r1   r8   Úvectors_batchÚidxrU  Úgrpc_resultÚhttp_results                  r™   ÚupsertzQdrantRemote.upsert;  s/  € ð ×ÓÜ˜&¤&§,¡,Ô/Ü4>×4ZÑ4ZØ—N‘N¤C¨¯
©
£Oó5�ô  %¤S¨¯©£_Ó5öð ô ×$Ñ$Ü%×?Ñ?ÀÇ
Á
È3ÁÓPØ -¨cÑ 2ð  &Ÿ™Ð:ô '×6Ñ6°v·±ÀsÑ7KÔLà!%öð�ð ô ˜&¤$Ô'ð "(öð ô & e¬V×-?Ñ-?Ô@ô #×7Ñ7¸Ô>à"ñ#ð�ð ô ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä˜-¬¯©Ô7Ü *× 9Ñ 9ÀÔ N�ä˜+¤v×'8Ñ'8Ô9Ü(×<Ñ<¸[ÓI�à×*Ñ*×1Ñ1Ü×!Ñ!Ø$3ØØ!Ø%Ø'9Ø"/Ø#Ø +ô	ð Ÿ™ð 2ó ÷ ‰fð ð Ð*ÐIÐ,IÓIÐ*Ü×3Ñ3°KÓ@Ð@ä˜-¬¯©Ô5Ü *× 9Ñ 9ÀÔ N�ä˜&¤$Ô'ð "(öð ô & e¬T×-=Ñ-=Ô>ô #×7Ñ7¸Ô>à"ñ#ð�ð ô  ×*Ñ*Ø!Ø0Ø"/Ø +ô	�ô ˜&¤&§,¡,Ô/Ü×+Ñ+Ø Ø0Ø"/Ø +ô	�ð ×-Ñ-×8Ñ8×FÑFØ /ØØ(.Ø!Øð Gó ÷ ‰fð ð Ð*ÐIÐ,IÓIÐ*ØÐùòoùòùòTs   Á;A0M4Ä8M9Ê/8M>c                 ó^  — | j                   �r"|D �	cg c]  }	t        j                  |	«      ‘Œ }}	t        |t        j
                  «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        |t        j                  «      rt        j                  |¬«      }| j                  j                  t        j                  |||||||¬«      | j                   ¬«      j"                  }
|
€J d«       ‚t%        j&                  |
«      S t        |t        j                  «      rt%        j                  |¬«      }| j(                  j*                  j-                  ||t	        j                  |||¬«      ||¬«      j"                  S c c}	w )Nré   )rÚ   ro  rð   rp  rç   rq  r1   rî   rw  )rð   rñ   rq  )rÚ   ro  Úupdate_vectorsrp  r1   )rS   r   Úconvert_point_vectorsrs   r!   r�  r‚  r   r  r  rø   rù   rÏ   ÚUpdateVectorsr   ÚUpdatePointVectorsrz   r  r   r‡  r|   rR  r‘  )r‹   rÚ   rð   ro  rp  rç   rq  r1   r8   rU  r�  s              r™   r‘  zQdrantRemote.update_vectors¥  s}  € ð ×ÓØKQÖRÀ%”j×6Ñ6°uÕ=ÐRˆFÐRä˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä˜-¬¯©Ô7Ü *× 9Ñ 9ÀÔ N�à×*Ñ*×8Ñ8Ü×'Ñ'Ø$3ØØ!Ø%Ø'9Ø"/Ø#ôð Ÿ™ð 9ó ÷ ‰fð ð Ð*ÐIÐ,IÓIÐ*Ü×3Ñ3°KÓ@Ð@ä˜-¬¯©Ô5Ü *× 9Ñ 9ÀÔ N�à×&Ñ&×1Ñ1×@Ñ@Ø /ØÜ%×3Ñ3Ø!Ø0Ø"/ô ð
 "Øð Aó 
÷ ‰fð
ùò; Ss   ’F*ru  c                 óÞ  — | j                   rþ| j                  |«      \  }	}
|xs |
}t        |t        j                  «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }| j                  j                  t        j                  ||t        j                  |¬«      |	|||¬«      | j                  ¬«      j                   }|€J d«       ‚t#        j$                  |«      S | j'                  |«      \  }}| j(                  j*                  j-                  ||||t/        t        j                  ||||¬«      ¬«      j                   S )N)Únames)rÚ   ro  ru  Úpoints_selectorrp  rç   r1   rî   z#Delete vectors returned None result)Úvectorrð   rë   rñ   )rÚ   ro  rp  r1   Údelete_vectors)rS   Ú_try_argument_to_grpc_selectorrs   r!   r�  r   r‚  r   r  r  rÏ   ÚDeleteVectorsr   ÚDeletePointVectorsÚVectorsSelectorrz   r  r   r‡  Ú'_try_argument_to_rest_points_and_filterr|   rR  r™  r   )r‹   rÚ   ru  rð   ro  rp  rç   r1   r8   r—  Úopt_shard_key_selectorr�  Ú_pointsÚ_filters                 r™   r™  zQdrantRemote.delete_vectorsÚ  si  € ð ×ÒØ6:×6YÑ6YÐZ`Ó6aÑ3ˆOÐ3Ø!3Ò!MÐ7MÐä˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"à×*Ñ*×8Ñ8Ü×'Ñ'Ø$3ØÜ ×0Ñ0Ø%ôð %4Ø%Ø'9Ø#ô
ð Ÿ™ð 9ó ÷ ‰fð ð Ð*ÐQÐ,QÓQÐ*ä×3Ñ3°KÓ@Ð@à#×KÑKÈFÓSÑˆG�WØ×&Ñ&×1Ñ1×@Ñ@Ø /ØØ!ØÜ(Ü×(Ñ(Ø"Ø"Ø"Ø0ô ð Aó ÷ ‰fðr¤   r|  c                 ó¼  — | j                   �rt        |t        t        j                  «      «      rt        j                  |«      }|D �	cg c]<  }	t        |	t        t        j                  «      «      rt        j                  |	«      n|	‘Œ> }}	t        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }| j                  j                  t!        j"                  |||||||¬«      |�|n| j$                  ¬«      j&                  }
|
€J d«       ‚|
D �cg c]  }t)        j*                  |«      ‘Œ c}S t        |t         j,                  «      rt)        j.                  |«      }|D �	cg c]3  }	t        |	t         j0                  «      rt)        j2                  |	«      n|	‘Œ5 }}	| j4                  j6                  j9                  ||t        j:                  ||||¬«      |¬«      j&                  }|€J d«       ‚|S c c}	w c c}w c c}	w )N)rÚ   r|  râ   rã   rí   rç   r1   rî   zRetrieve returned None result)r|  râ   rò   rñ   )rÚ   ræ   Úpoint_requestr1   z!Retrieve API returned None result)rS   rs   r   r!   rü   r   rý   rF  rG  rÿ   r  r  r  r  rÏ   ÚGetr   Ú	GetPointsrz   r  r   rL  r  r  rO  rN  r|   rR  Ú
get_pointsÚPointRequest)r‹   rÚ   r|  râ   rã   ræ   rç   r1   r8   rŒ  r  ÚrecordrŽ  s                r™   ÚretrievezQdrantRemote.retrieve  sE  € ð ×ÓÜ˜,Ô(;¼F×<WÑ<WÓ(XÔYÜ)×HÑHÈÓV�ð öð ô " #Ô':¼6×;QÑ;QÓ'RÔSô ×8Ñ8¸Ô=àñðˆCð ô &×:Ñ:¸<ÓHˆLä˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"à×%Ñ%×)Ñ)Ü—‘Ø$3ØØ!-Ø!-Ø%0Ø'9Ø#ôð $+Ð#6™¸D¿M¹Mð *ó ÷ ‰fð ð Ð%ÐFÐ'FÓFÐ%àMSÖTÀ6”J×6Ñ6°vÕ>ÒTÐTô ˜,¬×(@Ñ(@ÔAÜ)×GÑGÈÓU�ð öàô 6@ÀÄTÇ\Á\Ô5R”×,Ñ,¨SÔ1ÐX[Ñ[ðˆCð ð
 ×-Ñ-×8Ñ8×CÑCØ /Ø'Ü$×1Ñ1ØØ!-Ø ,Ø0ô	ð  ð Dó 
÷ ‰fð ð Ð*ÐOÐ,OÓOÐ*ØÐùòoùò@ Uùòs   Á
AIÅ.IÇ 8Ic                 óT  — d }t        |t        «      rtt        j                  t        j                  |D �cg c]<  }t        |t        t        j                  «      «      rt        j                  |«      n|‘Œ> c}¬«      ¬«      }||fS t        |t        j                  «      r|}||fS t        |t        t        j                  «      «      rD|j                  �t        j                  |j                  «      }t        j                  |«      }||fS t        |t        j                  «      r2t        j                  t        t        j                   |¬«      «      }||fS t        |t        j                  «      rt        j                  |¬«      }||fS t#        dt%        |«      › �«      ‚c c}w )N)r|  rï   )rë   ú"Unsupported points selector type: )rs   r÷   r   ÚPointsSelectorÚPointsIdsListr   r!   rF  r   rG  r   rñ   r  Úconvert_points_selectorrø   r   ÚFilterSelectorr\   ru   )Úclsrð   rç   rŒ  r—  s        r™   rš  z+QdrantRemote._try_argument_to_grpc_selectorY  sŒ  € ð "ÐÜ�fœdÔ#Ü"×1Ñ1Ü×)Ñ)ð $*öð  ô  *¨#Ô/BÄ6×CYÑCYÓ/ZÔ[ô '×@Ñ@ÀÔEà!$ñ%òô	ôˆOð4 Ð 2Ð2Ð2ô ˜¤× 3Ñ 3Ô4Ø$ˆOð Ð 2Ð2Ð2ô ˜¤¬×)>Ñ)>Ó ?Ô@Ø×ÑÐ+Ü%/×%JÑ%JÈ6×K[ÑK[Ó%\Ð"Ü(×@Ñ@ÀÓHˆOð Ð 2Ð2Ð2ô ˜¤§¡Ô.Ü(×@Ñ@Üœ&×/Ñ/¸Ô?óˆOð Ð 2Ð2Ð2ô	 ˜¤§¡Ô,Ü"×1Ñ1¸Ô@ˆOð Ð 2Ð2Ð2ô ÐAÄ$ÀvÃ,ÀÐPÓQÐQùò/s   µAF%c                 óä  — t        |t        «      r\|D �cg c]3  }t        |t        j                  «      rt	        j
                  |«      n|‘Œ5 }}t        t        j                  ||¬«      }|S t        |t        j                  «      rt	        j                  |«      }||_        |S t        |t        t        j                  «      «      r|}||_        |S t        |t        j                  «      rt        t        j                  ||¬«      }|S t        |t        j                  «      r1t        t        j                  t	        j                  |«      |¬«      }|S t!        dt#        |«      › �«      ‚c c}w )N)rð   rñ   )rë   rñ   r«  )rs   r÷   r   rO  r   rN  r   r!   ÚPointIdsListr¬  r®  rñ   r   rø   r¯  rù   r\   ru   )r°  rð   rç   rŒ  r   r—  s         r™   Ú_try_argument_to_rest_selectorz+QdrantRemote._try_argument_to_rest_selector{  sW  € ô �fœdÔ#ð "öàô 6@ÀÄTÇ\Á\Ô5R”×,Ñ,¨SÔ1ÐX[Ñ[ðˆGð ô (Ü×#Ñ#ØØ,ôˆOð. Ðô% ˜¤× 3Ñ 3Ô4Ü(×@Ñ@ÀÓHˆOØ(:ˆOÔ%ð  Ðô ˜¤¬×)>Ñ)>Ó ?Ô@Ø$ˆOØ(:ˆOÔ%ð Ðô ˜¤§¡Ô.Ü'Ü×%Ñ%¨fÐ@RôˆOð Ðô ˜¤§¡Ô,Ü'Ü×%Ñ%Ü!×0Ñ0°Ó8Ø,ôˆOð Ðô ÐAÄ$ÀvÃ,ÀÐPÓQÐQùò5s   •8E-r—  c                 ó|   — |j                  d«      }|€g S t        ||«      }|dk(  rt        |j                  «      S g S )NÚpoints_selector_one_ofrð   )Ú
WhichOneofÚgetattrr÷   r|  )r°  r—  ÚnameÚvals       r™   Ú_points_selector_to_points_listz,QdrantRemote._points_selector_to_points_listŸ  sF   € ð ×)Ñ)Ð*BÓCˆØˆ<ØˆIä�o tÓ,ˆà�8ÒÜ˜Ÿ™“=Ð Øˆ	r¤   c                 ó:  — d }d }t        |t        «      rB|D �cg c]3  }t        |t        j                  «      rt	        j
                  |«      n|‘Œ5 }}||fS t        |t        j                  «      rit	        j                  |«      }t        |t        j                  «      r|j                  }||fS t        |t        j                  «      r|j                  }||fS t        |t        j                  «      r|j                  }||fS t        |t        j                  «      r|j                  }||fS t        |t        j                  «      r|}||fS t        |t        j                  «      rt	        j                  |«      }||fS t        dt!        |«      › �«      ‚c c}w )Nr«  )rs   r÷   r   rO  r   rN  r¬  r®  r!   r²  rð   r¯  rë   rø   rù   r\   ru   )r°  rð   r   r¡  rŒ  Úselectors         r™   rž  z4QdrantRemote._try_argument_to_rest_points_and_filter­  s�  € ð ˆØˆÜ�fœdÔ#ð "öàô 6@ÀÄTÇ\Á\Ô5R”×,Ñ,¨SÔ1ÐX[Ñ[ðˆGð ð* ˜ÐÐô# ˜¤× 3Ñ 3Ô4Ü!×9Ñ9¸&ÓAˆHÜ˜(¤F×$7Ñ$7Ô8Ø"Ÿ/™/�ð ˜ÐÐô ˜H¤f×&;Ñ&;Ô<Ø"Ÿ/™/�ð ˜ÐÐô ˜¤× 3Ñ 3Ô4Ø—m‘mˆGð ˜ÐÐô ˜¤× 5Ñ 5Ô6Ø—m‘mˆGð ˜ÐÐô ˜¤§¡Ô.ØˆGð ˜ÐÐô ˜¤§¡Ô,Ü ×/Ñ/°Ó7ˆGð ˜ÐÐô ÐAÄ$ÀvÃ,ÀÐPÓQÐQùò's   ™8Fc                 óx  — | j                   rÞ| j                  |«      \  }}|xs |}t        |t        j                  «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        j                  | j                  j                  t        j                  ||||||¬«      | j                   ¬«      j"                  «      S | j%                  ||«      }| j&                  j(                  j+                  |||||¬«      j"                  }	|	€J d«       ‚|	S )N©rÚ   ro  rð   rp  rç   r1   rî   )rÚ   ro  r—  rp  r1   zDelete points returned None)rS   rš  rs   r!   r�  r   r‚  r   r  r  r   r‡  rÏ   ÚDeleter   ÚDeletePointsrz   r  r³  r|   rR  Údelete_points©
r‹   rÚ   r—  ro  rp  rç   r1   r8   rŸ  r  s
             r™   ÚdeletezQdrantRemote.deleteË  sG  € ð ×ÒØ6:×6YÑ6YØó7Ñ3ˆOÐ3ð "4Ò!MÐ7MÐä˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä×3Ñ3Ø× Ñ ×'Ñ'Ü×%Ñ%Ø(7Ø!Ø.Ø!)Ø+=Ø 'ôð !ŸM™Mð (ó 
÷ ‘&óð ð #×AÑAØÐ!3óˆOð 15×0CÑ0C×0NÑ0N×0\Ñ0\Ø /ØØ /Ø!Øð 1]ó 1÷ ‰fð ð Ð%ÐDÐ'DÓDÐ%ØˆMr¤   rv  c	                 óÖ  — | j                   ró| j                  |«      \  }
}|xs |}t        |t        j                  «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        j                  | j                  j                  t        j                  ||t        j                   |«      |
||||¬«      | j"                  ¬«      j$                  «      S | j'                  |«      \  }}| j(                  j*                  j-                  ||||t        j                  |||||¬«      ¬«      j$                  }|€J d«       ‚|S )N)rÚ   ro  rv  r—  rp  rç   r�   r1   rî   )rv  rð   rë   rñ   r�   ©rÚ   ro  rp  r1   Úset_payloadzSet payload returned None)rS   rš  rs   r!   r�  r   r‚  r   r  r  r   r‡  rÏ   Ú
SetPayloadr   ÚSetPayloadPointsr  rz   r  rž  r|   rR  rÆ  )r‹   rÚ   rv  rð   r�   ro  rp  rç   r1   r8   r—  rŸ  r   r¡  r  s                  r™   rÆ  zQdrantRemote.set_payloadü  sk  € ð ×ÒØ6:×6YÑ6YÐZ`Ó6aÑ3ˆOÐ3Ø!3Ò!MÐ7MÐä˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä×3Ñ3Ø× Ñ ×+Ñ+Ü×)Ñ)Ø(7Ø!Ü *× :Ñ :¸7Ó CØ(7Ø!)Ø+=ØØ 'ô	ð !ŸM™Mð ,ó ÷ ‘&óð ð   $×KÑKÈFÓSÑˆG�WØ04×0CÑ0C×0NÑ0N×0ZÑ0ZØ /ØØ!ØÜ"×-Ñ-Ø#Ø"Ø"Ø0Øôð 1[ó 1÷ ‰fð ð Ð%ÐBÐ'BÓBÐ%ØˆMr¤   c                 óÒ  — | j                   rò| j                  |«      \  }	}
|xs |
}t        |t        j                  «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        j                  | j                  j                  t        j                  ||t        j                   |«      |	|||¬«      | j"                  ¬«      j$                  «      S | j'                  |«      \  }}| j(                  j*                  j-                  ||||t        j.                  ||||¬«      ¬«      j$                  }|€J d«       ‚|S )N)rÚ   ro  rv  r—  rp  rç   r1   rî   )rv  rð   rë   rñ   rÅ  zOverwrite payload returned None)rS   rš  rs   r!   r�  r   r‚  r   r  r  r   r‡  rÏ   ÚOverwritePayloadr   rÈ  r  rz   r  rž  r|   rR  Úoverwrite_payloadrÇ  )r‹   rÚ   rv  rð   ro  rp  rç   r1   r8   r—  rŸ  r   r¡  r  s                 r™   rË  zQdrantRemote.overwrite_payload3  se  € ð ×ÒØ6:×6YÑ6YÐZ`Ó6aÑ3ˆOÐ3Ø!3Ò!MÐ7MÐä˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä×3Ñ3Ø× Ñ ×1Ñ1Ü×)Ñ)Ø(7Ø!Ü *× :Ñ :¸7Ó CØ(7Ø!)Ø+=Ø 'ôð !ŸM™Mð 2ó ÷ ‘&óð ð  $×KÑKÈFÓSÑˆG�WØ04×0CÑ0C×0NÑ0N×0`Ñ0`Ø /ØØ!ØÜ"×-Ñ-Ø#Ø"Ø"Ø0ô	ð 1aó 1÷ ‰fð ð Ð%ÐHÐ'HÓHÐ%ØˆMr¤   Úkeysc                 ó¬  — | j                   rß| j                  |«      \  }	}
|xs |
}t        |t        j                  «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        j                  | j                  j                  t        j                  ||||	|||¬«      | j                   ¬«      j"                  «      S | j%                  |«      \  }}| j&                  j(                  j+                  ||||t        j                  ||||¬«      ¬«      j"                  }|€J d«       ‚|S )N)rÚ   ro  rÌ  r—  rp  rç   r1   rî   )rÌ  rð   rë   rñ   )rÚ   ro  rp  r1   Údelete_payloadzDelete payload returned None)rS   rš  rs   r!   r�  r   r‚  r   r  r  r   r‡  rÏ   ÚDeletePayloadr   ÚDeletePayloadPointsrz   r  rž  r|   rR  rÎ  )r‹   rÚ   rÌ  rð   ro  rp  rç   r1   r8   r—  rŸ  r   r¡  r  s                 r™   rÎ  zQdrantRemote.delete_payloadg  sZ  € ð ×ÒØ6:×6YÑ6YÐZ`Ó6aÑ3ˆOÐ3Ø!3Ò!MÐ7MÐÜ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä×3Ñ3Ø× Ñ ×.Ñ.Ü×,Ñ,Ø(7Ø!Ø!Ø(7Ø!)Ø+=Ø 'ôð !ŸM™Mð /ó ÷ ‘&óð ð  $×KÑKÈFÓSÑˆG�WØ04×0CÑ0C×0NÑ0N×0]Ñ0]Ø /ØØ!ØÜ%×3Ñ3ØØ"Ø"Ø0ô	 ð 1^ó 1÷ ‰fð ð Ð%ÐEÐ'EÓEÐ%ØˆMr¤   c                 óx  — | j                   rÞ| j                  |«      \  }}|xs |}t        |t        j                  «      rt        j                  |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        j                  | j                  j                  t        j                  ||||||¬«      | j                   ¬«      j"                  «      S | j%                  ||«      }| j&                  j(                  j+                  |||||¬«      j"                  }	|	€J d«       ‚|	S )Nr¾  rî   )rÚ   ro  rp  r1   r—  zClear payload returned None)rS   rš  rs   r!   r�  r   r‚  r   r  r  r   r‡  rÏ   ÚClearPayloadr   ÚClearPayloadPointsrz   r  r³  r|   rR  Úclear_payloadrÂ  s
             r™   rÔ  zQdrantRemote.clear_payloadš  sG  € ð ×ÒØ6:×6YÑ6YØó7Ñ3ˆOÐ3ð "4Ò!MÐ7MÐä˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�äÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"ä×3Ñ3Ø× Ñ ×-Ñ-Ü×+Ñ+Ø(7Ø!Ø.Ø!)Ø+=Ø 'ôð !ŸM™Mð .ó 
÷ ‘&óð ð #×AÑAØÐ!3óˆOð 15×0CÑ0C×0NÑ0N×0\Ñ0\Ø /ØØ!ØØ /ð 1]ó 1÷ ‰fð ð Ð%ÐDÐ'DÓDÐ%ØˆMr¤   Úupdate_operationsc           	      óJ  — | j                   r»|D �cg c]  }t        j                  |«      ‘Œ }}t        |t        j
                  «      rt        j                  |«      }| j                  j                  t        j                  |||||¬«      | j                  ¬«      j                  D �cg c]  }t        j                  |«      ‘Œ c}S | j                  j                   j#                  ||||t	        j$                  |¬«      ¬«      j                  }|€J d«       ‚|S c c}w c c}w )N)rÚ   ro  Ú
operationsrp  r1   rî   )r×  )rÚ   ro  rp  r1   rÕ  z!Batch update points returned None)rS   r   Úconvert_update_operationrs   r!   r�  r‚  rÏ   ÚUpdateBatchr   ÚUpdateBatchPointsrz   r  r   r‡  r|   rR  Úbatch_updateÚUpdateOperations)	r‹   rÚ   rÕ  ro  rp  r1   r8   Ú	operationr  s	            r™   Úbatch_update_pointsz QdrantRemote.batch_update_pointsË  s,  € ð ×ÒàPaö!ØCL”
×3Ñ3°IÕ>ð!Ðð !ô ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ð #×.Ñ.×:Ñ:Ü×*Ñ*Ø(7Ø!Ø#4Ø!)Ø 'ôð !ŸM™Mð ;ó 	÷ ‘&öàô ×0Ñ0°Õ8òð ð 7;×6IÑ6I×6TÑ6T×6aÑ6aØ /ØØ!ØÜ"(×"9Ñ"9ÐEVÔ"Wð 7bó 7÷ ‰fð ð Ð%ÐJÐ'JÓJÐ%ØˆMùò;!ùòs   ‘DÂ)D Úchange_aliases_operationsc                 óx  — | j                   r—|D �cg c]3  }t        |t        j                  «      st	        j
                  |«      n|‘Œ5 }}| j                  j                  t        j                  ||¬«      |�|¬«      j                  S | j                  ¬«      j                  S |D �cg c]3  }t        |t        j                  «      rt        j
                  |«      n|‘Œ5 }}| j                  j                  j                  |t        j                   |¬«      ¬«      j                  }|€J d«       ‚|S c c}w c c}w )N)r1   Úactionsrî   )rá  )r1   Úchange_aliases_operationzUpdate aliases returned None)rS   rs   r   ÚAliasOperationsr   Úconvert_alias_operationsrÍ   ÚUpdateAliasesÚChangeAliasesrz   r  r   r:   Úaliases_apiÚupdate_aliasesr!   ÚChangeAliasesOperation)r‹   rß  r1   r8   rÝ  râ  r  s          r™   Úupdate_collection_aliasesz&QdrantRemote.update_collection_aliasesô  sc  € ð ×Òð ";ö(ð ô & i´×1EÑ1EÔFô ×7Ñ7¸	ÔBà"ñ#ð(Ð$ð (ð ×(Ñ(×6Ñ6Ü×"Ñ"Ø#Ø4ôð $+Ð#6˜ð 7ó ÷ ‰fðð
 =A¿M¹Mð 7ó ÷ ‰fðð 7ö$
ð ô ˜i¬×)=Ñ)=Ô>ô ×3Ñ3°IÔ>àñð$
Ð ð $
ð #Ÿi™i×3Ñ3×BÑBØÜ%+×%BÑ%BØ0ô&ð Có 
÷
 ‰&ð 	ð Ð!ÐAÐ#AÓAÐ!Øˆùò?(ùò $
s   ‘8D2Â(8D7c                 ó’  — | j                   r|| j                  j                  t        j                  |¬«      | j
                  ¬«      j                  }t        j                  |D �cg c]  }t        j                  |«      ‘Œ c}¬«      S | j                  j                  j                  |¬«      j                  }|€J d«       ‚|S c c}w )N©rÚ   rî   ©Úaliasesz$Get collection aliases returned None)rS   rÍ   ÚListCollectionAliasesr   ÚListCollectionAliasesRequestrz   rî  ri  ÚCollectionsAliasesResponser   Úconvert_alias_descriptionr:   rç  Úget_collection_aliasesr  )r‹   rÚ   r8   r;  Údescriptionr  s         r™   ró  z#QdrantRemote.get_collection_aliases  sÁ   € ð ×ÒØ×,Ñ,×BÑBÜ×1Ñ1À/ÔRØŸ™ð Có ÷ ‰gð ô ×3Ñ3àYaöØJU”J×8Ñ8¸ÕEòôð ð �I‰I×!Ñ!×8Ñ8ÈÐ8ÓY×`Ñ`ð 	ð Ð!ÐIÐ#IÓIÐ!Øˆùòs   Á%Cc                 óŠ  — | j                   rz| j                  j                  t        j                  «       | j
                  ¬«      j                  }t        j                  |D �cg c]  }t        j                  |«      ‘Œ c}¬«      S | j                  j                  j                  «       j                  }|€J d«       ‚|S c c}w )Nrî   rí  zGet aliases returned None)rS   rÍ   ÚListAliasesr   ÚListAliasesRequestrz   rî  ri  rñ  r   rò  r:   rç  Úget_collections_aliasesr  ©r‹   r8   r;  rô  r  s        r™   Úget_aliaseszQdrantRemote.get_aliases0  s´   € Ø×ÒØ×,Ñ,×8Ñ8Ü×'Ñ'Ó)°4·=±=ð 9ó ç‰gð ô ×3Ñ3àYaöØJU”J×8Ñ8¸ÕEòôð ð �I‰I×!Ñ!×9Ñ9Ó;×BÑBð 	ð Ð!Ð>Ð#>Ó>Ð!Øˆùòó   Á#C c                 óŠ  — | j                   rz| j                  j                  t        j                  «       | j
                  ¬«      j                  }t        j                  |D �cg c]  }t        j                  |«      ‘Œ c}¬«      S | j                  j                  j                  «       j                  }|€J d«       ‚|S c c}w )Nrî   )ÚcollectionszGet collections returned None)rS   rÍ   ÚListr   ÚListCollectionsRequestrz   rý  ri  ÚCollectionsResponser   Úconvert_collection_descriptionr:   Úcollections_apiÚget_collectionsr  rù  s        r™   r  zQdrantRemote.get_collections@  s¹   € Ø×ÒØ×,Ñ,×1Ñ1Ü×+Ñ+Ó-°t·}±}ð 2ó ç‰kð ô ×,Ñ,ð (0öà#ô ×=Ñ=¸kÕJòôð ð �I‰I×%Ñ%×5Ñ5Ó7×>Ñ>ð 	ð Ð!ÐBÐ#BÓBÐ!Øˆùòrû  c                 ó@  — | j                   rXt        j                  | j                  j	                  t        j                  |¬«      | j                  ¬«      j                  «      S | j                  j                  j                  |¬«      j                  }|€J d«       ‚|S )Nrì  rî   zGet collection returned None)rS   r   Úconvert_collection_inforÍ   r¤  r   ÚGetCollectionInfoRequestrz   r  r:   r  Úget_collection©r‹   rÚ   r8   r  s       r™   r  zQdrantRemote.get_collectionR  s™   € Ø×ÒÜ×5Ñ5Ø×%Ñ%×)Ñ)Ü×1Ñ1À/ÔRØ ŸM™Mð *ó ÷ ‘&ó	ð ð /3¯i©i×.GÑ.G×.VÑ.VØ+ð /Wó /
ç
‰&ð 	ð Ð!ÐAÐ#AÓAÐ!Øˆr¤   c                 óB  — | j                   rO| j                  j                  t        j                  |¬«      | j
                  ¬«      j                  j                  S | j                  j                  j                  |¬«      j                  }|€J d«       ‚|j                  S )Nrì  rî   zCollection exists returned None)rS   rÍ   ÚCollectionExistsr   ÚCollectionExistsRequestrz   r  Úexistsr:   r  Úcollection_existsr  s       r™   r  zQdrantRemote.collection_exists`  s”   € Ø×ÒØ×(Ñ(×9Ñ9Ü×,Ñ,¸_ÔMØŸ™ð :ó ÷ ‰f—V‘Vðð
 59·I±I×4MÑ4M×4_Ñ4_Ø+ð 5`ó 5
ç
‰&ð 	ð Ð!ÐDÐ#DÓDÐ!Ø�}‰}Ðr¤   Úoptimizers_configÚcollection_paramsÚvectors_configÚhnsw_configÚquantization_configÚsparse_vectors_configÚstrict_mode_configrC   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&                  j)                  t+        j,                  ||||||||	||
¬«
      |�|¬«      j0                  S | j.                  ¬«      j0                  S t        |t*        j                  «      rt3        j
                  |«      }t        |t*        j                  «      rt3        j                  |«      }t        |t*        j4                  «      rt3        j                  |«      }t        |t*        j                  «      rt3        j                  |«      }t        |t*        j                  «      rt3        j                  |«      }| j6                  j8                  j;                  |t        j,                  |||||||	|
¬«      |¬«      j0                  }|€J d«       ‚|S )N)
rÚ   r  rì   r  r  r  r  r  r1   rC   rî   )r  rì   ru  r  r  Úsparse_vectorsr  rC   )Úupdate_collectionr1   zUpdate collection returned None)rS   rs   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   ÚUpdateCollectionrz   r  r   ÚVectorsConfigDiffr:   r  r  )r‹   rÚ   r  r  r  r  r  r1   r  r  rC   r8   r  s                r™   r  zQdrantRemote.update_collectionm  s®  € ð ×ÓÜÐ+¬V×-HÑ-HÔIÜ$.×$MÑ$MÐN_Ó$`Ð!äÐ+¬V×-HÑ-HÔIÜ$.×$MÑ$MÐN_Ó$`Ð!ä˜.¬$Ô/Ü!+×!GÑ!GÈÓ!W�ä˜+¤v×'<Ñ'<Ô=Ü(×AÑAÀ+ÓN�äÐ-¬x¼×8UÑ8UÓ/VÔWÜ&0×&QÑ&QØ'ó'Ð#ô Ð/´Ô6Ü(2×(OÑ(OØ)ó)Ð%ô Ð,¬f×.EÑ.EÔFÜ%/×%JÑ%JÐK]Ó%^Ð"ä˜(¤DÔ)Ü%×5Ñ5°hÓ?�à×(Ñ(×/Ñ/Ü×%Ñ%Ø$3Ø&7Ø,Ø#1Ø +Ø(;Ø*?Ø'9Ø#Ø%ôð $+Ð#6˜ð 0ó ÷ ‰fðð =A¿M¹Mð 0ó ÷ ‰fðô  Ð'¬×)BÑ)BÔCÜ *× IÑ IÐJ[Ó \ÐäÐ'¬×)BÑ)BÔCÜ *× IÑ IÐJ[Ó \Ðä�n¤d×&<Ñ&<Ô=Ü'×CÑCÀNÓSˆNä�k¤4×#6Ñ#6Ô7Ü$×=Ñ=¸kÓJˆKäÐ)¬4×+FÑ+FÔGÜ",×"MÑ"MÐNaÓ"bÐà"Ÿi™i×7Ñ7×IÑIØÜ$×5Ñ5Ø"3Ø(Ø&Ø'Ø$7Ø4Ø#5Ø!ô	ð ð Jó 
÷ ‰&ð 	ð Ð!ÐDÐ#DÓDÐ!Øˆr¤   c                 óD  — | j                   rY| j                  j                  t        j                  ||¬«      |�|¬«      j                  S | j
                  ¬«      j                  S | j                  j                  j                  ||¬«      j                  }|€J d«       ‚|S )N©rÚ   r1   rî   zDelete collection returned None)
rS   rÍ   r¿  r   ÚDeleteCollectionrz   r  r:   r  Údelete_collection)r‹   rÚ   r1   r8   r  s        r™   r+  zQdrantRemote.delete_collectionÈ  s¯   € ð ×ÒØ×(Ñ(×/Ñ/Ü×%Ñ%°oÈwÔWØ#*Ð#6˜ð 0ó ÷ ‰fðà<@¿M¹Mð 0ó ÷ ‰fðð
 #Ÿi™i×7Ñ7×IÑIØ Wð Jó 
ç
‰&ð 	ð Ð!ÐDÐ#DÓDÐ!Øˆr¤   Ú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-        j.                  |||	||||||||
||||¬«      }| j0                  j3                  || j4                  ¬«      j6                  S t        |t,        j                  «      rt9        j                  |«      }t        |t,        j                  «      rt9        j                  |«      }t        |	t,        j                  «      rt9        j                  |	«      }	t        |
t,        j                  «      rt9        j                  |
«      }
t        j.                  ||||||||	|
||||¬«      }| j:                  j<                  j?                  |||¬«      j6                  }|€J d«       ‚|S )N)rÚ   r  r0  r  r,  r/  r1   r  r-  r.  r  r  r1  r  rC   rî   )ru  r,  r-  r.  r/  r  r  r0  r  r  r1  r  rC   )rÚ   Úcreate_collectionr1   zCreate collection returned None) rS   rs   r!   ÚVectorParamsr  r   Úconvert_vectors_configr  r  r  r  ÚWalConfigDiffÚconvert_wal_config_diffr   ÚQuantizationConfigÚconvert_quantization_configr"  ÚShardingMethodÚconvert_sharding_methodr#  r$  r  r   ÚCreateCollectionrÍ   ÚCreaterz   r  r   r:   r  r3  )r‹   rÚ   r  r,  r-  r.  r/  r  r  r0  r  r1   r  r1  r  rC   r8   r3  Úcreate_collection_requestr  s                       r™   r3  zQdrantRemote.create_collection×  s³  € ð& ×ÓÜ˜.¬6×+>Ñ+>ÄÐ*EÔFÜ!+×!BÑ!BÀ>Ó!R�ä˜+¤v×'<Ñ'<Ô=Ü(×AÑAÀ+ÓN�äÐ+¬V×-HÑ-HÔIÜ$.×$MÑ$MÐN_Ó$`Ð!ä˜*¤f×&:Ñ&:Ô;Ü'×?Ñ?À
ÓK�
äØ#Üœ×2Ñ2Ó3ôô '1×&LÑ&LÐM`Ó&aÐ#äÐ/´Ô6Ü(2×(OÑ(OØ)ó)Ð%ô ˜/¬6×+@Ñ+@ÔAÜ",×"DÑ"DÀ_Ó"U�äÐ,¬f×.EÑ.EÔFÜ%/×%JÑ%JÐK]Ó%^Ð"ä˜(¤DÔ)Ü%×5Ñ5°hÓ?�ä $× 5Ñ 5Ø /Ø'Ø%Ø"3Ø)Ø /ØØ-Ø#5Ø)AØ$7Ø&;Ø /Ø#5Ø!ô!Ðð" ×(Ñ(×/Ñ/Ð0AÈ4Ï=É=Ð/ÓY×`Ñ`Ð`ä�k¤4×#6Ñ#6Ô7Ü$×=Ñ=¸kÓJˆKäÐ'¬×)BÑ)BÔCÜ *× IÑ IÐJ[Ó \Ðä�j¤$×"4Ñ"4Ô5Ü#×;Ñ;¸JÓGˆJäÐ)¬4×+BÑ+BÔCÜ",×"HÑ"HÐI\Ó"]Ðä$*×$;Ñ$;Ø"Ø%Ø1Ø%=Ø+Ø#Ø/Ø!Ø 3Ø0Ø+Ø1Øô%
Ð!ð  #Ÿi™i×7Ñ7×IÑIØ+Ø7Øð Jó 
÷ ‰&ð	 	ð Ð!ÐDÐ#DÓDÐ!Øˆr¤   c                 óh   — | j                  ||¬«       | j                  |||||||||	|
|||||¬«      S )Nrî   )rÚ   r  r,  r-  r.  r/  r  r  r0  r  r1   r  r1  r  rC   )r+  r3  )r‹   rÚ   r  r,  r-  r.  r/  r  r  r0  r  r1   r  r1  r  rC   r8   s                    r™   Úrecreate_collectionz QdrantRemote.recreate_collectionC  s\   € ð& 	×Ñ˜¸ÐÔ@à×%Ñ%Ø+Ø)Ø%Ø1Ø%=Ø+Ø#Ø/Ø!Ø 3ØØ"7Ø+Ø1Øð &ó 
ð 	
r¤   c                 ó2   — | j                   rt        S t        S r¡   )rS   r#   r$   r¢   s    r™   Ú_updater_classzQdrantRemote._updater_classj  s   € à×ÒÜ$Ð$ä$Ð$r¤   Úbatches_iteratorÚmax_retriesÚparallelÚmethodc
                 ó8  — |�(|t        «       v r|}
n)t        d|› dt        «       › �«      ‚dt        «       v rdnd}
| j                  rL|| j                  | j                  || j
                  | j                  ||| j                  | j                  ||	dœ}n || j                  |||||	dœ| j                  ¥}|dk(  r3 | j                  j                  d	i |¤Ž}|j                  |«      D ]  }Œ y t        || j                  |
¬«      } |j                  |fi |¤ŽD ]  }Œ y )
NzStart methods z& is not available, available methods: Ú
forkserverÚspawn)rÚ   r2   r+   rD  r³   rC   ro  rç   r´   r1   rq  rr  )rÚ   ÚurirD  ro  rç   rq  rr  r;   )Ústart_methodrP   )r   r\   rS   r^   rT   rV   ri   rU   rz   rx   ry   rB  rŠ   Úprocessr"   Úunordered_map)r‹   rC  rÚ   rD  rE  rF  ro  rç   rq  rr  rK  Úupdater_kwargsÚupdaterr’   Úpools                  r™   Ú_upload_collectionzQdrantRemote._upload_collectionq  sO  € ð ÐØÔ.Ó0Ñ0Ø%‘ä Ø$ V HÐ,RÔShÓSjÐRkÐlóð ð ,8Ô;PÓ;RÑ+R™<ÐX_ˆLà×Òà#2ØŸ
™
ØŸ™Ø*Ø—{‘{Ø ×.Ñ.ØØ&8Ø×-Ñ-ØŸ=™=Ø!.Ø*ñ‰Nð  $3Ø—}‘}Ø*ØØ&8Ø!.Ø*ñ	ð —/‘/ð	ˆNð �qŠ=Ø/�d×)Ñ)×/Ñ/ÑA°.ÑAˆGØ—_‘_Ð%5Ó6ò �Øñô & h°×0CÑ0CÐR^Ô_ˆDØ'�T×'Ñ'Ð(8ÑK¸NÑKò �Øñr¤   Ú
batch_sizec                 ór   — | j                   j                  ||¬«      }| j                  ||||||||	|
¬«	       y )N)ÚrecordsrR  ©	rC  rÚ   rD  rE  rF  ro  rç   rq  rr  )rB  Úiterate_records_batchesrQ  )r‹   rÚ   rð   rR  rE  rF  rD  ro  rç   rq  rr  r8   rC  s                r™   Úupload_pointszQdrantRemote.upload_points«  sV   € ð  ×.Ñ.×FÑFØ zð Gó 
Ðð 	×ÑØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 õ 
	
r¤   c                 óv   — | j                   j                  ||||¬«      }| j                  ||||||	|
||¬«	       y )N)ru  rv  r|  rR  rU  )rB  Úiterate_batchesrQ  )r‹   rÚ   ru  rv  r|  rR  rE  rF  rD  ro  rç   rq  rr  r8   rC  s                  r™   Úupload_collectionzQdrantRemote.upload_collectionÉ  s\   € ð   ×.Ñ.×>Ñ>ØØØØ!ð	 ?ó 
Ðð 	×ÑØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 õ 
	
r¤   Ú
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¿|}	|	j!                  d«      }
t#        |	|
«      }t        |t        j$                  «      rt        j&                  j(                  }t        |t        j*                  «      rt        j&                  j,                  }t        |t        j.                  «      rt        j&                  j0                  }t        |t        j2                  «      rt        j&                  j4                  }t        |t        j6                  «      rt        j&                  j8                  }t        |t        j:                  «      rt        j&                  j<                  }t        |t        j>                  «      rt        j&                  j@                  }t        |t        jB                  «      rt        j&                  jD                  }t        jF                  ||||	|||¬«      }tI        jJ                  | jL                  jO                  || jP                  ¬«      jR                  «      S t        |t        «      rtI        j                  |«      }t        |t        j                  «      rtI        j                  |«      }| jT                  jV                  jY                  |t	        jN                  ||¬«      |||¬	«      jR                  }|€J d
«       ‚|S )Nz2field_type is deprecated, use field_schema insteadr(   zpayload-index-field-type)rF   rG   rH   rŒ  Úindex_params)rÚ   r[  r]  Úfield_index_paramsro  rp  r1   rî   )r[  r\  )rÚ   Úcreate_field_indexro  rp  r1   z Create field index returned None)-r   ÚDeprecationWarningrS   rs   r!   ÚPayloadSchemaTyper   Úconvert_payload_schema_typer)  Ú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Ï   ÚCreateFieldIndexrz   r  r|   Úindexes_apira  )r‹   rÚ   r[  r\  r]  ro  rp  r1   r8   r`  r¸  r_  Úrequestr  s                 r™   Úcreate_payload_indexz!QdrantRemote.create_payload_indexì  sä  € ð Ð!ÜØLÜ+ØØ.õ	ð &ˆLà×ÓØ!%ÐÜ˜,¬×(@Ñ(@ÔAÜ)×EÑEÀlÓS�ä˜,¬Ô,Ü)×EÑEÜ×,Ñ,¨\Ó:ó �ô ˜,¬Ô,ô
  AÀÓN�ä˜,¬´×1KÑ1KÓ(LÔMÜ)×GÑGÈÓU�ä˜,¬×(?Ñ(?Õ@Ø%1Ð"Ø)×4Ñ4°^ÓD�Ü&Ð'9¸4Ó@�Ü˜l¬D×,@Ñ,@ÔAÜ#'§>¡>×#?Ñ#?�Lä˜l¬D×,CÑ,CÔDÜ#'§>¡>×#BÑ#B�Lä˜l¬D×,CÑ,CÔDÜ#'§>¡>×#BÑ#B�Lä˜l¬D×,AÑ,AÔBÜ#'§>¡>×#@Ñ#@�Lä˜l¬D×,?Ñ,?Ô@Ü#'§>¡>×#>Ñ#>�Lä˜l¬D×,@Ñ,@ÔAÜ#'§>¡>×#?Ñ#?�Lä˜l¬D×,DÑ,DÔEÜ#'§>¡>×#CÑ#C�Lä˜l¬D×,@Ñ,@ÔAÜ#'§>¡>×#?Ñ#?�Lä×5Ñ5Ø /Ø%Ø'Ø#5ØØ!ØôˆGô ×3Ñ3Ø× Ñ ×1Ñ1°'À4Ç=Á=Ð1ÓQ×XÑXóð ô �l¤CÔ(Ü%×AÑAÀ,ÓOˆLä�l¤D×$;Ñ$;Ô<Ü%×CÑCÀLÓQˆLà,0×,?Ñ,?×,KÑ,K×,^Ñ,^Ø+Ü%×6Ñ6Ø%°Lô ð ØØð -_ó -
÷ ‰&ð 	ð Ð!ÐEÐ#EÓEÐ!Øˆr¤   c                 óT  — | j                   r^t        j                  |||||¬«      }t        j                  | j
                  j                  || j                  ¬«      j                  «      S | j                  j                  j                  |||||¬«      j                  }|€J d«       ‚|S )N)rÚ   r[  ro  rp  r1   rî   z Delete field index returned None)rS   r   ÚDeleteFieldIndexCollectionr   r‡  rÏ   ÚDeleteFieldIndexrz   r  r|   r|  Údelete_field_index)	r‹   rÚ   r[  ro  rp  r1   r8   r}  r  s	            r™   Údelete_payload_indexz!QdrantRemote.delete_payload_indexO	  sº   € ð ×ÒÜ×5Ñ5Ø /Ø%ØØ!ØôˆGô ×3Ñ3Ø× Ñ ×1Ñ1°'À4Ç=Á=Ð1ÓQ×XÑXóð ð -1×,?Ñ,?×,KÑ,K×,^Ñ,^Ø+Ø!ØØØð -_ó -
÷ ‰&ð 	ð Ð!ÐEÐ#EÓEÐ!Øˆr¤   c                 ój  — | j                   rh| j                  j                  t        j                  |¬«      | j
                  ¬«      j                  }|D �cg c]  }t        j                  |«      ‘Œ c}S | j                  j                  j                  |¬«      j                  }|€J d«       ‚|S c c}w )Nrì  rî   ú'List snapshots API returned None result)rS   rÑ   rþ  r   ÚListSnapshotsRequestrz   Úsnapshot_descriptionsr   Úconvert_snapshot_descriptionr|   Úsnapshots_apiÚlist_snapshotsr  )r‹   rÚ   r8   Ú	snapshotsÚsnapshots        r™   rŠ  zQdrantRemote.list_snapshotsn	  sµ   € ð ×ÒØ×+Ñ+×0Ñ0Ü×)Ñ)¸/ÔJÐTX×TaÑTað 1ó ç#Ñ#ð ð W`Ö`È(”J×;Ñ;¸HÕEÒ`Ð`à×'Ñ'×5Ñ5×DÑDØ+ð Eó 
ç
‰&ð 	ð Ð$ÐOÐ&OÓOÐ$ØÐùò as   ÁB0c                 ó0  — | j                   rZ| j                  j                  t        j                  |¬«      | j
                  ¬«      j                  }t        j                  |«      S | j                  j                  j                  ||¬«      j                  S )Nrì  rî   )rÚ   ro  )rS   rÑ   r=  r   ÚCreateSnapshotRequestrz   Úsnapshot_descriptionr   rˆ  r|   r‰  Úcreate_snapshotr  )r‹   rÚ   ro  r8   rŒ  s        r™   r�  zQdrantRemote.create_snapshot}	  sŠ   € ð ×ÒØ×*Ñ*×1Ñ1Ü×*Ñ*¸?ÔKÐUY×UbÑUbð 2ó ç"Ñ"ð ô ×:Ñ:¸8ÓDÐDà×"Ñ"×0Ñ0×@Ñ@Ø+°$ð Aó 
ç
‰&ð	r¤   Úsnapshot_namec                 óø   — | j                   r=| j                  j                  t        j                  ||¬«      | j
                  ¬«       y| j                  j                  j                  |||¬«      j                  S )N)rÚ   r‘  rî   T)rÚ   r‘  ro  )
rS   rÑ   r¿  r   ÚDeleteSnapshotRequestrz   r|   r‰  Údelete_snapshotr  )r‹   rÚ   r‘  ro  r8   s        r™   r”  zQdrantRemote.delete_snapshotŠ	  s|   € ð ×ÒØ×Ñ×&Ñ&Ü×*Ñ*Ø$3À=ôð Ÿ™ð	 'ô ð à×"Ñ"×0Ñ0×@Ñ@Ø+Ø'Øð Aó 
÷ ‰&ð		r¤   c                 ób  — | j                   rf| j                  j                  t        j                  «       | j
                  ¬«      j                  }|D �cg c]  }t        j                  |«      ‘Œ c}S | j                  j                  j                  «       j                  }|€J d«       ‚|S c c}w )Nrî   z,List full snapshots API returned None result)rS   rÑ   ÚListFullr   ÚListFullSnapshotsRequestrz   r‡  r   rˆ  r|   r‰  Úlist_full_snapshotsr  )r‹   r8   r‹  rŒ  s       r™   r˜  z QdrantRemote.list_full_snapshotsœ	  s¢   € Ø×ÒØ×+Ñ+×4Ñ4Ü×-Ñ-Ó/ØŸ™ð 5ó ÷ $Ñ#ð ð W`Ö`È(”J×;Ñ;¸HÕEÒ`Ð`à×'Ñ'×5Ñ5×IÑIÓK×RÑRˆ	ØÐ$ÐTÐ&TÓTÐ$ØÐùò	 as   ÁB,c                 ó*  — | j                   rX| j                  j                  t        j                  «       | j
                  ¬«      j                  }t        j                  |«      S | j                  j                  j                  |¬«      j                  S )Nrî   )ro  )rS   rÑ   Ú
CreateFullr   ÚCreateFullSnapshotRequestrz   r�  r   rˆ  r|   r‰  Úcreate_full_snapshotr  )r‹   ro  r8   r�  s       r™   rœ  z!QdrantRemote.create_full_snapshot¨	  s|   € Ø×ÒØ#'×#6Ñ#6×#AÑ#AÜ×.Ñ.Ó0¸$¿-¹-ð $Bó $ç"Ñ"ð !ô ×:Ñ:Ð;OÓPÐPà×"Ñ"×0Ñ0×EÑEÈ4ÐEÓP×WÑWÐWr¤   c                 óô   — | j                   r<| j                  j                  t        j                  |¬«      | j
                  ¬«       y| j                  j                  j                  ||¬«      j                  S )N)r‘  rî   T)r‘  ro  )
rS   rÑ   Ú
DeleteFullr   ÚDeleteFullSnapshotRequestrz   r|   r‰  Údelete_full_snapshotr  )r‹   r‘  ro  r8   s       r™   r   z!QdrantRemote.delete_full_snapshot±	  so   € ð ×ÒØ×Ñ×*Ñ*Ü×.Ñ.¸]ÔKØŸ™ð +ô ð à×"Ñ"×0Ñ0×EÑEØ'¨dð Fó 
ç
‰&ð	r¤   ÚlocationÚchecksumÚpriorityc           
      ó”   — | j                   j                  j                  ||t        j                  ||||¬«      ¬«      j
                  S )N©r¡  r£  r¢  r/   )rÚ   ro  Úsnapshot_recover)r|   r‰  Úrecover_from_snapshotr!   ÚSnapshotRecoverr  )r‹   rÚ   r¡  r/   r¢  r£  ro  r8   s           r™   Úrecover_snapshotzQdrantRemote.recover_snapshot¿	  sP   € ð ×"Ñ"×0Ñ0×FÑFØ+ØÜ#×3Ñ3Ø!Ø!Ø!Øô	ð Gó 	
÷ ‰&ð		r¤   Úshard_idc                 óz   — | j                   j                  j                  ||¬«      j                  }|€J d«       ‚|S )N)rÚ   rª  r…  )r|   r‰  Úlist_shard_snapshotsr  )r‹   rÚ   rª  r8   r‹  s        r™   r¬  z!QdrantRemote.list_shard_snapshotsÔ	  sP   € ð ×'Ñ'×5Ñ5×JÑJØ+Øð Kó 
÷ ‰&ð 	ð Ð$ÐOÐ&OÓOÐ$ØÐr¤   c                 óf   — | j                   j                  j                  |||¬«      j                  S )N)rÚ   rª  ro  )r|   r‰  Úcreate_shard_snapshotr  )r‹   rÚ   rª  ro  r8   s        r™   r®  z"QdrantRemote.create_shard_snapshotÞ	  s9   € ð ×"Ñ"×0Ñ0×FÑFØ+ØØð Gó 
÷ ‰&ð		r¤   c                 óh   — | j                   j                  j                  ||||¬«      j                  S )N)rÚ   rª  r‘  ro  )r|   r‰  Údelete_shard_snapshotr  )r‹   rÚ   rª  r‘  ro  r8   s         r™   r°  z"QdrantRemote.delete_shard_snapshotç	  s<   € ð ×"Ñ"×0Ñ0×FÑFØ+ØØ'Øð	 Gó 
÷
 ‰&ð	r¤   c                 ó–   — | j                   j                  j                  |||t        j                  ||||¬«      ¬«      j
                  S )Nr¥  )rÚ   rª  ro  Úshard_snapshot_recover)r|   r‰  Úrecover_shard_from_snapshotr!   ÚShardSnapshotRecoverr  )	r‹   rÚ   rª  r¡  r/   r¢  r£  ro  r8   s	            r™   Úrecover_shard_snapshotz#QdrantRemote.recover_shard_snapshotö	  sS   € ð ×"Ñ"×0Ñ0×LÑLØ+ØØÜ#)×#>Ñ#>Ø!Ø!Ø!Øô	$ð	 Mó 

÷ ‰&ð
	r¤   rñ   Úshards_numberÚ	placementÚinitial_statec                 ó~  — | j                   rÝt        |t        t        j                  «      «      rt        j                  |«      }t        |t        j                  «      rt        j                  |«      }| j                  j                  t        j                  ||t        j                  ||||xs g |¬«      ¬«      |�|¬«      j                  S | j                  ¬«      j                  S | j                  j                   j#                  ||t        j$                  |||||¬«      ¬«      j                  }	|	€J d«       ‚|	S )N)rñ   r¶  r-  r·  r¸  ©rÚ   r1   r}  rî   )rÚ   r1   Úcreate_sharding_keyzCreate shard key returned None)rS   rs   r   r!   ÚShardKeyr   Úconvert_shard_keyÚReplicaStateÚconvert_replica_staterÍ   ÚCreateShardKeyr   ÚCreateShardKeyRequestrz   r  r|   Údistributed_apiÚcreate_shard_keyÚCreateShardingKey)
r‹   rÚ   rñ   r¶  r-  r·  r¸  r1   r8   r  s
             r™   rÃ  zQdrantRemote.create_shard_key
  s?  € ð ×ÒÜ˜)Ô%8¼¿¹Ó%IÔJÜ&×8Ñ8¸ÓC�	ä˜-¬×)<Ñ)<Ô=Ü *× @Ñ @ÀÓ O�à×(Ñ(×7Ñ7Ü×*Ñ*Ø$3Ø#Ü ×/Ñ/Ø"+Ø&3Ø+=Ø"+¢/¨rØ&3ôô
ð $+Ð#6˜ð 8ó ÷ ‰fðð =A¿M¹Mð 8ó ÷ ‰fðð ×(Ñ(×8Ñ8×IÑIØ /ØÜ$*×$<Ñ$<Ø'Ø"/Ø'9Ø'Ø"/ô%ð Jó 
÷ ‰fð ð Ð%ÐGÐ'GÓGÐ%ØˆMr¤   c           	      ó  — | j                   r¦t        |t        t        j                  «      «      rt        j                  |«      }| j                  j                  t        j                  ||t        j                  |¬«      ¬«      |�|¬«      j                  S | j                  ¬«      j                  S | j                  j                  j                  ||t        j                   |¬«      ¬«      j                  }|€J d«       ‚|S )N)rñ   rº  rî   )rÚ   r1   Údrop_sharding_keyzDelete shard key returned None)rS   rs   r   r!   r¼  r   r½  rÍ   ÚDeleteShardKeyr   ÚDeleteShardKeyRequestrz   r  r|   rÂ  Údelete_shard_keyÚDropShardingKey)r‹   rÚ   rñ   r1   r8   r  s         r™   rÉ  zQdrantRemote.delete_shard_key<
  s  € ð ×ÒÜ˜)Ô%8¼¿¹Ó%IÔJÜ&×8Ñ8¸ÓC�	à×(Ñ(×7Ñ7Ü×*Ñ*Ø$3Ø#Ü ×/Ñ/Ø"+ôôð $+Ð#6˜ð 8ó 	÷ ‰fð	ð =A¿M¹Mð 8ó 	÷ ‰fð	ð ×(Ñ(×8Ñ8×IÑIØ /ØÜ"(×"8Ñ"8Ø'ô#ð Jó ÷ ‰fð ð Ð%ÐGÐ'GÓGÐ%ØˆMr¤   c                 ó  — | j                   rN| j                  j                  t        j                  «       | j
                  ¬«      }t        j                  |«      S | j                  j                  j                  «       }|€J d«       ‚|S )Nrî   zHealthcheck returned None)rS   rÓ   ÚHealthCheckr   ÚHealthCheckRequestrz   r   Úconvert_health_check_replyr×   Úservice_apiÚroot)r‹   Úversion_infos     r™   ÚinfozQdrantRemote.info\
  sy   € Ø×ÒØŸ>™>×5Ñ5Ü×'Ñ'Ó)°4·=±=ð 6ó ˆLô ×8Ñ8¸ÓFÐFØ—y‘y×,Ñ,×1Ñ1Ó3ˆØÐ'ÐDÐ)DÓDÐ'ØÐr¤   Úcluster_operationc                 ó”  — | j                   �rt        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<   nnt        |t        j                  «      r||d<   nNt        |t        j                  «      r||d<   n.t        |t        j                  «      r||d<   nt        d	|› �«      ‚| j                  j                  t	        j                   d||d
œ|¤Ž|�|¬«      j$                  S | j"                  ¬«      j$                  S | j&                  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_operationsr1   z'Cluster collection update returned NonerP   )rS   r   Úconvert_cluster_operationsrs   r   Ú	MoveShardÚReplicateShardÚAbortShardTransferÚReplicarÀ  rÇ  ÚRestartTransferÚReplicatePointsrt   rÍ   ÚUpdateCollectionClusterSetupÚ#UpdateCollectionClusterSetupRequestrz   r  r×   rÂ  Úupdate_collection_cluster)r‹   rÚ   rÓ  r1   r8   Úgrpc_operationÚupdate_results          r™   Úcluster_collection_updatez&QdrantRemote.cluster_collection_updatef
  sÑ  € ð ×ÓÜ *× EÑ EÐFWÓ XÐØˆNäÐ+¬T¯^©^Ô<Ø/@�˜|Ò,ÜÐ-¬t×/BÑ/BÔCØ4E�Ð0Ò1ÜÐ-¬t×/FÑ/FÔGØ3D�Ð/Ò0ÜÐ-¬t¯|©|Ô<Ø1B�˜~Ò.ÜÐ-¬t×/BÑ/BÔCØ5F�Ð1Ò2ÜÐ-¬t×/BÑ/BÔCØ5F�Ð1Ò2ÜÐ-¬t×/CÑ/CÔDØ5F�Ð1Ò2ÜÐ-¬t×/CÑ/CÔDØ5F�Ð1Ò2äÐ"=Ð>OÐ=PÐ QÓRÐRà×(Ñ(×EÑEÜ×8Ñ8ð Ø$3¸WñØHVñð $+Ð#6˜ð	 Fó ÷
 ‰fðð =A¿M¹Mð	 Fó ÷
 ‰fðð Ÿ	™	×1Ñ1×KÑKØ+Ð@QÐ[bð Ló 
ç
‰&ð 	ð Ð(ÐSÐ*SÓSÐ(ØÐr¤   c                 ót   — | j                   j                  j                  «       j                  }|€J d«       ‚|S )NzCluster status returned None)r×   rÂ  Úcluster_statusr  )r‹   Ústatus_results     r™   rê  zQdrantRemote.cluster_status�
  s8   € àŸ	™	×1Ñ1×@Ñ@ÓB×IÑIˆØÐ(ÐHÐ*HÓHÐ(ØÐr¤   c                 ót   — | j                   j                  j                  «       j                  }|€J d«       ‚|S )Nz"Recover current peer returned None)r×   rÂ  Úrecover_current_peerr  )r‹   Úrecover_results     r™   rí  z!QdrantRemote.recover_current_peer–
  s8   € àŸ™×2Ñ2×GÑGÓI×PÑPˆØÐ)ÐOÐ+OÓOÐ)ØÐr¤   Úpeer_idÚforcec                 ó|   — | j                   j                  j                  |||¬«      j                  }|€J d«       ‚|S )N)rï  rð  r1   zRemove peer returned None)r×   rÂ  Úremove_peerr  )r‹   rï  rð  r1   r8   rç  s         r™   rò  zQdrantRemote.remove_peerœ
  sP   € ð Ÿ	™	×1Ñ1×=Ñ=ØØØð >ó 
÷ ‰&ð	 	ð
 Ð(ÐEÐ*EÓEÐ(ØÐr¤   c                 ó0  — | j                   rP| j                  j                  t        j                  |¬«      | j
                  ¬«      }t        j                  |«      S | j                  j                  j                  |¬«      j                  }|€J d«       ‚|S )Nrì  rî   z%Collection cluster info returned None)rS   rÍ   ÚCollectionClusterInfor   ÚCollectionClusterInfoRequestrz   r   Úconvert_collection_cluster_infor×   rÂ  Úcollection_cluster_infor  )r‹   rÚ   Úcollection_infos      r™   r÷  z$QdrantRemote.collection_cluster_info¬
  s”   € Ø×ÒØ"×3Ñ3×IÑIÜ×1Ñ1À/ÔRØŸ™ð Jó ˆOô ×=Ñ=¸oÓNÐNØŸ)™)×3Ñ3×KÑKØ+ð Ló 
ç
‰&ð 	ð Ð*ÐSÐ,SÓSÐ*ØÐr¤   Úcompleted_limitc                 óz   — | j                   j                  j                  ||¬«      j                  }|€J d«       ‚|S )N)rÚ   rù  zGet optimizations returned None)r:   r  Úget_optimizationsr  )r‹   rÚ   rù  r8   r  s        r™   rû  zQdrantRemote.get_optimizations¹
  sL   € ð —‘×*Ñ*×<Ñ<Ø+Ø+ð =ó 
÷ ‰&ð 	ð Ð!ÐDÐ#DÓDÐ!Øˆr¤   c           
      óÎ  — | j                   rš| j                  j                  t        j                  |¬«      | j
                  ¬«      }t        j                  |j                  D �cg c]5  }t        j                  t        j                  |j                  «      ¬«      ‘Œ7 c}¬«      S | j                  j                  j                  |¬«      j                   }|€J d«       ‚|S c c}w )Nrì  rî   )r�   )Ú
shard_keyszList shard keys returned None)rS   rÍ   ÚListShardKeysr   ÚListShardKeysRequestrz   r!   ÚShardKeysResponserý  ÚShardKeyDescriptionr   r½  r�   r×   rÂ  Úlist_shard_keysr  )r‹   rÚ   r8   r;  Úskr  s         r™   r  zQdrantRemote.list_shard_keysÇ
  sÙ   € ð
 ×ÒØ×,Ñ,×:Ñ:Ü×)Ñ)¸/ÔJØŸ™ð ;ó ˆHô ×+Ñ+ð
 '×1Ñ1ö	ð ô ×.Ñ.Ü&×8Ñ8¸¿¹Ó@öòôð ð —‘×*Ñ*×:Ñ:Ø+ð ;ó 
ç
‰&ð 	ð Ð!ÐBÐ#BÓBÐ!Øˆùòs   Á%:C"Údetails_levelc                 óz   — | j                   j                  j                  ||¬«      j                  }|€J d«       ‚|S )N)r  r1   zCluster telemetry returned None)r×   rÂ  Úcluster_telemetryr  )r‹   r  r1   r8   r  s        r™   r  zQdrantRemote.cluster_telemetryß
  sL   € ð —‘×*Ñ*×<Ñ<Ø'Øð =ó 
÷ ‰&ð 	ð Ð!ÐDÐ#DÓDÐ!Øˆr¤   )Ni½  i¾  FNNNNNNNTNNr¡   )r›   N)NNNNNé
   NTFNNNNN)NN)NNNNNr  r)   TFNNNNNN)Nr)   r  NNNN)	Nr  NNTFNNN)NTNNN)Nr  FNNN)TNNNNN)TNNNN)TNNN)TFNNN)TNN)	NNNNNNNNN)NNNNNNNNNNNNNN)r;   NFNNN)é@   r;   Nr)   FNNN)
NNr  r;   Nr)   FNNN)NNTNN)T)NNNT)NNNNN)­Ú__name__Ú
__module__Ú__qualname__r{   r°   r)  re  Úboolr  r   r   r   rR   Ústaticmethodrˆ   Úpropertyr£   Úfloatr¨   Útupler®   r±   rº   r¾   rÂ   rÅ   rÈ   rË   r   rÁ   rÍ   r¼   rÏ   rÄ   rÑ   rÇ   rÓ   r    r   r×   r:   ri  rO  r÷   ÚSparseVectorr  Ú
NumpyArrayÚDocumentÚImageÚInferenceObjectrõ   rø   rú   r
   ÚPayloadSelectorr   r  r  r
  r  r  r  ÚWithLookupInterfaceÚGroupsResultr.  ÚSearchMatrixPairsResponser8  ÚSearchMatrixOffsetsResponser@  rP  ÚRecordrW  ÚCountResultrb  rj  rl  ÚPointsr�  rƒ  ÚUpdateResultr�  ÚPointVectorsr‘  r¬  r™  r©  Úclassmethodrš  r!   r³  rº  rF  rž  rÃ  ÚPayloadrÆ  rË  rÎ  rÔ  ÚUpdateOperationrÞ  rã  rê  rñ  ró  rú  r   r  ÚCollectionInfor  r  r  r  r'  r  r   r	   ÚSparseVectorParamsr#  r  r+  r4  r6  r8  r:  r3  r@  r   r%   rB  r   rQ  r}  rW  ÚVectorStructrZ  rc  r~  rƒ  ÚSnapshotDescriptionrŠ  r�  r”  r˜  rœ  r   ÚSnapshotPriorityr©  r¬  r®  r°  rµ  r¼  r¾  rÃ  rÉ  ÚVersionInforÒ  ÚClusterOperationsrè  ÚClusterStatusrê  rí  rò  rô  r÷  ÚOptimizationsResponserû  r   r  ÚDistributedTelemetryDatar  Ú__classcell__)r˜   s   @r™   r'   r'   -   så  ø„ ØÐØÐð ØØØ!Ø!Ø"Ø!Ø"ØØ.2ØW[Ø$(Ø $Ø)-ñUà�4‰ZðUð �D‰jðUð ð	Uð
 ðUð �d‰{ðUð �t‘ðUð �d‘
ðUð �t‘ðUð �D‰jðUð ˜3 ˜8‘n tÑ+ðUð & b¨# gÑ.°¸"¸iÈ¹nÐ:LÑ1MÑMÐPTÑTðUð "ðUð ˜‘:ðUð �c˜3�h‘ $Ñ&ðUð  õ!Uðn ðØðØ%)¨#¨s¨(¡^ðØ;>ðØILðà	òó ðð< ð˜ò ó ðñ ¨¡ð ¸sð Àtó ð. ð*˜ð *  c¨D¡j°#°s¸T±zÀ3ÈÁ:Ð&MÑ Nò *ó ð*ð
/ Só 
/óRó6
ó
ó
ó
ð 3ó ð ð	L $×"6Ñ"6ò 	Ló ð	Lð ð	G˜TŸ_™_ò 	Gó ð	Gð ð	J × 2Ñ 2ò 	Jó ð	Jð ð	E˜4Ÿ?™?ò 	Eó ð	Eð ð#�h˜yÑ)ò #ó ð#ð ð#�h˜yÑ)ò #ó ð#ð( Ø ØAEØ,0Ø37ØØ!ØEIØ-2Ø(,Ø37Ø48Ø<@Ø"ñ3{àð{ð �}‰}Ø
ˆu‰+ñà
ˆt�E‰{Ñ
ñð ×
Ñ
ñð �+‰+ñ	ð
 ×
Ñ
ñð �.‰.ñð �+‰+ñð ×
Ñ
ñ ð ñ	ð{ð �T‰zð{ð —.‘. 4¨¯©Ñ#7Ñ7¸$Ñ>ð{ð —l‘l TÑ)ð{ð  ×)Ñ)¨DÑ0ð!{ð" ð#{ð$ �d‘
ð%{ð& ˜X c™]Ñ*¨U×-BÑ-BÑBð'{ð( ˜X c™]Ñ*ð){ð*  ™ð+{ð, ×)Ñ)¨DÑ0ð-{ð. ×*Ñ*¨TÑ1ð/{ð0 "×2Ñ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'ð �}‰}Ø
ˆu‰+ñà
ˆt�E‰{Ñ
ñð ×
Ñ
ñð �+‰+ñ	ð
 ×
Ñ
ñð �.‰.ñð �+‰+ñð ×
Ñ
ñ ð ñ	ð	B'ð �T‰zðB'ð —.‘. 4¨¯©Ñ#7Ñ7¸$Ñ>ðB'ð  —l‘l TÑ)ð!B'ð" ×)Ñ)¨DÑ0ð#B'ð$ ð%B'ð& ð'B'ð( ˜X c™]Ñ*¨U×-BÑ-BÑBð)B'ð* ˜X c™]Ñ*ð+B'ð,  ™ð-B'ð. ×.Ñ.°Ñ5ð/B'ð0 ×)Ñ)¨DÑ0ð1B'ð2 ×*Ñ*¨TÑ1ð3B'ð4 "×2Ñ2°TÑ9ð5B'ð6 �t‘ð7B'ð8 ð9B'ð: 
×	Ñ	ó;B'ðN -1ØØØ Ø48Ø<@Ø"ñ6$àð6$ð —l‘l TÑ)ð6$ð ð	6$ð
 ð6$ð �T‰zð6$ð ×*Ñ*¨TÑ1ð6$ð "×2Ñ2°TÑ9ð6$ð �t‘ð6$ð ð6$ð 
×	(Ñ	(ó6$ðv -1ØØØ Ø48Ø<@Ø"ñ6$àð6$ð —l‘l TÑ)ð6$ð ð	6$ð
 ð6$ð �T‰zð6$ð ×*Ñ*¨TÑ1ð6$ð "×2Ñ2°TÑ9ð6$ð �t‘ð6$ð ð6$ð 
×	*Ñ	*ó6$ðv .2ØØ)-Ø'+ØEIØ-2Ø48Ø<@Ø"ñXHàðXHð —|‘| dÑ*ðXHð ð	XHð
 —-‘- $Ñ&ðXHð —‘ Ñ$ðXHð ˜X c™]Ñ*¨U×-BÑ-BÑBðXHð ˜X c™]Ñ*ðXHð ×*Ñ*¨TÑ1ðXHð "×2Ñ2°TÑ9ðXHð �t‘ðXHð ðXHð 
ˆt�E—L‘LÑ! 5§=¡=°4Ñ#7Ð7Ñ	8óXHðz -1ØØ<@Ø"Ø48ñ/àð/ð —l‘l TÑ)ð/ð ð	/ð
 "×2Ñ2°TÑ9ð/ð �t‘ð/ð ×*Ñ*¨TÑ1ð/ð ð/ð 
×	Ñ	ó/ðj -1ØØØ"Ø48Ø<@ñ9àð9ð ð9ð —l‘l TÑ)ð	9ð
 ð9ð ð9ð �t‘ð9ð ×*Ñ*¨TÑ1ð9ð "×2Ñ2°TÑ9ð9ð ð9ð 
×	Ñ	ó9ð~ Ø/3Ø<@Ø-1Ø/3Ø"ñhàðhð —‘ðhð ð	hð
 ×%Ñ%¨Ñ,ðhð "×2Ñ2°TÑ9ðhð —|‘| dÑ*ðhð ×%Ñ%¨Ñ,ðhð �t‘ðhð ðhð 
×	Ñ	óhð\ Ø/3Ø<@Ø-1Ø"ñ3àð3ð ˜×+Ñ+Ñ,ð3ð ð	3ð
 ×%Ñ%¨Ñ,ð3ð "×2Ñ2°TÑ9ð3ð —|‘| dÑ*ð3ð �t‘ð3ð ð3ð 
×	Ñ	ó3ðt Ø/3Ø<@Ø"ñ5àð5ð ˜#‘ð5ð ×$Ñ$ð	5ð
 ð5ð ×%Ñ%¨Ñ,ð5ð "×2Ñ2°TÑ9ð5ð �t‘ð5ð ð5ð 
×	Ñ	ó5ðv FJØ-2Ø48Ø<@Ø"ñFàðFð �e—m‘mÑ$ðFð ˜X c™]Ñ*¨U×-BÑ-BÑBð	Fð
 ˜X c™]Ñ*ðFð ×*Ñ*¨TÑ1ðFð "×2Ñ2°TÑ9ðFð �t‘ðFð ðFð 
ˆe�l‰lÑ	óFðP ð3Ø×)Ñ)ð3à	ˆt×"Ñ" D×$9Ñ$9¸DÑ$@Ð@Ñ	Aò3ó ð3ðB ð!à×$Ñ$ð!ð "×2Ñ2°TÑ9ð!ð 
×	Ñ	ò	!ó ð!ðF ðØ"×1Ñ1ðà	ˆd�l‰lÑ	òó ðð ð Ø×)Ñ)ð à	ˆt�F×*Ñ*Ñ+¨dÑ2°F·M±MÀDÑ4HÐHÑ	Iò ó ð ðB Ø/3Ø<@Ø"ñ/àð/ð ×-Ñ-ð/ð ð	/ð
 ×%Ñ%¨Ñ,ð/ð "×2Ñ2°TÑ9ð/ð �t‘ð/ð ð/ð 
×	Ñ	ó/ðl ØØ/3Ø<@Ø"ñ5àð5ð —‘ð5ð ×$Ñ$ð	5ð
 �4‰Zð5ð ð5ð ×%Ñ%¨Ñ,ð5ð "×2Ñ2°TÑ9ð5ð �t‘ð5ð ð5ð 
×	Ñ	ó5ðx Ø/3Ø<@Ø"ñ2àð2ð —‘ð2ð ×$Ñ$ð	2ð
 ð2ð ×%Ñ%¨Ñ,ð2ð "×2Ñ2°TÑ9ð2ð �t‘ð2ð ð2ð 
×	Ñ	ó2ðr Ø/3Ø<@Ø"ñ1àð1ð �s‰mð1ð ×$Ñ$ð	1ð
 ð1ð ×%Ñ%¨Ñ,ð1ð "×2Ñ2°TÑ9ð1ð �t‘ð1ð ð1ð 
×	Ñ	ó1ðn Ø/3Ø<@Ø"ñ/àð/ð ×-Ñ-ð/ð ð	/ð
 ×%Ñ%¨Ñ,ð/ð "×2Ñ2°TÑ9ð/ð �t‘ð/ð ð/ð 
×	Ñ	ó/ðj Ø/3Ø"ñ'àð'ð $ E×$9Ñ$9Ñ:ð'ð ð	'ð
 ×%Ñ%¨Ñ,ð'ð �t‘ð'ð ð'ð 
ˆe× Ñ Ñ	!ó'ðX #ñ&à#+¨E×,AÑ,AÑ#Bð&ð �t‘ð&ð ð	&ð
 
ó&ðPØ"ðØ.1ðà	×	)Ñ	)óð( Cð ¨E×,LÑ,Ló ð ¨ð °×0IÑ0Ió ð$¨cð ¸Sð ÀU×EYÑEYó ð°ð Àð Èó ð  @DØ?CØ9=Ø37ØCGØ"ØOSØ<@Ø)-ñYàðYð !×5Ñ5¸Ñ<ðYð !×5Ñ5¸Ñ<ð	Yð
 ×/Ñ/°$Ñ6ðYð ×)Ñ)¨DÑ0ðYð #×9Ñ9¸DÑ@ðYð �t‘ðYð  ' s¨E×,DÑ,DÐ'DÑEÈÑLðYð "×2Ñ2°TÑ9ðYð —-‘- $Ñ&ðYð ðYð 
óYðx ;?ñØ"ðØ-0°4©ZðØJMðà	óð$ X\Ø#'Ø)-Ø/3Ø'+Ø37Ø?CØ15Ø?CØ"ØOSØ7;Ø<@Ø)-ñ!jàðjð ×*Ñ*¨W°S¸%×:LÑ:LÐ5LÑ-MÑMÐPTÑTðjð ˜D‘jð	jð
   $™Jðjð #&¨¡*ðjð  ™ðjð ×)Ñ)¨DÑ0ðjð !×5Ñ5¸Ñ<ðjð ×'Ñ'¨$Ñ.ðjð #×5Ñ5¸Ñ<ðjð �t‘ðjð  ' s¨E×,DÑ,DÐ'DÑEÈÑLðjð ×-Ñ-°Ñ4ðjð "×2Ñ2°TÑ9ðjð  —-‘- $Ñ&ð!jð" ð#jð$ 
ó%jð^ X\Ø#'Ø)-Ø/3Ø'+Ø37Ø?CØ15Ø?CØ"ØOSØ7;Ø<@Ø)-ñ!%
àð%
ð ×*Ñ*¨W°S¸%×:LÑ:LÐ5LÑ-MÑMÐPTÑTð%
ð ˜D‘jð	%
ð
   $™Jð%
ð #&¨¡*ð%
ð  ™ð%
ð ×)Ñ)¨DÑ0ð%
ð !×5Ñ5¸Ñ<ð%
ð ×'Ñ'¨$Ñ.ð%
ð #×5Ñ5¸Ñ<ð%
ð �t‘ð%
ð  ' s¨E×,DÑ,DÐ'DÑEÈÑLð%
ð ×-Ñ-°Ñ4ð%
ð "×2Ñ2°TÑ9ð%
ð  —-‘- $Ñ&ð!%
ð" ð#%
ð$ 
ó%%
ðN ð%  \Ñ 2ò %ó ð%ð Ø!ØØ<@Ø-1Ø/3ñ8à"ð8ð ð8ð ð	8ð
 ð8ð �d‘
ð8ð ð8ð "×2Ñ2°TÑ9ð8ð —|‘| dÑ*ð8ð ×%Ñ%¨Ñ,ð8ð 
ó8ð| ØØ!ØØØ<@Ø-1Ø/3ñ
àð
ð ˜×*Ò*Ñ+ð
ð ð	
ð
 ð
ð �d‘
ð
ð ð
ð ð
ð "×2Ñ2°TÑ9ð
ð —|‘| dÑ*ð
ð ×%Ñ%¨Ñ,ð
ð ð
ð 
ó
ðD 48Ø.2ØØØ!ØØØ<@Ø-1Ø/3ñ!
àð!
ð �c˜5×+Ñ+Ð+Ñ,¨u×/?Ñ/?Ñ?À(È5×K]ÒK]ÑB^Ñ^ð!
ð ˜$˜s C˜x™.Ñ)¨DÑ0ð	!
ð
 �e—m‘mÑ$ tÑ+ð!
ð ð!
ð ð!
ð �d‘
ð!
ð ð!
ð ð!
ð "×2Ñ2°TÑ9ð!
ð —|‘| dÑ*ð!
ð ×%Ñ%¨Ñ,ð!
ð ð!
ð 
ó!
ðN 8<Ø59ØØ/3Ø"ñaàðað ðað ×-Ò-°Ñ4ð	að
 ×+Ò+¨dÑ2ðað ðað ×%Ñ%¨Ñ,ðað �t‘ðað ðað 
×	Ñ	óaðN Ø/3Ø"ñàðð ðð ð	ð
 ×%Ñ%¨Ñ,ðð �t‘ðð ðð 
×	Ñ	óð>Ø"ðØ.1ðà	ˆe×'Ò'Ñ	(óð  26ñØ"ðØ*.ðØADðà	×	"Ò	" TÑ	)óð FJñØ"ðØ36ðØ>BðØUXðà	�‰óð$
¨Cð 
°D¸×9RÒ9RÑ4Só 
ñX¨ð XÀð XÈ×HaÒHaó 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Ò2ð(ð �t‘ð	(ð
 ð(ð 
ó(ðT × 3Ò 3ó ð dó ð "Ø"ñ	àðð �d‰{ðð �t‘ð	ð
 ðð 
óð °sð ¸u×?ZÒ?Zó ð  '+ñàðð ˜t™ðð ð	ð
 
×	$Ò	$óðàðð ðð 
×	 Ò	 ó	ð4 %)Ø"ñà˜T‘zðð �t‘ðð ð	ð
 
×	'Ò	'÷r¤   r'   )?Úimportlib.metadataro   Úloggingrb   rq   Úmultiprocessingr   Ú	threadingr   Útypingr   r   r   r   r	   r
   r   r   rg   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   ri  Ú&qdrant_client.conversions.common_typesr   Ú$qdrant_client.conversions.conversionr   r   r   Úqdrant_client.httpr   r    r!   Ú qdrant_client.parallel_processorr"   Ú$qdrant_client.uploader.grpc_uploaderr#   Ú$qdrant_client.uploader.rest_uploaderr$   Úqdrant_client.uploader.uploaderr%   r'   rP   r¤   r™   ú<module>rD     s{   ðÛ Û Û Û Ý 1Ý ÷	÷ 	ó 	ó Ý ß 'Ý  ç PÝ &Ý 4Ý )Ý 0ß PÝ 0Ý ;Ý F÷ñ ÷
 ;Ñ :Ý ?Ý BÝ BÝ 8ô~*�:õ ~*r¤   