Ë
    BêñiÀ ã                   ón  — 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)ÚAsyncQdrantBase)Úis_compatibleÚget_server_version)Úget_async_channel)Úcommon_types)Úget_args_subscribed)Ú
GrpcToRestÚ
RestToGrpcÚ!grpc_payload_schema_to_field_type)ÚAsyncApiClientÚ	AsyncApisÚmodels)Ú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 )ÇÚAsyncQdrantRemoteé   é   NÚurlÚportÚ	grpc_portÚprefer_grpcÚhttpsÚapi_keyÚprefixÚtimeoutÚhostÚgrpc_optionsÚauth_token_providerÚcheck_compatibilityÚ	pool_sizeÚheadersÚkwargsc                 óX  •— 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| _<        |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© )AÚ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Ú_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"                                    €úc/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/qdrant_client/async_qdrant_remote.pyrR   zAsyncQdrantRemote.__init__/   sy  ø€ ô$ 	‰ÑÑ"˜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ÜØ}óð ò Ø�~‰~˜kÔ*Ø˜3˜%�j�Ü'¨›nˆJØ(2¯©¸¿¹Ð$ˆTŒZ˜œØ× Ò Ø(×/Ñ/°7Ñ:�”Ø)×0Ñ0�”Ø'+§z¢z˜Ÿš°tˆDŒJØ�|Š| 
§¢Ü ØOÐPSÈuÐT`Ðak×apÑapÐ`qÐróð ð —’Ø)Ÿ™�”Ø�|‰|Ð#4Ñ4Ü Ð#3°D·L±L°>Ð!BÓCÐCàÒ, ˆDŒJØˆDŒJØ)0Ð)<”4—9‘9˜WÔ%À$ˆØˆŒØ$7ˆÔ!Ø—‘˜H dÓ+ˆØˆ>Ø�z‰zÐ7Ñ7ÜŸ™°dÐVWÔX‘Ø—‘Ð,ÜŸ™°d·o±oÔF‘Ø�_‰_Ð(ÜØPÐQZÐP[Ð[fÐgmÐfnÐoóð ð —
‘
˜7 EÓ*ˆØˆÔØ17·±¸JÈÓ1K×1QÑ1QÓ1S×T¡v¨¨1˜a ™dÓTˆÔÙØ%Ÿm™m›oò 8‘
��UØ*/�×"Ñ" 3Ñ'Ø×"Ñ"×)Ñ)¨3°¨,Õ7ð8ð ÐØ�|‰|˜vÒ%ÜØJÜ(Ø õô Àd×FXÑFX×YÑ2B°;À�[ IÓ-ÓYÔZØ × 2Ñ 2Ñ2ä!Ø~Ü(Ø õð
 -4ˆD×Ñ˜yÑ)Ø×Ñ×%Ñ% y°'Ð&:Ô;Ü"×+Ñ+×3Ñ3°OÓDˆÜ!×0Ñ0Ó2ˆØ% nÐ%5°X¸nÐ=MÐNˆ
Ø˜4×-Ñ-Ñ-ÜØpÐq{Ðp|Ð|~Ðôð Ð#Ð(AÀ\Ñ(QÜØ^Ð_iÐ^jÐjlÐmÜ$Øõð
 ,6ˆ×Ñ˜<Ñ(Ø8Bˆ×ÑÐ4Ñ5Ø/5¯z©zÐ:LÈdÓ/SÐØÐ'´Ð<LÌkÔ1ZÜØ^Ô_cÐdtÓ_uÐ^vÐwóð ð œ{×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Ñ#Ü9Bñ :
Ø—‘ð:
Ø"&§/¡/ñ:
ˆÔð 79ˆÔØFJˆÔ%ØPTˆÔ*ØLPˆÔ(ØDHˆÔ#Ø,-ˆÔ$Ø"ˆŒÙÜØ×0Ñ0à—M‘MØ×&Ñ&Ø—O‘O×'Ñ'¨Ó/Ø—M‘Mð	ð ô	÷ ‰e�gð ùó] Uùó Zs   Ë;Z Î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&AsyncQdrantRemote._check_compatibilityÑ   s§   € ð	Ü&×/Ñ/×7Ñ7¸ÓHˆNÜ/°¸,ÈÈgÓVˆNÙ!Üð aÜ(Ø öô
 # >°>ÔBÜØ4°^Ð4DÐDiÐjxÐiyð  z|ð  }Ü(Ø öð Cøô ò 	Üð ]Ü$Ø÷ð	ús   ‚AA+ Á%A+ Á+B	ÂB	c                 ó   — | j                   S ©N)rƒ   ©r‡   s    r•   ÚclosedzAsyncQdrantRemote.closedë   s   € à�|‰|Ðó    Ú
grpc_gracec              ‹   ó®  K  — t        | d«      rDt        | j                  «      dkD  r,| j                  D ]  }	 |j                  |¬«      ƒ d {  –—†  Œ 	 | j                  j                  «       ƒ d {  –—†  d| _        y 7 Œ1# t        $ r t        dt        d¬«       Y Œjt        $ r Y Œtw xY w7 Œ9# t        $ r t        dt        d¬«       Y d| _        y w xY w­w)	Nr}   r   )ÚgracezKUnable 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   rm   ÚRuntimeErrorr:   Úacloserš   rƒ   )r‡   r¡   r8   Úchannels       r•   r¥   zAsyncQdrantRemote.closeï   sÕ   è ø€ Ü�4Ð-Ô.´3°t×7NÑ7NÓ3OÐRSÒ3SØ×2Ñ2ò 
�ð	Ø!Ÿ-™-¨j˜-Ó9×9Ñ9ð
ð	Ø—)‘)×"Ñ"Ó$×$Ð$ð ˆ�ð# :ùÜ%ò Ü Ø mÜ!,Ø#$÷ô
 $ò Ùðúð %ùÜò 	ÜØhÜ$Øöð
 ˆ�ð	üs|   ‚4C·B ÁA>ÁB ÁCÁB- Á1B+Á2B- Á6CÁ>B Â B(ÂCÂB(Â%CÂ'B(Â(CÂ+B- Â-CÃ	CÃCÃC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AsyncQdrantRemote._parse_url  sP   € ä% c›Nˆà×ÑØ×ÑØ×ÑØ×Ñð	(
Ñ$ˆ��t˜Vð ˜˜d FÐ+Ð+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%AsyncQdrantRemote._get_grpc_pool_size  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ƒ   r§   r[   r}   Úranger¯   Úget_channelr^   rT   rV   ri   rU   rw   re   rl   rš   )r‡   Úchannel_poolrŽ   r©   Úes        r•   Ú_init_grpc_channelz$AsyncQdrantRemote._init_grpc_channel  sÙ   € Ø�<Š<ÜÐ^Ó_Ð_ð	RØˆLÜ�4×*Ñ*Ó+¨qÒ0Ü˜t×7Ñ7Ó9Ó:ò 
1�AÜ)Ø!ŸZ™ZØ!Ÿ_™_Ø ŸK™KØ!%×!3Ñ!3Ø $× 2Ñ 2Ø$(×$:Ñ$:Ø,0×,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*AsyncQdrantRemote._init_grpc_points_client1  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/AsyncQdrantRemote._init_grpc_collections_client7  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-AsyncQdrantRemote._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(AsyncQdrantRemote._init_grpc_root_clientC  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#AsyncQdrantRemote._next_grpc_clientI  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"AsyncQdrantRemote.grpc_collectionsP  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AsyncQdrantRemote.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 AsyncQdrantRemote.grpc_snapshotsh  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AsyncQdrantRemote.grpc_roott  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AsyncQdrantRemote.rest€  ó   € ð ×"Ñ"Ð"r    c                 ó   — | j                   S rÓ   rÔ   rž   s    r•   r:   zAsyncQdrantRemote.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              ‹   óÂ  K  — | 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                  ¬«      ƒ d {  –—† }|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                  ||||¬«      ƒ d {  –—† }|j8                  }|€J d«       ‚|S c c}w 7 �Œrc c}w 7 Œ(­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AsyncQdrantRemote.query_points’  sM  è ø€ ð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]Ó%^Ð"Ø,0×,<Ñ,<×,BÑ,BÜ× Ñ Ø$3ØØ%Ø'ØØ!Ø!-Ø!-Ø(Ø$3ØØ +Ø#Ø'9Ø%0ôð" $+Ð#6™¸D¿M¹Mð% -Có -÷ 'ˆ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ð "&§¡×!5Ñ!5×!BÑ!BØ /Ø'ØØ+ð	 "Có "÷ ˆLð 3?×2EÑ2EˆFØÐ%Ð=Ð'=Ó=Ð%ØˆMùòOð$'ûò( Yð2ús>   ‚A)OÁ+8OÂ#G OÉ#OÉ$OÉ6OÊD"OÎ4OÎ5!OÏOÚrequestsc              ‹   ó8  K  — | 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                  ¬«      ƒ d {  –—† }|j                  D ��cg c]C  }t        j                  |j                  D �cg c]  }t!        j"                  |«      ‘Œ c}¬«      ‘ŒE c}}S | j$                  j&                  j)                  |||t        j*                  |¬«      ¬«      ƒ d {  –—† j                  }	|	€J d«       ‚|	S c c}w 7 Œ¾c c}w c c}}w 7 Œ+­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$AsyncQdrantRemote.query_batch_pointsý  s’  è ø€ ð ×Óð
 "ö	ð ô ˜a¤×!4Ñ!4Ô5ô ×0Ñ0°°OÔDàñðˆHð ô ˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�Ø6:×6FÑ6F×6QÑ6QÜ×%Ñ%Ø$3Ø!)Ø%0Ø#ô	ð $+Ð#6™¸D¿M¹Mð 7Ró 7÷ 1ˆHð "Ÿ™÷	ð ô ×$Ñ$ØLMÏHÉHÖUÀSœJ×;Ñ;¸CÕ@ÒUöóð ð —i‘i×*Ñ*×=Ñ=Ø$3Ø +Ø#Ü(.×(@Ñ(@È(Ô(Sð	 >ó ÷ ÷ ‰fð ð Ð'ÐDÐ)DÓDÐ'ØˆOùòCð1úò VùóðúsN   ‚F”9FÁA?FÃFÃFÃ "FÄFÄ
FÄ(AFÅ,FÅ-FÆFÆFÚgroup_byÚ
group_sizeÚwith_lookupc              ‹   ó`  K  — | 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<                  ¬«      ƒ d {  –—† 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                  ||||¬«      ƒ d {  –—† }|€J d«       ‚|j>                  S c c}w 7 �ŒO7 Œ!­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%AsyncQdrantRemote.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]Ó%^Ð"à×&Ñ&×2Ñ2Ü×)Ñ)ò Ù(7ðá#ðñ "*ðñ  ,ð	ñ
 $ðñ &2ðñ &2ðñ  -ðñ )8ðñ $ðñ "*ðñ $.ðñ %0ðñ %0ðñ !(ðñ  ,>ð!ñ" *5ð#ð& (/Ð':™GÀÇÁð) 3ó ÷ ÷, ‰fð/ ô0 ×3Ñ3°FÓ;Ð;ä˜,¬¯©Ô4Ü)×8Ñ8¸|ÔL�Ü˜-¬×):Ñ):Ô;Ü *× @Ñ @ÀÓ O�Ü˜,¬×(@Ñ(@ÔAÜ)×GÑGÈÓU�Ü˜+¤t×':Ñ':Ô;Ü(×@Ñ@ÀÓM�Ü"×5Ñ5Ø,Ø!ØØØ#Ø$Ø /ØØ!Ø%Ø(Ø)Ø'Ø'ôˆMð  "&§¡×!5Ñ!5×!IÑ!IØ /Ø'ØØ%2ð	 "Jó "÷ ˆLð  Ð+ÐTÐ-TÓTÐ+Ø×&Ñ&Ð&ùò_ð.ùðbús2   ‚A)P.Á+8P$Â#H7P.ËP)ËD/P.Ð
P,ÐP.Ð,P.Úsamplec	              ‹   ób  K  — | 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                  ¬«      ƒ d {  –—† }
t!        j"                  |
j$                  «      S t        |t        j                  «      rt!        j
                  |¬«      }| j&                  j(                  j+                  |||t        j,                  |||||¬«      ¬«      ƒ d {  –—† j$                  }|€J d«       ‚|S 7 Œ±7 Œ­w)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•   r6  z%AsyncQdrantRemote.search_matrix_pairsž  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ô ×9Ñ9¸(¿/¹/ÓJÐJÜ�l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà×%Ñ%×0Ñ0×DÑDØ /Ø'ØÜ&,×&@Ñ&@Ø0ØØ!ØØ'ô'ð	 Eó ÷ ÷ ‰&ð 	ð $Ð/Ð[Ð1[Ó[Ð/Ø#Ð#ð?øð"úó%   ‚C7F/Ã9F+Ã:BF/ÆF-ÆF/Æ-F/c	              ‹   ób  K  — | 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                  ¬«      ƒ d {  –—† }
t!        j"                  |
j$                  «      S t        |t        j                  «      rt!        j
                  |¬«      }| j&                  j(                  j+                  |||t        j,                  |||||¬«      ¬«      ƒ d {  –—† j$                  }|€J d«       ‚|S 7 Œ±7 Œ­w)Nrç   r/  rì   r0  r1  z*Search matrix offsets returned None result)rS   rs   r!   rö   r   r÷   r   r  r  r   r  rÍ   ÚSearchMatrixOffsetsr   r4  rz   r   Úconvert_search_matrix_offsetsr  r|   r  Úsearch_matrix_offsetsr7  r8  s               r•   r?  z'AsyncQdrantRemote.search_matrix_offsetsÒ  s†  è ø€ ð ×ÓÜ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�Ø!×-Ñ-×AÑAÜ×'Ñ'Ø$3Ø'Ø!ØØØ#Ø%0Ø'9ô	ð $+Ð#6™¸D¿M¹Mð Bó ÷ ˆHô ×;Ñ;¸H¿O¹OÓLÐLÜ�l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà×%Ñ%×0Ñ0×FÑFØ /Ø'ØÜ&,×&@Ñ&@Ø0ØØ!ØØ'ô'ð	 Gó ÷ ÷ ‰&ð 	ð $Ð/Ð]Ð1]Ó]Ð/Ø#Ð#ð?øð"úr;  Úscroll_filterÚorder_byc              ‹   óþ  K  — | j                   �r0t        |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.                  ¬«      ƒ d {  –—† }|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                  |||||||	¬«      |
¬«      ƒ d {  –—† j0                  }|€J d«       ‚|jN                  |j:                  fS 7 �Œ˜c c}w 7 Œ7­w)Nrç   )
rØ   ré   rA  rß   rá   rà   rÞ   rë   rå   r1   rì   Únext_page_offset)ré   rÞ   rA  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_idrC  ÚPointIdÚOrderByÚconvert_order_byr	  r
  r|   Ú
points_apiÚscroll_pointsÚScrollRequestrî   )r‡   rØ   r@  rÞ   rA  rß   rà   rá   rä   rå   r1   r8   r  ÚpointÚscroll_results                  r•   ÚscrollzAsyncQdrantRemote.scroll  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�Ø-1×-=Ñ-=×-DÑ-DÜ×!Ñ!Ø$3Ø(Ø%Ø!Ø!-Ø!-ØØ%0Ø'9Ø#ôð $+Ð#6™¸D¿M¹Mð .Eó .÷ (ˆCð  ILÏ
É
ÖS¸u”×3Ñ3°EÕ:ÒSà—<‘<Ð 2Ô3ô ×+Ñ+¨C×,@Ñ,@ÓAðð ð ð	ð ô ˜&¤$§,¡,Ô/Ü#×4Ñ4°VÓ<�Ü˜-¬¯©Ô5Ü *× 9Ñ 9ÀÔ N�Ü˜(¤D§L¡LÔ1Ü%×6Ñ6°xÓ@�Ü˜,¬×(@Ñ(@ÔAÜ)×GÑGÈÓU�à×)Ñ)×4Ñ4×BÑBØ$3Ø +Ü#)×#7Ñ#7Ø,Ø#Ø!)Ø%Ø%1Ø$0Ø"4ô$ð $ð Có ÷ ÷ ‰fð ð  !Ð,ÐVÐ.VÓVÐ,Ø!×(Ñ(¨-×*HÑ*HÐIÐIð_(ûò  Tðús1   ‚GM=ÇM3ÇM=Ç.M6È
D9M=ÍM;Í0M=Í6M=Úcount_filterÚexactc           
   ‹   óZ  K  — | 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                  ¬«      ƒ d {  –—† j                   }t#        j$                  |«      S t        |t        j                  «      rt#        j
                  |¬«      }| j&                  j(                  j+                  |t        j,                  |||¬«      ||¬«      ƒ d {  –—† j                   }	|	€J d«       ‚|	S 7 Œ¯7 Œ­w)Nrç   )rØ   ré   rX  rå   r1   rë   rì   )ré   rX  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|   rQ  Úcount_pointsÚCountRequest)
r‡   rØ   rW  rX  rå   r1   rä   r8   r9  Úcount_results
             r•   ÚcountzAsyncQdrantRemote.countT  s  è ø€ ð ×ÓÜ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�à×&Ñ&×,Ñ,Ü×$Ñ$Ø(7Ø+Ø#Ø+=Ø 'Ø)4ôð (/Ð':™GÀÇÁð -ó 
÷ 
÷ ‰fð ô ×2Ñ2°8Ó<Ð<Ü�l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà×%Ñ%×0Ñ0×=Ñ=Ø /Ü$×1Ñ1Ø'¨uÐ@Rôð (Øð >ó ÷ ÷ ‰&ð 	ð Ð'ÐLÐ)LÓLÐ'ØÐð5
øð ús%   ‚C5F+Ã7F'Ã8BF+ÆF)ÆF+Æ)F+r‹   Úfacet_filterc	              ‹   ó°  K  — | 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                  ¬«      ƒ d {  –—† }
t!        j"                  |
j$                  D �cg c]  }t'        j(                  |«      ‘Œ c}¬«      S t        |t        j                  «      rt'        j
                  |¬«      }| j*                  j,                  j/                  |||t        j0                  |||||¬«      ¬«      ƒ d {  –—† j2                  }|€J d«       ‚|S 7 ŒÓc c}w 7 Œ ­w)Nrç   )rØ   r‹   ré   rÞ   rX  r1   rë   rå   rì   )Úhits)rï   r‹   rÞ   ré   rX  )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ÚFacetResponserd  r   Úconvert_facet_value_hitr|   rQ  ÚfacetÚFacetRequestr  )r‡   rØ   r‹   rb  rÞ   rX  r1   rä   rå   r8   r9  r  Úfacet_results                r•   rk  zAsyncQdrantRemote.facet‚  s§  è ø€ ð ×ÓÜ˜,¬¯©Ô6Ü)×8Ñ8¸|ÔL�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�Ø!×-Ñ-×3Ñ3Ü× Ñ Ø$3ØØ'ØØØ#Ø%0Ø'9ô	ð $+Ð#6™¸D¿M¹Mð 4ó ÷ ˆHô ×&Ñ&ØIQÏÉÖWÀ#”j×8Ñ8¸Õ=ÒWôð ô �l¤D§K¡KÔ0Ü%×4Ñ4¸<ÔHˆLà×%Ñ%×0Ñ0×6Ñ6Ø /Ø'ØÜ$×1Ñ1Ø0ØØØ'Øôð	 7ó ÷ ÷ ‰&ð 	ð Ð'ÐLÐ)LÓLÐ'ØÐðCúò Xð
ús1   ‚C7GÃ9GÃ:!GÄGÄ7A<GÆ3GÆ4GÇGrî   ÚwaitÚorderingÚupdate_filterÚupdate_modec	              ‹   ó8  K  — | j                   �ret        |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:                  ¬«      ƒ d {  –—† 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                  |||||¬«      ƒ d {  –—† j<                  }|€J d«       ‚|S c c}w c c}w 7 �ŒHc c}w 7 Œ+­w)	N)ÚidÚvectorsÚpayloadrç   )rØ   rn  rî   ro  rå   rp  r1   rq  rì   úUpsert returned None result)rî   rï   rp  rq  )Úbatchrï   rp  rq  )rØ   rn  Úpoint_insert_operationsro  r1   )&rS   rs   r!   ÚBatchr   Úconvert_batch_vector_structrt  r[   Úidsr´   r   ÚPointStructrF  Ú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|   rQ  Úupsert_points)r‡   rØ   rî   rn  ro  rå   rp  rq  r1   r8   Úvectors_batchÚidxrT  Úgrpc_resultÚhttp_results                  r•   ÚupsertzAsyncQdrantRemote.upsert¸  sD  è ø€ ð ×ÓÜ˜&¤&§,¡,Ô/Ü4>×4ZÑ4ZØ—N‘N¤C¨¯
©
£Oó5�ô  %¤S¨¯©£_Ó5ö	ð ô ×$Ñ$Ü%×?Ñ?ÀÇ
Á
È3ÁÓPØ -¨cÑ 2à!Ÿ?™?Ð6ô !+× :Ñ :¸6¿?¹?È3Ñ;OÔ Pà!öð	�ð 	ô ˜&¤$Ô'ð
 "(ö	ð ô " %¬×);Ñ);Ô<ô ×3Ñ3°EÔ:àñð�ð ô ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü˜-¬¯©Ô7Ü *× 9Ñ 9ÀÔ N�Ü˜+¤v×'8Ñ'8Ô9Ü(×<Ñ<¸[ÓI�à×&Ñ&×-Ñ-Ü×%Ñ%Ø(7Ø!Ø%Ø!)Ø+=Ø&3Ø 'Ø$/ô	ð !ŸM™Mð .ó ÷ ÷ ‰fð ð Ð*ÐIÐ,IÓIÐ*Ü×3Ñ3°KÓ@Ð@ä˜-¬¯©Ô5Ü *× 9Ñ 9ÀÔ N�Ü˜&¤$Ô'ð
 "(ö	ð ô " %¬×)9Ñ)9Ô:ô ×3Ñ3°EÔ:àñð�ð ô  ×*Ñ*Ø!Ø0Ø"/Ø +ô	�ô ˜&¤&§,¡,Ô/Ü×+Ñ+Ø Ø0Ø"/Ø +ô	�ð ×)Ñ)×4Ñ4×BÑBØ$3ØØ,2Ø%Ø#ð Có ÷ ÷ ‰fð ð Ð*ÐIÐ,IÓIÐ*ØÐùòW	ùòðûò(ð(úsL   ‚A;NÁ=A0NÃ-NÄ8NÄ;DNÉNÉ	A0NÊ98NË1A;NÍ,NÍ-$NÎNc              ‹   óŽ  K  — | 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                   ¬«      ƒ d {  –—† j"                  }
|
€J d«       ‚t%        j&                  |
«      S t        |t        j                  «      rt%        j                  |¬«      }| j(                  j*                  j-                  ||t	        j                  |||¬«      ||¬«      ƒ d {  –—† j"                  S c c}	w 7 Œ³7 Œ­w)Nrç   )rØ   rn  rî   ro  rå   rp  r1   rì   rv  )rî   rï   rp  )rØ   rn  Úupdate_vectorsro  r1   )rS   r   Úconvert_point_vectorsrs   r!   r€  r�  r   r  r  rö   r÷   rÍ   ÚUpdateVectorsr   ÚUpdatePointVectorsrz   r  r   r†  r|   rQ  r�  )r‡   rØ   rî   rn  ro  rå   rp  r1   r8   rT  rŒ  s              r•   r�  z AsyncQdrantRemote.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�à×&Ñ&×4Ñ4Ü×+Ñ+Ø(7Ø!Ø%Ø!)Ø+=Ø&3Ø 'ôð !ŸM™Mð 5ó ÷ ÷ ‰fð ð Ð*ÐIÐ,IÓIÐ*Ü×3Ñ3°KÓ@Ð@ä˜-¬¯©Ô5Ü *× 9Ñ 9ÀÔ N�à×)Ñ)×4Ñ4×CÑCØ$3ØÜ#)×#7Ñ#7Ø%Ð1CÐS`ô$ð &Ø#ð Dó ÷ ÷ ‰fð
ùò5 Sðøð&ús/   ‚G”F<°CGÄGÄBGÆ-GÆ.GÇGrt  c              ‹   ó  K  — | 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                  ¬«      ƒ d {  –—† j                   }|€J d«       ‚t#        j$                  |«      S | j'                  |«      \  }}| j(                  j*                  j-                  ||||t/        t        j                  ||||¬«      ¬«      ƒ d {  –—† j                   S 7 Œ˜7 Œ­w)N)Únames)rØ   rn  rt  Úpoints_selectorro  rå   r1   rì   z#Delete vectors returned None result)Úvectorrî   ré   rï   )rØ   rn  ro  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|   rQ  r˜  r   )r‡   rØ   rt  rî   rn  ro  rå   r1   r8   r–  Úopt_shard_key_selectorrŒ  Ú_pointsÚ_filters                 r•   r˜  z AsyncQdrantRemote.delete_vectorsH  s}  è ø€ ð ×ÓØ8<×8[Ñ8[Ð\bÓ8cÑ5ˆ_Ð4Ø!3Ò!MÐ7MÐÜ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"à×&Ñ&×4Ñ4Ü×+Ñ+Ø(7Ø!Ü $× 4Ñ 4¸7Ô CØ(7Ø!)Ø+=Ø 'ôð !ŸM™Mð 5ó ÷ ÷ ‰fð ð Ð*ÐQÐ,QÓQÐ*Ü×3Ñ3°KÓ@Ð@à!%×!MÑ!MÈfÓ!UÑˆW�gà×)Ñ)×4Ñ4×CÑCØ$3ØØ%Ø#Ü#,Ü×,Ñ,Ø&Ø&Ø&Ø"4ô$ð Dó ÷ ÷ ‰fðð#øð$ús%   ‚C'FÃ)FÃ*B	FÅ3FÅ4FÆFr{  c              ‹   óî  K  — | 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$                  ¬«      ƒ d {  –—† 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:                  ||||¬«      |¬«      ƒ d {  –—† j&                  }|€J d«       ‚|S c c}	w 7 �Œ
c c}w c c}	w 7 Œ+­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û   rE  rF  rý   r   r  r  r  rÍ   ÚGetr   Ú	GetPointsrz   r  r   rK  r	  r
  rN  rM  r|   rQ  Ú
get_pointsÚPointRequest)r‡   rØ   r{  rà   rá   rä   rå   r1   r8   r‹  r  Úrecordr�  s                r•   ÚretrievezAsyncQdrantRemote.retrieve|  sY  è ø€ ð ×ÓÜ˜,Ô(;¼F×<WÑ<WÓ(XÔYÜ)×HÑHÈÓV�ð
 ö	ð ô ˜cÔ#6´v×7MÑ7MÓ#NÔOô ×4Ñ4°SÔ9àñðˆCð ô &×:Ñ:¸<ÓHˆLÜ˜+Ô':¼6×;QÑ;QÓ'RÔSÜ(×AÑAÀ+ÓN�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"à×&Ñ&×*Ñ*Ü—N‘NØ(7ØØ%1Ø%1Ø)4Ø+=Ø 'ôð (/Ð':™GÀÇÁð +ó ÷ ÷ ‰fð ð Ð%ÐFÐ'FÓFÐ%ØMSÖTÀ6”J×6Ñ6°vÕ>ÒTÐTä˜,¬×(@Ñ(@ÔAÜ)×GÑGÈÓU�ð öàô 5?¸sÄDÇLÁLÔ4Q”
×+Ñ+¨CÔ0ÐWZÑZðˆCð ð
 ×)Ñ)×4Ñ4×?Ñ?Ø$3Ø +Ü"(×"5Ñ"5ØØ%1Ø$0Ø"4ô	#ð $ð @ó 
÷ 
÷ ‰fð ð Ð*ÐOÐ,OÓOÐ*ØÐùòaðûò Uùòð

úsK   ‚A
I5ÁAI!ÂCI5ÅI&ÅI5Å8I)Æ6I5Ç
8I.ÈAI5ÉI3ÉI5É)I5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!   rE  r   rF  r   rï   r  Úconvert_points_selectorrö   r   ÚFilterSelectorr\   ru   )Úclsrî   rå   r‹  r–  s        r•   r™  z0AsyncQdrantRemote._try_argument_to_grpc_selector¼  sŒ  € ð "ÐÜ�fœdÔ#Ü"×1Ñ1Ü×)Ñ)ð
 $*ö	ð  ô & cÔ+>¼v×?UÑ?UÓ+VÔWô #×<Ñ<¸SÔAà ñ!òôô	ˆOð0  Ð!3Ð4Ð4ô ˜¤× 3Ñ 3Ô4Ø$ˆOð  Ð!3Ð4Ð4ô ˜¤¬×)>Ñ)>Ó ?Ô@Ø×ÑÐ+Ü%/×%JÑ%JÈ6×K[ÑK[Ó%\Ð"Ü(×@Ñ@ÀÓHˆOð  Ð!3Ð4Ð4ô ˜¤§¡Ô.Ü(×@Ñ@Üœ&×/Ñ/¸Ô?óˆOð  Ð!3Ð4Ð4ô	 ˜¤§¡Ô,Ü"×1Ñ1¸Ô@ˆOð  Ð!3Ð4Ð4ô Ð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   rN  r   rM  r   r!   ÚPointIdsListr«  r­  rï   r   rö   r®  r÷   r\   ru   )r¯  rî   rå   r‹  rŸ  r–  s         r•   Ú_try_argument_to_rest_selectorz0AsyncQdrantRemote._try_argument_to_rest_selectorÜ  sU  € ô �fœdÔ#ð "öàô 5?¸sÄDÇLÁLÔ4Q”
×+Ñ+¨CÔ0ÐWZÑZðˆGð ô (Ü×#Ñ#¨GÐ?QôˆOð* Ðô% ˜¤× 3Ñ 3Ô4Ü(×@Ñ@ÀÓHˆOØ(:ˆOÔ%ð  Ðô ˜¤¬×)>Ñ)>Ó ?Ô@Ø$ˆOØ(:ˆOÔ%ð Ðô ˜¤§¡Ô.Ü'Ü×%Ñ%¨fÐ@RôˆOð Ðô ˜¤§¡Ô,Ü'Ü×%Ñ%Ü!×0Ñ0°Ó8Ø,ôˆOð Ðô ÐAÄ$ÀvÃ,ÀÐPÓQÐQùò1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_listz1AsyncQdrantRemote._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   rN  r   rM  r«  r­  r!   r±  rî   r®  ré   rö   r÷   r\   ru   )r¯  rî   rŸ  r   r‹  Úselectors         r•   r�  z9AsyncQdrantRemote._try_argument_to_rest_points_and_filter  s�  € ð ˆØˆÜ�fœdÔ#ð "öàô 5?¸sÄDÇLÁLÔ4Q”
×+Ñ+¨CÔ0ÐWZÑZðˆ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              ‹   ó¨  K  — | 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                   ¬«      ƒ d {  –—† j"                  «      S | j%                  ||«      }| j&                  j(                  j+                  |||||¬«      ƒ d {  –—† j"                  }	|	€J d«       ‚|	S 7 Œk7 Œ­w)N©rØ   rn  rî   ro  rå   r1   rì   )rØ   rn  r–  ro  r1   zDelete points returned None)rS   r™  rs   r!   r€  r   r�  r   r  r  r   r†  rÍ   ÚDeleter   ÚDeletePointsrz   r  r²  r|   rQ  Údelete_points©
r‡   rØ   r–  rn  ro  rå   r1   r8   rž  r  s
             r•   ÚdeletezAsyncQdrantRemote.delete%  s`  è ø€ ð ×ÒØ8<×8[Ñ8[Øó9Ñ5ˆ_Ð4ð "4Ò!MÐ7MÐÜ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü×3Ñ3à×*Ñ*×1Ñ1Ü×)Ñ)Ø,;Ø!%Ø#2Ø%-Ø/AØ$+ôð !%§¡ð 2ó 
÷ 
÷ ‘&óð ð  #×AÑAØÐ!3óˆOð ×)Ñ)×4Ñ4×BÑBØ$3ØØ$3Ø%Ø#ð Có ÷ ÷ ‰fð ð Ð%ÐDÐ'DÓDÐ%ØˆMð7
øð$úó%   ‚C EÃ"EÃ#AEÄ4EÄ5EÅEru  c	              ‹   ó  K  — | 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"                  ¬«      ƒ d {  –—† j$                  «      S | j'                  |«      \  }}| j(                  j*                  j-                  ||||t        j                  |||||¬«      ¬«      ƒ d {  –—† j$                  }|€J d«       ‚|S 7 Œ…7 Œ­w)N)rØ   rn  ru  r–  ro  rå   r‹   r1   rì   )ru  rî   ré   rï   r‹   ©rØ   rn  ro  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|   rQ  rÆ  )r‡   rØ   ru  rî   r‹   rn  ro  rå   r1   r8   r–  rž  rŸ  r   r  s                  r•   rÆ  zAsyncQdrantRemote.set_payloadW  s…  è ø€ ð ×ÒØ8<×8[Ñ8[Ð\bÓ8cÑ5ˆ_Ð4Ø!3Ò!MÐ7MÐÜ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü×3Ñ3à×*Ñ*×5Ñ5Ü×-Ñ-Ø,;Ø!%Ü$.×$>Ñ$>¸wÓ$GØ,;Ø%-Ø/AØ #Ø$+ô	ð !%§¡ð 6ó ÷ ÷ ‘&óð ð$ "&×!MÑ!MÈfÓ!UÑˆW�gà×)Ñ)×4Ñ4×@Ñ@Ø$3ØØ%Ø#Ü &× 1Ñ 1Ø 'Ø&Ø&Ø"4Øô!ð Aó ÷ ÷ ‰fð ð Ð%ÐBÐ'BÓBÐ%ØˆMðCøð$ús%   ‚C5FÃ7E=Ã8A+FÅ#E?Å$FÅ?Fc              ‹   ó  K  — | 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"                  ¬«      ƒ d {  –—† j$                  «      S | j'                  |«      \  }}| j(                  j*                  j-                  ||||t        j.                  ||||¬«      ¬«      ƒ d {  –—† j$                  }|€J d«       ‚|S 7 Œ„7 Œ­w)N)rØ   rn  ru  r–  ro  rå   r1   rì   )ru  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|   rQ  Úoverwrite_payloadrÇ  )r‡   rØ   ru  rî   rn  ro  rå   r1   r8   r–  rž  rŸ  r   r  s                 r•   rË  z#AsyncQdrantRemote.overwrite_payload�  s~  è ø€ ð ×ÒØ8<×8[Ñ8[Ð\bÓ8cÑ5ˆ_Ð4Ø!3Ò!MÐ7MÐÜ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü×3Ñ3à×*Ñ*×;Ñ;Ü×-Ñ-Ø,;Ø!%Ü$.×$>Ñ$>¸wÓ$GØ,;Ø%-Ø/AØ$+ôð !%§¡ð <ó ÷ ÷ ‘&óð ð" "&×!MÑ!MÈfÓ!UÑˆW�gà×)Ñ)×4Ñ4×FÑFØ$3ØØ%Ø#Ü &× 1Ñ 1Ø 'Ø&Ø&Ø"4ô	!ð Gó ÷ ÷ ‰fð ð Ð%ÐHÐ'HÓHÐ%ØˆMð?øð"ús%   ‚C4E?Ã6E;Ã7A*E?Å!E=Å"E?Å=E?Úkeysc              ‹   óÜ  K  — | 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                   ¬«      ƒ d {  –—† j"                  «      S | j%                  |«      \  }}| j&                  j(                  j+                  ||||t        j                  ||||¬«      ¬«      ƒ d {  –—† j"                  }|€J d«       ‚|S 7 Œ„7 Œ­w)N)rØ   rn  rÌ  r–  ro  rå   r1   rì   )rÌ  rî   ré   rï   )rØ   rn  ro  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|   rQ  rÎ  )r‡   rØ   rÌ  rî   rn  ro  rå   r1   r8   r–  rž  rŸ  r   r  s                 r•   rÎ  z AsyncQdrantRemote.delete_payloadÄ  sq  è ø€ ð ×ÒØ8<×8[Ñ8[Ð\bÓ8cÑ5ˆ_Ð4Ø!3Ò!MÐ7MÐÜ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü×3Ñ3à×*Ñ*×8Ñ8Ü×0Ñ0Ø,;Ø!%Ø!%Ø,;Ø%-Ø/AØ$+ôð !%§¡ð 9ó ÷ ÷ ‘&óð ð" "&×!MÑ!MÈfÓ!UÑˆW�gà×)Ñ)×4Ñ4×CÑCØ$3ØØ%Ø#Ü#)×#7Ñ#7Ø!¨'¸'ÐM_ô$ð Dó ÷ ÷ ‰fð ð Ð%ÐEÐ'EÓEÐ%ØˆMð9øð"ús%   ‚C!E,Ã#E(Ã$A*E,ÅE*ÅE,Å*E,c              ‹   ó¨  K  — | 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                   ¬«      ƒ d {  –—† j"                  «      S | j%                  ||«      }| j&                  j(                  j+                  |||||¬«      ƒ d {  –—† j"                  }	|	€J d«       ‚|	S 7 Œk7 Œ­w)Nr½  rì   )rØ   rn  ro  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|   rQ  Úclear_payloadrÁ  s
             r•   rÔ  zAsyncQdrantRemote.clear_payloadö  s`  è ø€ ð ×ÒØ8<×8[Ñ8[Øó9Ñ5ˆ_Ð4ð "4Ò!MÐ7MÐÜ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ÜÐ,Ô.AÄ&×BYÑBYÓ.ZÔ[Ü%/×%JÑ%JÐK]Ó%^Ð"Ü×3Ñ3à×*Ñ*×7Ñ7Ü×/Ñ/Ø,;Ø!%Ø#2Ø%-Ø/AØ$+ôð !%§¡ð 8ó 
÷ 
÷ ‘&óð ð  #×AÑAØÐ!3óˆOð ×)Ñ)×4Ñ4×BÑBØ$3ØØ%Ø#Ø$3ð Có ÷ ÷ ‰fð ð Ð%ÐDÐ'DÓDÐ%ØˆMð7
øð$úrÃ  Úupdate_operationsc           	   ‹   óz  K  — | j                   rÃ|D �cg c]  }t        j                  |«      ‘Œ }}t        |t        j
                  «      rt        j                  |«      }| j                  j                  t        j                  |||||¬«      | j                  ¬«      ƒ d {  –—† j                  D �cg c]  }t        j                  |«      ‘Œ c}S | j                  j                   j#                  ||||t	        j$                  |¬«      ¬«      ƒ d {  –—† j                  }|€J d«       ‚|S c c}w 7 Œ�c c}w 7 Œ%­w)N)rØ   rn  Ú
operationsro  r1   rì   )r×  )rØ   rn  ro  r1   rÕ  z!Batch update points returned None)rS   r   Úconvert_update_operationrs   r!   r€  r�  rÍ   ÚUpdateBatchr   ÚUpdateBatchPointsrz   r  r   r†  r|   rQ  Úbatch_updateÚUpdateOperations)	r‡   rØ   rÕ  rn  ro  r1   r8   Ú	operationr  s	            r•   Úbatch_update_pointsz%AsyncQdrantRemote.batch_update_points(  sD  è ø€ ð ×ÒàPaö!ØCL”
×3Ñ3°IÕ>ð!Ðð !ô ˜(¤F×$8Ñ$8Ô9Ü%×<Ñ<¸XÓF�ð ×*Ñ*×6Ñ6Ü×.Ñ.Ø,;Ø!%Ø'8Ø%-Ø$+ôð !%§¡ð 7ó 	÷ 	÷ ‘&öàô ×0Ñ0°Õ8òð ð" ×)Ñ)×4Ñ4×AÑAØ$3ØØ%Ø#Ü&,×&=Ñ&=ÐIZÔ&[ð Bó ÷ ÷ ‰fð ð Ð%ÐJÐ'JÓJÐ%ØˆMùò?!ð	úòð"ús;   ‚D;“D-¯A3D;Â"D2Â#D;Â3D4ÃAD;ÄD9ÄD;Ä4D;Úchange_aliases_operationsc              ‹   óŠ  K  — | j                   r�|D �cg c]3  }t        |t        j                  «      st	        j
                  |«      n|‘Œ5 }}| j                  j                  t        j                  ||¬«      |�|n| j                  ¬«      ƒ d {  –—† j                  S |D �cg c]3  }t        |t        j                  «      rt        j
                  |«      n|‘Œ5 }}| j                  j                  j                  |t        j                   |¬«      ¬«      ƒ d {  –—† j                  }|€J d«       ‚|S c c}w 7 Œ©c c}w 7 Œ%­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+AsyncQdrantRemote.update_collection_aliasesS  s[  è ø€ ð ×Òð
 ";ö	(ð ô " )¬T×-AÑ-AÔBô ×3Ñ3°IÔ>àñð(Ð$ð (ð ×+Ñ+×9Ñ9Ü×&Ñ&¨wÐ@XÔYØ'.Ð':™GÀÇÁð :ó ÷ ÷ ‰fðð 7ö	$
ð ô ˜)¤T×%9Ñ%9Ô:ô ×/Ñ/°	Ô:àñð$
Ð ð $
ð —)‘)×'Ñ'×6Ñ6ØÜ)/×)FÑ)FØ4ô*ð 7ó ÷ ÷ ‰&ð 	ð Ð!ÐAÐ#AÓAÐ!Øˆùò7(ðúò
$
ðús<   ‚E“8D5ÁAEÂD:ÂEÂ#8D<ÃA EÄEÄEÄ<Ec              ‹   óÂ  K  — | j                   r„| j                  j                  t        j                  |¬«      | j
                  ¬«      ƒ d {  –—† j                  }t        j                  |D �cg c]  }t        j                  |«      ‘Œ c}¬«      S | j                  j                  j                  |¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œˆc c}w 7 Œ ­w)N©rØ   rì   ©Úaliasesz$Get collection aliases returned None)rS   rË   ÚListCollectionAliasesr   ÚListCollectionAliasesRequestrz   rî  rh  ÚCollectionsAliasesResponser   Úconvert_alias_descriptionr:   rç  Úget_collection_aliasesr  )r‡   rØ   r8   r9  Údescriptionr  s         r•   ró  z(AsyncQdrantRemote.get_collection_aliasesw  s×   è ø€ ð ×Òà×+Ñ+×AÑAÜ×5Ñ5ÀoÔVØ ŸM™Mð Bó ÷ ÷ ‰gð ô ×3Ñ3àYaöØJU”J×8Ñ8¸ÕEòôð ð —)‘)×'Ñ'×>Ñ>ÈÐ>Ó_×_ß
‰&ð 	ð Ð!ÐIÐ#IÓIÐ!Øˆðúòð
 `ús0   ‚ACÁCÁ!CÁ/CÂ1CÂ<CÂ=CÃCc              ‹   óº  K  — | j                   r‚| j                  j                  t        j                  «       | j
                  ¬«      ƒ d {  –—† j                  }t        j                  |D �cg c]  }t        j                  |«      ‘Œ c}¬«      S | j                  j                  j                  «       ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ†c c}w 7 Œ ­w)Nrì   rí  zGet aliases returned None)rS   rË   ÚListAliasesr   ÚListAliasesRequestrz   rî  rh  rñ  r   rò  r:   rç  Úget_collections_aliasesr  ©r‡   r8   r9  rô  r  s        r•   Úget_aliaseszAsyncQdrantRemote.get_aliasesŒ  sÌ   è ø€ Ø×Òà×+Ñ+×7Ñ7Ü×+Ñ+Ó-°t·}±}ð 8ó ÷ ÷ ‰gð	 ô
 ×3Ñ3àYaöØJU”J×8Ñ8¸ÕEòôð ð —)‘)×'Ñ'×?Ñ?ÓA×Aß
‰&ð 	ð Ð!Ð>Ð#>Ó>Ð!Øˆðúò
ð
 Búó0   ‚A	CÁCÁ!CÁ-CÂ	/CÂ8CÂ9CÃCc              ‹   óº  K  — | j                   r‚| j                  j                  t        j                  «       | j
                  ¬«      ƒ d {  –—† j                  }t        j                  |D �cg c]  }t        j                  |«      ‘Œ c}¬«      S | j                  j                  j                  «       ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ†c c}w 7 Œ ­w)Nrì   )ÚcollectionszGet collections returned None)rS   rË   ÚListr   ÚListCollectionsRequestrz   rý  rh  ÚCollectionsResponser   Úconvert_collection_descriptionr:   Úcollections_apiÚget_collectionsr  rù  s        r•   r  z!AsyncQdrantRemote.get_collectionsž  sÐ   è ø€ Ø×Òà×+Ñ+×0Ñ0Ü×/Ñ/Ó1¸4¿=¹=ð 1ó ÷ ÷ ‰kð	 ô
 ×,Ñ,ð (0öà#ô ×=Ñ=¸kÕJòôð ð —)‘)×+Ñ+×;Ñ;Ó=×=ß
‰&ð 	ð Ð!ÐBÐ#BÓBÐ!Øˆðúò
ð >úrû  c              ‹   óp  K  — | j                   r`t        j                  | j                  j	                  t        j                  |¬«      | j                  ¬«      ƒ d {  –—† j                  «      S | j                  j                  j                  |¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 ŒU7 Œ­w)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 AsyncQdrantRemote.get_collection±  s«   è ø€ Ø×ÒÜ×5Ñ5à×/Ñ/×3Ñ3Ü×5Ñ5ÀoÔVØ $§¡ð 4ó ÷ ÷ ‘&óð ð —)‘)×+Ñ+×:Ñ:È?Ð:Ó[×[ß
‰&ð 	ð Ð!ÐAÐ#AÓAÐ!Øˆðøð \ús$   ‚AB6ÁB2Á;B6ÂB4ÂB6Â4B6c              ‹   ór  K  — | j                   rW| j                  j                  t        j                  |¬«      | j
                  ¬«      ƒ d {  –—† j                  j                  S | j                  j                  j                  |¬«      ƒ d {  –—† j                  }|€J d«       ‚|j                  S 7 Œe7 Œ%­w)Nrì  rì   zCollection exists returned None)rS   rË   ÚCollectionExistsr   ÚCollectionExistsRequestrz   r  Úexistsr:   r  Úcollection_existsr  s       r•   r  z#AsyncQdrantRemote.collection_existsÁ  s¦   è ø€ Ø×Òà×+Ñ+×<Ñ<Ü×0Ñ0ÀÔQØ ŸM™Mð =ó ÷ ÷ ‰f—V‘Vðð —)‘)×+Ñ+×=Ñ=ÈoÐ=Ó^×^ß
‰&ð 	ð Ð!ÐDÐ#DÓDÐ!Ø�}‰}Ððøð _ús%   ‚AB7ÁB3ÁAB7ÂB5Â$B7Â5B7Úoptimizers_configÚcollection_paramsÚvectors_configÚhnsw_configÚquantization_configÚsparse_vectors_configÚstrict_mode_configrC   c              ‹   ó>  K  — | j                   �r½t        |t        j                  «      rt	        j
                  |«      }t        |t        j                  «      rt	        j                  |«      }t        |t        «      rt	        j                  |«      }t        |t        j                  «      rt	        j                  |«      }t        |t        t        j                  «      «      rt	        j                  |«      }t        |t        «      rt	        j                  |«      }t        |	t        j                   «      rt	        j"                  |	«      }	t        |
t        «      rt	        j$                  |
«      }
| j&                  j)                  t+        j,                  ||||||||	||
¬«
      |�|n| j.                  ¬«      ƒ d {  –—† 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,                  |||||||	|
¬«      |¬«      ƒ d {  –—† j0                  }|€J d«       ‚|S 7 �ŒZ7 Œ­w)N)
rØ   r  rê   r  r  r  r  r  r1   rC   rì   )r  rê   rt  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#AsyncQdrantRemote.update_collectionÏ  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Ó?�à×+Ñ+×2Ñ2Ü×)Ñ)Ø(7Ø*;Ø0Ø'5Ø$/Ø,?Ø.CØ+=Ø 'Ø!)ôð (/Ð':™GÀÇÁð 3ó ÷ ÷ ‰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Ðà—)‘)×+Ñ+×=Ñ=ØÜ"(×"9Ñ"9Ø&7Ø,Ø*Ø +Ø(;Ø#8Ø'9Ø%ô	#ð  ð >ó ÷ ÷ ‰&ð 	ð  Ð!ÐDÐ#DÓDÐ!ØˆðWùð6ús%   ‚F<LÆ>LÆ?D?LË>LË?LÌLc              ‹   óV  K  — | j                   rR| j                  j                  t        j                  ||¬«      |�|n| j
                  ¬«      ƒ d {  –—† j                  S | j                  j                  j                  ||¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 ŒR7 Œ­w)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#AsyncQdrantRemote.delete_collection   s¬   è ø€ ð ×Òà×+Ñ+×2Ñ2Ü×)Ñ)¸/ÐSZÔ[Ø'.Ð':™GÀÇÁð 3ó ÷ ÷ ‰fðð —)‘)×+Ñ+×=Ñ=¸oÐW^Ð=Ó_×_ß
‰&ð 	ð Ð!ÐDÐ#DÓDÐ!Øˆðøð `ús$   ‚AB)ÁB%Á8B)ÂB'ÂB)Â'B)Úshard_numberÚreplication_factorÚwrite_consistency_factorÚon_disk_payloadÚ
wal_configÚsharding_methodc              ‹   ór  K  — | 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                  ¬«      ƒ d {  –—† 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?                  |||¬«      ƒ d {  –—† j6                  }|€J d«       ‚|S 7 �Œ27 Œ­w)N)rØ   r  r0  r  r,  r/  r1   r  r-  r.  r  r  r1  r  rC   rì   )rt  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#AsyncQdrantRemote.create_collection0  sÉ  è ø€ ð& ×ÓÜ˜.¬6×+>Ñ+>ÄÐ*EÔFÜ!+×!BÑ!BÀ>Ó!R�Ü˜+¤v×'<Ñ'<Ô=Ü(×AÑAÀ+ÓN�ÜÐ+¬V×-HÑ-HÔIÜ$.×$MÑ$MÐN_Ó$`Ð!Ü˜*¤f×&:Ñ&:Ô;Ü'×?Ñ?À
ÓK�
ÜÐ-¬x¼×8QÑ8QÓ/RÔSÜ&0×&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Ø!ô!Ðð$ ×+Ñ+×2Ñ2Ð3DÈdÏmÉmÐ2Ó\×\ß‰fðô �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Øô%
Ð!ð  —)‘)×+Ñ+×=Ñ=Ø /Ø";Øð >ó ÷ ÷
 ‰&ð 	ð Ð!ÐDÐ#DÓDÐ!ØˆðC ]ùð4ús%   ‚G>L7È L2ÈDL7ÌL5ÌL7Ì5L7c              ‹   ó˜   K  — | j                  ||¬«      ƒ d {  –—†  | j                  |||||||||	|
|||||¬«      ƒ d {  –—† S 7 Œ,7 Œ­w)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%AsyncQdrantRemote.recreate_collection�  sw   è ø€ ð& ×$Ñ$ _¸gÐ$ÓF×FÐFØ×+Ñ+Ø+Ø)Ø%Ø1Ø%=Ø+Ø#Ø/Ø!Ø 3ØØ"7Ø+Ø1Øð ,ó 
÷ 
ð 	
ð 	Gøð
ús!   ‚A
™Aš'A
ÁAÁA
ÁA
c                 ó2   — | j                   rt        S t        S r�   )rS   r#   r$   rž   s    r•   Ú_updater_classz AsyncQdrantRemote._updater_class³  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   rn  rå   r²   r1   rp  rq  )rØ   ÚurirD  rn  rå   rp  rq  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  rn  rå   rp  rq  rK  Úupdater_kwargsÚupdaterrŽ   Úpools                  r•   Ú_upload_collectionz$AsyncQdrantRemote._upload_collectionº  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  rn  rå   rp  rq  )rB  Úiterate_records_batchesrQ  )r‡   rØ   rî   rR  rE  rF  rD  rn  rå   rp  rq  r8   rC  s                r•   Úupload_pointszAsyncQdrantRemote.upload_pointsò  sV   € ð  ×.Ñ.×FÑFØ zð Gó 
Ðð 	×ÑØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 õ 
	
r    c                 óv   — | j                   j                  ||||¬«      }| j                  ||||||	|
||¬«	       y )N)rt  ru  r{  rR  rU  )rB  Úiterate_batchesrQ  )r‡   rØ   rt  ru  r{  rR  rE  rF  rD  rn  rå   rp  rq  r8   rC  s                  r•   Úupload_collectionz#AsyncQdrantRemote.upload_collection  sY   € ð   ×.Ñ.×>Ñ>Ø W°#À*ð ?ó 
Ðð 	×ÑØ-Ø+Ø#ØØØØ1Ø'Ø#ð 	 õ 
	
r    Ú
field_nameÚfield_schemaÚ
field_typec           	   ‹   ó¶  K  — |�t        dt        dd¬«       |}| j                  �rþd }	t        |t        j
                  «      rt        j                  |«      }t        |t        «      r(t        j                  t	        j
                  |«      «      }t        |t        «      rt        |«      }t        |t        t        j                  «      «      rt        j                  |«      }t        |t        j                  «      �r¿|}	|	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                  ¬«      ƒ d {  –—† jR                  «      S t        |t        «      rtI        j                  |«      }t        |t        j                  «      rtI        j                  |«      }| jT                  jV                  jY                  |t	        jN                  ||¬«      |||¬	«      ƒ d {  –—† jR                  }|€J d
«       ‚|S 7 ŒÂ7 Œ­w)Nz2field_type is deprecated, use field_schema insteadr(   zpayload-index-field-type)rF   rG   rH   r‹  Úindex_params)rØ   r[  r]  Úfield_index_paramsrn  ro  r1   rì   )r[  r\  )rØ   Úcreate_field_indexrn  ro  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]  rn  ro  r1   r8   r`  r·  r_  Úrequestr  s                 r•   Úcreate_payload_indexz&AsyncQdrantRemote.create_payload_index.  sù  è ø€ ð Ð!ÜØLÜ+ØØ.õ	ð &ˆLØ×ÓØ!%ÐÜ˜,¬×(@Ñ(@ÔAÜ)×EÑEÀlÓS�Ü˜,¬Ô,Ü)×EÑEÜ×,Ñ,¨\Ó:ó �ô ˜,¬Ô,Ü@ÀÓ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Ø×'Ñ'×8Ñ8¸È$Ï-É-Ð8ÓX×X×`Ñ`óð ô �l¤CÔ(Ü%×AÑAÀ,ÓOˆLÜ�l¤D×$;Ñ$;Ô<Ü%×CÑCÀLÓQˆLà×%Ñ%×1Ñ1×DÑDØ /Ü#)×#:Ñ#:Ø)¸ô$ð Ø!Øð Eó ÷ ÷ ‰&ð 	ð Ð!ÐEÐ#EÓEÐ!Øˆð% Yøðús%   ‚LOÌOÌB(OÎ;OÎ<OÏOc              ‹   ó„  K  — | j                   rft        j                  |||||¬«      }t        j                  | j
                  j                  || j                  ¬«      ƒ d {  –—† j                  «      S | j                  j                  j                  |||||¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 ŒY7 Œ­w)N)rØ   r[  rn  ro  r1   rì   z Delete field index returned None)rS   r   ÚDeleteFieldIndexCollectionr   r†  rÍ   ÚDeleteFieldIndexrz   r  r|   r|  Údelete_field_index)	r‡   rØ   r[  rn  ro  r1   r8   r}  r  s	            r•   Údelete_payload_indexz&AsyncQdrantRemote.delete_payload_index  sÒ   è ø€ ð ×ÒÜ×5Ñ5Ø /Ø%ØØ!ØôˆGô ×3Ñ3Ø×'Ñ'×8Ñ8¸È$Ï-É-Ð8ÓX×X×`Ñ`óð ð ×%Ñ%×1Ñ1×DÑDØ /Ø%ØØ!Øð Eó ÷ ÷ ‰&ð 	ð Ð!ÐEÐ#EÓEÐ!Øˆð Yøðús$   ‚A C Á"B<Á#?C Â"B>Â#C Â>C c              ‹   óš  K  — | j                   rp| j                  j                  t        j                  |¬«      | j
                  ¬«      ƒ d {  –—† j                  }|D �cg c]  }t        j                  |«      ‘Œ c}S | j                  j                  j                  |¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œtc c}w 7 Œ ­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 AsyncQdrantRemote.list_snapshotsŸ  sÄ   è ø€ ð ×Òà×)Ñ)×.Ñ.Ü×-Ñ-¸oÔNØ ŸM™Mð /ó ÷ ÷ $Ñ#ð ð W`Ö`È(”J×;Ñ;¸HÕEÒ`Ð`à×%Ñ%×3Ñ3×BÑBÐSbÐBÓc×cß
‰&ð 	ð Ð$ÐOÐ&OÓOÐ$ØÐðúò
 aàcús0   ‚ACÁCÁCÁ CÁ<,CÂ(C	Â)CÃCc              ‹   ó`  K  — | j                   rb| j                  j                  t        j                  |¬«      | j
                  ¬«      ƒ d {  –—† j                  }t        j                  |«      S | j                  j                  j                  ||¬«      ƒ d {  –—† j                  S 7 Œ\7 Œ­w)Nrì  rì   )rØ   rn  )rS   rÏ   r=  r   ÚCreateSnapshotRequestrz   Úsnapshot_descriptionr   rˆ  r|   r‰  Úcreate_snapshotr  )r‡   rØ   rn  r8   rŒ  s        r•   r�  z!AsyncQdrantRemote.create_snapshot°  s¥   è ø€ ð ×Òà×)Ñ)×0Ñ0Ü×.Ñ.¸ÔOØ ŸM™Mð 1ó ÷ ÷ #Ñ"ð ô ×:Ñ:¸8ÓDÐDà×%Ñ%×3Ñ3×CÑCØ /°dð Dó ÷ ÷ ‰&ð		ðøðús%   ‚AB.ÁB*ÁAB.ÂB,ÂB.Â,B.Úsnapshot_namec              ‹   ó(  K  — | j                   rE| j                  j                  t        j                  ||¬«      | j
                  ¬«      ƒ d {  –—†  y| j                  j                  j                  |||¬«      ƒ d {  –—† j                  S 7 Œ?7 Œ­w)N)rØ   r‘  rì   T)rØ   r‘  rn  )
rS   rÏ   r¾  r   ÚDeleteSnapshotRequestrz   r|   r‰  Údelete_snapshotr  )r‡   rØ   r‘  rn  r8   s        r•   r”  z!AsyncQdrantRemote.delete_snapshotÁ  s™   è ø€ ð ×ÒØ×%Ñ%×,Ñ,Ü×*Ñ*Ø$3À=ôð Ÿ™ð	 -ó ÷ ð ð à×%Ñ%×3Ñ3×CÑCØ /¸}ÐSWð Dó ÷ ÷ ‰&ð		ðøðús$   ‚ABÁBÁ0BÁ?BÂ BÂBc              ‹   ó’  K  — | j                   rn| j                  j                  t        j                  «       | j
                  ¬«      ƒ d {  –—† j                  }|D �cg c]  }t        j                  |«      ‘Œ c}S | j                  j                  j                  «       ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œrc c}w 7 Œ ­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%AsyncQdrantRemote.list_full_snapshotsÒ  sµ   è ø€ Ø×Òà×)Ñ)×2Ñ2Ü×1Ñ1Ó3¸T¿]¹]ð 3ó ÷ ÷ $Ñ#ð	 ð
 W`Ö`È(”J×;Ñ;¸HÕEÒ`Ð`Ø×.Ñ.×<Ñ<×PÑPÓR×R×ZÑZˆ	ØÐ$ÐTÐ&TÓTÐ$ØÐðúò aØRús0   ‚A	CÁB>ÁCÁC Á:*CÂ$CÂ%CÃ Cc              ‹   óZ  K  — | j                   r`| j                  j                  t        j                  «       | j
                  ¬«      ƒ d {  –—† j                  }t        j                  |«      S | j                  j                  j                  |¬«      ƒ d {  –—† j                  S 7 Œ[7 Œ­w)Nrì   )rn  )rS   rÏ   Ú
CreateFullr   ÚCreateFullSnapshotRequestrz   r�  r   rˆ  r|   r‰  Úcreate_full_snapshotr  )r‡   rn  r8   r�  s       r•   rœ  z&AsyncQdrantRemote.create_full_snapshotÞ  s˜   è ø€ ð ×Òà×)Ñ)×4Ñ4Ü×2Ñ2Ó4¸d¿m¹mð 5ó ÷ ÷ #Ñ"ð	 !ô
 ×:Ñ:Ð;OÓPÐPØ×)Ñ)×7Ñ7×LÑLÐRVÐLÓW×W×_Ñ_Ð_ðøð
 Xús%   ‚A	B+ÁB'ÁAB+ÂB)ÂB+Â)B+c              ‹   ó$  K  — | j                   rD| j                  j                  t        j                  |¬«      | j
                  ¬«      ƒ d {  –—†  y| j                  j                  j                  ||¬«      ƒ d {  –—† j                  S 7 Œ>7 Œ­w)N)r‘  rì   T)r‘  rn  )
rS   rÏ   Ú
DeleteFullr   ÚDeleteFullSnapshotRequestrz   r|   r‰  Údelete_full_snapshotr  )r‡   r‘  rn  r8   s       r•   r   z&AsyncQdrantRemote.delete_full_snapshotê  s‘   è ø€ ð ×ÒØ×%Ñ%×0Ñ0Ü×.Ñ.¸]ÔKÐUY×UbÑUbð 1ó ÷ ð ð à×%Ñ%×3Ñ3×HÑHØ+°$ð Ió ÷ ÷ ‰&ð		ð	øð
ús$   ‚ABÁBÁ/BÁ=BÁ>BÂBÚlocationÚchecksumÚpriorityc           
   ‹   ó°   K  — | j                   j                  j                  ||t        j                  ||||¬«      ¬«      ƒ d {  –—† j
                  S 7 Œ­w)N©r¡  r£  r¢  r/   )rØ   rn  Úsnapshot_recover)r|   r‰  Úrecover_from_snapshotr!   ÚSnapshotRecoverr  )r‡   rØ   r¡  r/   r¢  r£  rn  r8   s           r•   Úrecover_snapshotz"AsyncQdrantRemote.recover_snapshotø  s\   è ø€ ð ×%Ñ%×3Ñ3×IÑIØ /ØÜ!'×!7Ñ!7Ø%°À8ÐU\ô"ð Jó ÷ ÷ ‰&ð	ðús   ‚AAÁAÁAÚshard_idc              ‹   ó–   K  — | j                   j                  j                  ||¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ­w)N)rØ   rª  r…  )r|   r‰  Úlist_shard_snapshotsr  )r‡   rØ   rª  r8   r‹  s        r•   r¬  z&AsyncQdrantRemote.list_shard_snapshots	  s]   è ø€ ð ×%Ñ%×3Ñ3×HÑHØ /¸(ð Ió ÷ ÷ ‰&ð	 	ð
 Ð$ÐOÐ&OÓOÐ$ØÐðúó   ‚+A	­A®A	c              ‹   ó‚   K  — | j                   j                  j                  |||¬«      ƒ d {  –—† j                  S 7 Œ­w)N)rØ   rª  rn  )r|   r‰  Úcreate_shard_snapshotr  )r‡   rØ   rª  rn  r8   s        r•   r¯  z'AsyncQdrantRemote.create_shard_snapshot	  sE   è ø€ ð ×%Ñ%×3Ñ3×IÑIØ /¸(Èð Jó ÷ ÷ ‰&ð		ðús   ‚,?®=¯?c              ‹   ó„   K  — | j                   j                  j                  ||||¬«      ƒ d {  –—† j                  S 7 Œ­w)N)rØ   rª  r‘  rn  )r|   r‰  Údelete_shard_snapshotr  )r‡   rØ   rª  r‘  rn  r8   s         r•   r±  z'AsyncQdrantRemote.delete_shard_snapshot 	  sJ   è ø€ ð ×%Ñ%×3Ñ3×IÑIØ /Ø!Ø+Øð	 Jó ÷ ÷ ‰&ð	ðús   ‚-A ¯>°A c              ‹   ó²   K  — | j                   j                  j                  |||t        j                  ||||¬«      ¬«      ƒ d {  –—† j
                  S 7 Œ­w)Nr¥  )rØ   rª  rn  Úshard_snapshot_recover)r|   r‰  Úrecover_shard_from_snapshotr!   ÚShardSnapshotRecoverr  )	r‡   rØ   rª  r¡  r/   r¢  r£  rn  r8   s	            r•   Úrecover_shard_snapshotz(AsyncQdrantRemote.recover_shard_snapshot1	  s_   è ø€ ð ×%Ñ%×3Ñ3×OÑOØ /Ø!ØÜ'-×'BÑ'BØ%°À8ÐU\ô(ð	 Pó ÷ ÷ ‰&ð		ðús   ‚AAÁAÁArï   Úshards_numberÚ	placementÚinitial_statec              ‹   ó�  K  — | j                   rÖt        |t        t        j                  «      «      rt        j                  |«      }t        |t        j                  «      rt        j                  |«      }| j                  j                  t        j                  ||t        j                  ||||xs g |¬«      ¬«      |�|n| j                  ¬«      ƒ d {  –—† j                  S | j                  j                   j#                  ||t        j$                  |||||¬«      ¬«      ƒ d {  –—† j                  }	|	€J d«       ‚|	S 7 Œk7 Œ­w)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"AsyncQdrantRemote.create_shard_keyG	  s>  è ø€ ð ×ÒÜ˜)Ô%8¼¿¹Ó%IÔJÜ&×8Ñ8¸ÓC�	Ü˜-¬×)<Ñ)<Ô=Ü *× @Ñ @ÀÓ O�à×+Ñ+×:Ñ:Ü×.Ñ.Ø(7Ø 'Ü $× 3Ñ 3Ø&/Ø*7Ø/AØ&/¢o°2Ø*7ô!ô
ð (/Ð':™GÀÇÁð ;ó ÷ ÷ ‰fðð$ ×)Ñ)×9Ñ9×JÑJØ$3Ø#Ü(.×(@Ñ(@Ø"+Ø&3Ø+=Ø"+Ø&3ô)ð Kó 
÷ 
÷ ‰fð ð Ð%ÐGÐ'GÓGÐ%ØˆMð=øð"
ús%   ‚CEÃEÃAEÄ(EÄ)EÅEc           	   ‹   ó  K  — | j                   rŸt        |t        t        j                  «      «      rt        j                  |«      }| j                  j                  t        j                  ||t        j                  |¬«      ¬«      |�|n| j                  ¬«      ƒ d {  –—† j                  S | j                  j                  j                  ||t        j                   |¬«      ¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œg7 Œ­w)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"AsyncQdrantRemote.delete_shard_keyx	  sü   è ø€ ð ×ÒÜ˜)Ô%8¼¿¹Ó%IÔJÜ&×8Ñ8¸ÓC�	à×+Ñ+×:Ñ:Ü×.Ñ.Ø(7Ø 'Ü $× 3Ñ 3¸iÔ Hôð
 (/Ð':™GÀÇÁð ;ó ÷ ÷ ‰fð	ð ×)Ñ)×9Ñ9×JÑJØ$3Ø#Ü&,×&<Ñ&<ÀyÔ&Qð Kó ÷ ÷
 ‰fð ð Ð%ÐGÐ'GÓGÐ%ØˆMð%øðús%   ‚BDÂDÂ ADÃ-D	Ã.DÄ	Dc              ƒ   óD  K  — | j                   rV| j                  j                  t        j                  «       | j
                  ¬«      ƒ d {  –—† }t        j                  |«      S | j                  j                  j                  «       ƒ d {  –—† }|€J d«       ‚|S 7 ŒP7 Œ­w)Nrì   zHealthcheck returned None)rS   rÑ   ÚHealthCheckr   ÚHealthCheckRequestrz   r   Úconvert_health_check_replyrÕ   Úservice_apiÚroot)r‡   Úversion_infos     r•   ÚinfozAsyncQdrantRemote.info—	  s�   è ø€ Ø×ÒØ!%§¡×!;Ñ!;Ü×'Ñ'Ó)°4·=±=ð "<ó "÷ ˆLô ×8Ñ8¸ÓFÐFØ!ŸY™Y×2Ñ2×7Ñ7Ó9×9ˆØÐ'ÐDÐ)DÓDÐ'ØÐðøð :ús%   ‚A	B ÁBÁA B ÂBÂB ÂB Úcluster_operationc              ‹   ó¦  K  — | j                   �rxt        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
œ|¤Ž|�|n| j"                  ¬«      ƒ d {  –—† j$                  S | j&                  j(                  j+                  |||¬«      ƒ d {  –—† j$                  }|€J d«       ‚|S 7 ŒS7 Œ­w)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+AsyncQdrantRemote.cluster_collection_update¡	  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à×+Ñ+×HÑHÜ×<Ñ<ð Ø(7ÀñØLZñð (/Ð':™GÀÇÁð	 Ió ÷ ÷ ‰fðð —)‘)×+Ñ+×EÑEØ /Ø#4Øð Fó ÷ ÷
 ‰&ð 	ð Ð(ÐSÐ*SÓSÐ(ØÐðøðús$   ‚E7GÅ9GÅ:9GÆ3GÆ4GÇGc              ƒ   ó�   K  — | j                   j                  j                  «       ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ­w)NzCluster status returned None)rÕ   rÃ  Úcluster_statusr  )r‡   Ústatus_results     r•   rë  z AsyncQdrantRemote.cluster_statusÏ	  sE   è ø€ Ø#Ÿy™y×8Ñ8×GÑGÓI×I×QÑQˆØÐ(ÐHÐ*HÓHÐ(ØÐð Júó   ‚(AªA«Ac              ƒ   ó�   K  — | j                   j                  j                  «       ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ­w)Nz"Recover current peer returned None)rÕ   rÃ  Úrecover_current_peerr  )r‡   Úrecover_results     r•   rï  z&AsyncQdrantRemote.recover_current_peerÔ	  sE   è ø€ Ø $§	¡	× 9Ñ 9× NÑ NÓ P×P×XÑXˆØÐ)ÐOÐ+OÓOÐ)ØÐð Qúrí  Úpeer_idÚforcec              ‹   ó˜   K  — | j                   j                  j                  |||¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ­w)N)rñ  rò  r1   zRemove peer returned None)rÕ   rÃ  Úremove_peerr  )r‡   rñ  rò  r1   r8   rè  s         r•   rô  zAsyncQdrantRemote.remove_peerÙ	  s\   è ø€ ð —)‘)×+Ñ+×7Ñ7Ø u°gð 8ó ÷ ÷ ‰&ð	 	ð
 Ð(ÐEÐ*EÓEÐ(ØÐðús   ‚,A
®A¯A
c              ƒ   ó`  K  — | j                   rX| j                  j                  t        j                  |¬«      | j
                  ¬«      ƒ d {  –—† }t        j                  |«      S | j                  j                  j                  |¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ\7 Œ­w)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)AsyncQdrantRemote.collection_cluster_infoä	  s¯   è ø€ Ø×ÒØ$(×$9Ñ$9×$OÑ$OÜ×1Ñ1À/ÔRØŸ™ð %Pó %÷ ˆOô ×=Ñ=¸oÓNÐNà—)‘)×+Ñ+×CÑCØ /ð Dó ÷ ÷ ‰&ð	 	ð
 Ð*ÐSÐ,SÓSÐ*ØÐðøðús%   ‚AB.ÁB*ÁAB.ÂB,ÂB.Â,B.Úcompleted_limitc              ‹   ó–   K  — | j                   j                  j                  ||¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ­w)N)rØ   rû  zGet optimizations returned None)r:   r  Úget_optimizationsr  )r‡   rØ   rû  r8   r  s        r•   rý  z#AsyncQdrantRemote.get_optimizationsó	  sY   è ø€ ð —)‘)×+Ñ+×=Ñ=Ø /Àð >ó ÷ ÷ ‰&ð	 	ð
 Ð!ÐDÐ#DÓDÐ!Øˆðúr­  c           
   ‹   óþ  K  — | j                   r¢| j                  j                  t        j                  |¬«      | j
                  ¬«      ƒ d {  –—† }t        j                  |j                  D �cg c]5  }t        j                  t        j                  |j                  «      ¬«      ‘Œ7 c}¬«      S | j                  j                  j                  |¬«      ƒ d {  –—† j                   }|€J d«       ‚|S 7 Œ¦c c}w 7 Œ ­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   r9  Úskr  s         r•   r  z!AsyncQdrantRemote.list_shard_keysþ	  sì   è ø€ ð ×ÒØ!×2Ñ2×@Ñ@Ü×)Ñ)¸/ÔJÐTX×TaÑTað Aó ÷ ˆHô ×+Ñ+ð '×1Ñ1öàô ×.Ñ.´:×3OÑ3OÐPR×PVÑPVÓ3WÖXòôð ð —)‘)×+Ñ+×;Ñ;ÈOÐ;Ó\×\ß
‰&ð 	ð Ð!ÐBÐ#BÓBÐ!Øˆðúòð ]ús0   ‚AC=ÁC4Á!C=Á/:C6Â)1C=ÃC;ÃC=Ã6C=Údetails_levelc              ‹   ó–   K  — | j                   j                  j                  ||¬«      ƒ d {  –—† j                  }|€J d«       ‚|S 7 Œ­w)N)r  r1   zCluster telemetry returned None)rÕ   rÃ  Úcluster_telemetryr  )r‡   r  r1   r8   r  s        r•   r  z#AsyncQdrantRemote.cluster_telemetry
  sY   è ø€ ð —)‘)×+Ñ+×=Ñ=Ø+°Wð >ó ÷ ÷ ‰&ð	 	ð
 Ð!Ð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:   rh  rN  rõ   ÚSparseVectorr  Ú
NumpyArrayÚDocumentÚImageÚInferenceObjectró   rö   rø   r
   ÚPayloadSelectorrþ   r   r  r  r  r  r  ÚWithLookupInterfaceÚGroupsResultr,  ÚSearchMatrixPairsResponser6  ÚSearchMatrixOffsetsResponser?  rO  ÚRecordrV  ÚCountResultra  ri  rk  ÚPointsr€  r‚  ÚUpdateResultrŽ  ÚPointVectorsr�  r«  r˜  r¨  Úclassmethodr™  r!   r²  r¹  rE  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[Ø$(Ø $Ø)-ñ`à�4‰Zð`ð �D‰jð`ð ð	`ð
 ð`ð �d‰{ð`ð �t‘ð`ð �d‘
ð`ð �t‘ð`ð �D‰jð`ð ˜3 ˜8‘n tÑ+ð`ð & b¨# gÑ.°¸"¸iÈ¹nÐ:LÑ1MÑMÐPTÑTð`ð "ð`ð ˜‘:ð`ð �c˜3�h‘ $Ñ&ð`ð  õ!`ðD ðØðØ%)¨#¨s¨(¡^ðØ;>ðØILðà	òó ðð2 ð˜ò ó ðñ e¨d¡lð ÀSð ÈTó ð. ð,˜ð ,  c¨D¡j°#°s¸T±zÀ3ÈÁ:Ð&MÑ Nò ,ó ð,ð	/ Só 	/óRó*
ó
ó
ó
ð 3ó ð ð	L $×"6Ñ"6ò 	Ló ð	Lð ð	G˜TŸ_™_ò 	Gó ð	Gð ð	J × 2Ñ 2ò 	Jó ð	Jð ð	E˜4Ÿ?™?ò 	Eó ð	Eð ð#�i Ñ/ò #ó ð#ð ð#�i Ñ/ò #ó ð#ð( Ø ØAEØ,0Ø37ØØ!ØEIØ-2Ø(,Ø37Ø48Ø<@Ø"ñ3iàðið �}‰}Ø
ˆu‰+ñà
ˆt�E‰{Ñ
ñð ×
Ñ
ñð �+‰+ñ	ð
 ×
Ñ
ñð �.‰.ñð �+‰+ñð ×
Ñ
ñ ð ñ	ðið �T‰zðið —.‘. 4¨¯©Ñ#7Ñ7¸$Ñ>ðið —l‘l TÑ)ðið  ×)Ñ)¨DÑ0ð!ið" ð#ið$ �d‘
ð%ið& ˜X c™]Ñ*¨U×-BÑ-BÑBð'ið( ˜X c™]Ñ*ð)ið*  ™ð+ið, ×)Ñ)¨DÑ0ð-ið. ×*Ñ*¨TÑ1ð/ið0 "×2Ñ2°TÑ9ð1ið2 �t‘ð3ið4 ð5ið6 
×	Ñ	ó7ið^ 59Ø"ñ*àð*ð ˜5×-Ñ-Ñ.ð*ð ×*Ñ*¨TÑ1ð	*ð
 �t‘ð*ð ð*ð 
ˆe×!Ñ!Ñ	"ó*ðr Ø ØAEØ,0Ø37ØØØEIØ-2Ø(,Ø8<Ø37Ø48Ø<@Ø"ñ7s'àðs'ð ðs'ð �}‰}Ø
ˆu‰+ñà
ˆt�E‰{Ñ
ñð ×
Ñ
ñð �+‰+ñ	ð
 ×
Ñ
ñð �.‰.ñð �+‰+ñð ×
Ñ
ñ ð ñ	ð	s'ð �T‰zðs'ð —.‘. 4¨¯©Ñ#7Ñ7¸$Ñ>ðs'ð  —l‘l TÑ)ð!s'ð" ×)Ñ)¨DÑ0ð#s'ð$ ð%s'ð& ð's'ð( ˜X c™]Ñ*¨U×-BÑ-BÑBð)s'ð* ˜X c™]Ñ*ð+s'ð,  ™ð-s'ð. ×.Ñ.°Ñ5ð/s'ð0 ×)Ñ)¨DÑ0ð1s'ð2 ×*Ñ*¨TÑ1ð3s'ð4 "×2Ñ2°TÑ9ð5s'ð6 �t‘ð7s'ð8 ð9s'ð: 
×	Ñ	ó;s'ðp -1ØØØ Ø48Ø<@Ø"ñ2$àð2$ð —l‘l TÑ)ð2$ð ð	2$ð
 ð2$ð �T‰zð2$ð ×*Ñ*¨TÑ1ð2$ð "×2Ñ2°TÑ9ð2$ð �t‘ð2$ð ð2$ð 
×	(Ñ	(ó2$ðn -1ØØØ Ø48Ø<@Ø"ñ2$àð2$ð —l‘l TÑ)ð2$ð ð	2$ð
 ð2$ð �T‰zð2$ð ×*Ñ*¨TÑ1ð2$ð "×2Ñ2°TÑ9ð2$ð �t‘ð2$ð ð2$ð 
×	*Ñ	*ó2$ðn .2ØØ)-Ø'+ØEIØ-2Ø48Ø<@Ø"ñLJàðLJð —|‘| dÑ*ðLJð ð	LJð
 —-‘- $Ñ&ðLJð —‘ Ñ$ðLJð ˜X c™]Ñ*¨U×-BÑ-BÑBðLJð ˜X c™]Ñ*ðLJð ×*Ñ*¨TÑ1ðLJð "×2Ñ2°TÑ9ðLJð �t‘ðLJð ðLJð 
ˆt�E—L‘LÑ! 5§=¡=°4Ñ#7Ð7Ñ	8óLJðb -1ØØ<@Ø"Ø48ñ,àð,ð —l‘l TÑ)ð,ð ð	,ð
 "×2Ñ2°TÑ9ð,ð �t‘ð,ð ×*Ñ*¨TÑ1ð,ð ð,ð 
×	Ñ	ó,ðd -1ØØØ"Ø48Ø<@ñ4àð4ð ð4ð —l‘l TÑ)ð	4ð
 ð4ð ð4ð �t‘ð4ð ×*Ñ*¨TÑ1ð4ð "×2Ñ2°TÑ9ð4ð ð4ð 
×	Ñ	ó4ðt Ø/3Ø<@Ø-1Ø/3Ø"ñ\àð\ð —‘ð\ð ð	\ð
 ×%Ñ%¨Ñ,ð\ð "×2Ñ2°TÑ9ð\ð —|‘| dÑ*ð\ð ×%Ñ%¨Ñ,ð\ð �t‘ð\ð ð\ð 
×	Ñ	ó\ðD Ø/3Ø<@Ø-1Ø"ñ0àð0ð ˜×+Ñ+Ñ,ð0ð ð	0ð
 ×%Ñ%¨Ñ,ð0ð "×2Ñ2°TÑ9ð0ð —|‘| dÑ*ð0ð �t‘ð0ð ð0ð 
×	Ñ	ó0ðn Ø/3Ø<@Ø"ñ2àð2ð ˜#‘ð2ð ×$Ñ$ð	2ð
 ð2ð ×%Ñ%¨Ñ,ð2ð "×2Ñ2°TÑ9ð2ð �t‘ð2ð ð2ð 
×	Ñ	ó2ðp FJØ-2Ø48Ø<@Ø"ñ>àð>ð �e—m‘mÑ$ð>ð ˜X c™]Ñ*¨U×-BÑ-BÑBð	>ð
 ˜X c™]Ñ*ð>ð ×*Ñ*¨TÑ1ð>ð "×2Ñ2°TÑ9ð>ð �t‘ð>ð ð>ð 
ˆe�l‰lÑ	ó>ð@ ð5Ø×)Ñ)ð5à	ˆt×"Ñ" D×$9Ñ$9¸DÑ$@Ð@Ñ	Aò5ó ð5ð> ðØ×)Ñ)ðØ?D×?UÑ?UÐX\Ñ?\ðà	×	Ñ	òó ðð> ð	Ø"×1Ñ1ð	à	ˆd�l‰lÑ	ò	ó ð	ð ð"Ø×)Ñ)ð"à	ˆt�F×*Ñ*Ñ+¨dÑ2°F·M±MÀDÑ4HÐHÑ	Iò"ó ð"ð@ Ø/3Ø<@Ø"ñ0àð0ð ×-Ñ-ð0ð ð	0ð
 ×%Ñ%¨Ñ,ð0ð "×2Ñ2°TÑ9ð0ð �t‘ð0ð ð0ð 
×	Ñ	ó0ðn ØØ/3Ø<@Ø"ñ6àð6ð —‘ð6ð ×$Ñ$ð	6ð
 �4‰Zð6ð ð6ð ×%Ñ%¨Ñ,ð6ð "×2Ñ2°TÑ9ð6ð �t‘ð6ð ð6ð 
×	Ñ	ó6ðz Ø/3Ø<@Ø"ñ3àð3ð —‘ð3ð ×$Ñ$ð	3ð
 ð3ð ×%Ñ%¨Ñ,ð3ð "×2Ñ2°TÑ9ð3ð �t‘ð3ð ð3ð 
×	Ñ	ó3ðt Ø/3Ø<@Ø"ñ0àð0ð �s‰mð0ð ×$Ñ$ð	0ð
 ð0ð ×%Ñ%¨Ñ,ð0ð "×2Ñ2°TÑ9ð0ð �t‘ð0ð ð0ð 
×	Ñ	ó0ðl Ø/3Ø<@Ø"ñ0àð0ð ×-Ñ-ð0ð ð	0ð
 ×%Ñ%¨Ñ,ð0ð "×2Ñ2°TÑ9ð0ð �t‘ð0ð ð0ð 
×	Ñ	ó0ðl Ø/3Ø"ñ)àð)ð $ E×$9Ñ$9Ñ:ð)ð ð	)ð
 ×%Ñ%¨Ñ,ð)ð �t‘ð)ð ð)ð 
ˆe× Ñ Ñ	!ó)ð\ #ñ"à#+¨E×,AÑ,AÑ#Bð"ð �t‘ð"ð ð	"ð
 
ó"ðHØ"ðØ.1ðà	×	)Ñ	)óð*¨#ð °%×2RÑ2Ró ð$¨cð °e×6OÑ6Oó ð&°Cð À3ð È5×K_ÑK_ó ð °sð Àcð Èdó ð" @DØ?CØ9=Ø37ØCGØ"ØOSØ<@Ø)-ñOàðOð !×5Ñ5¸Ñ<ðOð !×5Ñ5¸Ñ<ð	Oð
 ×/Ñ/°$Ñ6ðOð ×)Ñ)¨DÑ0ðOð #×9Ñ9¸DÑ@ðOð �t‘ðOð  ' s¨E×,DÑ,DÐ'DÑEÈÑLðOð "×2Ñ2°TÑ9ðOð —-‘- $Ñ&ðOð ðOð 
óOðd ;?ñØ"ðØ-0°4©ZðØJMðà	óð& 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ð[ð  —-‘- $Ñ&ð![ð" ð#[ð$ 
ó%[ð@ 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ð$
ð  —-‘- $Ñ&ð!$
ð" ð#$
ð$ 
ó%$
ðL ð%  \Ñ 2ò %ó ð%ð Ø!ØØ<@Ø-1Ø/3ñ6à"ð6ð ð6ð ð	6ð
 ð6ð �d‘
ð6ð ð6ð "×2Ñ2°TÑ9ð6ð —|‘| dÑ*ð6ð ×%Ñ%¨Ñ,ð6ð 
ó6ðx ØØ!ØØØ<@Ø-1Ø/3ñ
àð
ð ˜×*Ò*Ñ+ð
ð ð	
ð
 ð
ð �d‘
ð
ð ð
ð ð
ð "×2Ñ2°TÑ9ð
ð —|‘| dÑ*ð
ð ×%Ñ%¨Ñ,ð
ð ð
ð 
ó
ðB 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Ñ*ð
ð ×%Ñ%¨Ñ,ð
ð ð
ð 
ó
ðF 8<Ø59ØØ/3Ø"ñOàðOð ðOð ×-Ò-°Ñ4ð	Oð
 ×+Ò+¨dÑ2ðOð ðOð ×%Ñ%¨Ñ,ðOð �t‘ðOð ðOð 
×	Ñ	óOðj Ø/3Ø"ñàðð ðð ð	ð
 ×%Ñ%¨Ñ,ðð �t‘ðð ðð 
×	Ñ	óð@Ø"ðØ.1ðà	ˆe×'Ò'Ñ	(óð$ 26ñØ"ðØ*.ðØADðà	×	"Ò	" TÑ	)óð$ FJñØ"ðØ36ðØ>BðØUXðà	�‰óð"
°#ð 
¸$¸u×?XÒ?XÑ:Yó 
ð  ñ
`Øð
`Ø+.ð
`à	×	"Ò	"ó
`ð 04ñØ ðØ(,ðØ?Bðà	�‰óð$ #Ø#Ø26Øñàðð ðð �t‘ð	ð
 ˜‘*ðð ×(Ò(¨4Ñ/ðð ðð ðð 
�‰óð(	Ø"ð	Ø.1ð	Ø=@ð	à	ˆe×'Ò'Ñ	(ó	ð AEñØ"ðØ.1ðØ9=ðØPSðà	×	"Ò	" TÑ	)óð ñàðð ðð ð	ð
 ðð ðð 
�‰óð, #Ø#Ø26Øñàðð ðð ð	ð
 �t‘ðð ˜‘*ðð ×(Ò(¨4Ñ/ðð ðð ðð 
�‰óð4 %)Ø)-Ø&*Ø37Ø"ñ/àð/ð —>’>ð/ð ˜T‘zð	/ð
   $™Jð/ð ˜‘9˜tÑ#ð/ð ×)Ò)¨DÑ0ð/ð �t‘ð/ð ð/ð 
ó/ðj #ñ	àðð —>’>ðð �t‘ð	ð
 ðð 
óð>˜E×-Ò-ó ð #ñ	,àð,ð !×2Ò2ð,ð �t‘ð	,ð
 ð,ð 
ó,ð\ e×&9Ò&9ó ð
¨Dó ð NRñ	Øð	Ø#'¨$¡;ð	Ø@CÀdÁ
ð	Ø]`ð	à	ó	ð¸Sð ÀU×E`ÒE`ó ð  CGñ	Ø"ð	Ø58¸4±Zð	ØRUð	à	×	$Ò	$ó	ðØ"ðØ.1ðà	×	 Ò	 óð( GKñ	Ø  4™Zð	Ø9<¸t¹ð	ØVYð	à	×	'Ò	'÷	r    r'   )?Úimportlib.metadataro   rb   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.async_client_baser   Ú"qdrant_client.common.version_checkr   r   Úqdrant_client.connectionr   rµ   Úqdrant_client.conversionsr   rh  Ú&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>rE     ss   ðó Û Û Ý 1Ý ß X× XÓ XÛ Ý ß 'Ý  ß PÝ &Ý 4Ý )Ý ;ß PÝ EÝ ;Ý F÷ñ ÷
 AÑ @Ý ?Ý BÝ BÝ 8ôo'˜õ o'r    