%Gg~<ddlZddlZddlZddlmZmZddlmZmZm Z m Z m Z m Z ddl mZddlZddlmZddlmZddlmZmZddlmZdd lmZdd lmZdd l m!Z!dd l"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7ddl8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAddlBmCZCmDZDddlEmFZFddlGmHZHddlImJZJmKZKddlLmMZMddlNmOZOddlPmQZQmRZRmSZSddlTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_dZ`dZadedefdZGddZbd e ejd!edejdejfd"Zfd e ejd#edejdejfd$Zgd%ejdejFfd&Zid'ejd(ekdejfd)Zly)*N) OrderedDict defaultdict)AnyCallableOptionalSequenceUnionget_args)deepcopy)grpc)show_warning_once) constructto_jsonable_python) common_types)get_args_subscribed) GrpcToRest)models) ScoredPoint)DistanceExtendedPointId SparseVector OrderValue)reciprocal_rank_fusiondistribution_based_score_fusion) ContextPair ContextQueryDenseQueryVectorDiscoveryQuery DistanceOrder RecoQuerycalculate_context_scorescalculate_discovery_scorescalculate_distancecalculate_recommend_best_scoresdistance_to_order) MultiQueryVectorMultiRecoQueryMultiDiscoveryQueryMultiContextQueryMultiContextPaircalculate_multi_distance%calculate_multi_recommend_best_scores calculate_multi_discovery_scorescalculate_multi_context_scores) JsonPathItemparse_json_path)to_order_value)calculate_payload_mask) value_by_key parse_uuid)set_value_by_key)CollectionPersistence)empty_sparse_vectorsort_sparse_vectorvalidate_sparse_vector) SparseContextPairSparseContextQuerySparseDiscoveryQuerySparseQueryVectorSparseRecoQuerycalculate_distance_sparsecalculate_sparse_context_scores!calculate_sparse_discovery_scores&calculate_sparse_recommend_best_scoresmerge_positive_and_negative_avg sparse_avgg>xreturnc tjtj|dS#t$r2tjtj|dtcYSwxYw)NT) allow_nan)rIdefault)jsonloadsdumps Exception_to_jsonable_pythonrFs /home/kushmeetdev/apache_webroot/langgraph_flaskproject/venv/lib/python3.12/site-packages/qdrant_client/local/local_collection.pyrrQsPVzz$**Q$788 Vzz$**Q$@STUUVs),8A'&A'c!8eZdZdZdZ d~dej deede ddfdZ e d e eejfdee eejfe eejfffd Zdd Zd ed eddfdZd ed eddfdZedededefdZd ed edefdZddZedeeeeeeefeeeeeeeefej:ej<eeeefeee fe!eee!fejDf deeeee e!ejDfffdZ#dedejfdZ$ededede fdZ%ededede fdZ&e dde'de(ege fdede'fd Z)e dde d!ee e*eejVfdee fd"Z, dd#ed!ee e*eejVfd$e deejZfd%Z. dd#ed&ee e*edfdeej^fd'Z0 dd(eejbd eede2jffd)Z4 ddeeeeeeefeeeeeeeefej:ej<eeeefe eee fe!eee!fejDf d*eejbd+ed,eed!ee e*eejVfd&ee e*efd-eedeejjfd.Z6 dd/eejnd0eeejpd*eejbd+ed,ed!ee e*eejVfd&ee e*efd-eed1eed2e'dejrfd3Z:d0ejpd,edeejjfd4Z; dd5eeejjd/ejnd+ed,ed1eed*eejbd-eed!ee e*eejVfd&ee e*efdeejjfd6Z< dd/eejnd1eed*eejbd+eed,eed!ee e*eejVfd&ee e*efd-eedeejjfd7Z= dd8ed/eej|eeeeeej"ejnejDej~ejejdf d1eed0eejpeejpdfd*eejbd+ed9ed!ee e*eejVfd&ee e*efd-eed:eejd;eddejfd<ZD ddee*eeeeeeeejeFeGeHejDffej:ej<eFeGeHejDf d8ed*eejbd+ed9ed!ee e*eejVfd&ee e*efd-eed:eejd;eddejfd=ZI dded>eejbd+edejfd?ZK dd@e*ej|d!ee e*eejVfd&ee e*efdeejfdAZM ddBee*ejdCee*ejdDeejd*eejbd1eedEeddFeedeeeeeeeeej"eej"eeeeeeeeejbffdGZPe dHeeedIeeedejDfdJZQe dHeej"dIeej"dej"fdKZR ddBee*ejdCee*ejd*eejbd1eedEeddFeedDeejdeeeFeGeHej"ejDfejbffdLZS ddBee*ejdCee*ejd*eejbd+ed,ed!ee e*eejVfd&ee e*efd-eed1eedEeddFeedDeejdeejjfdMZT dd8edBee*ejdCee*ejd*eejbd+ed9ed-eed!ee e*eejVfd&ee e*efd1eedEeddFeed:eejd;eddDeejdejf dNZU dd*eejbd+edOed1eedejf dPZW dd*eejbd+edOed1eedejf dQZY dd*eejbd+edOed1eedeeeZeee5ff dRZ[e dSeejdTdd edeejej|ffdUZ\dVeejdTdd edeee]ee^ee_eej|ffdWZ` ddSeejdVee*ejd*eejbd1eedEeddFeedeeejee]ee^ee_ejbffdXZa ddSeejdVee*ejd*eejbd+ed,ed!ee e*eejVfd&ee e*efd1eedEeddFeed-eedeejjfdYZbedZejdeeeffd[Zc dd\eejbd+ed]eejd,eej|d!ee e*eejVfd&ee e*efdeeejeej|ffd^Zedd_eejbdejfd`Zg dd\eejbd+ed,eej|d!ee e*eejVfd&ee e*efdeeejeej|ff daZh dd]ejd\eejbd+ed!ee e*eejVfd&ee e*efdeeejeej|ff dbZi dd+ed*eejbd!ee e*eejVfd&ee e*efdeejjf dcZjddejddfdeZlddejddfdfZmddejddfdgZndhee*ejejfddfdiZpd#ed e eeeeeffddfdjZqdhe*ejddfdkZsd e*edleejbeejejejfddfdmZvd@eej|ddfdnZwdoejbdeejfdpZxdleejbeejejejfdeejfdqZydleejbeejejejfddfdrZzdZejddfdsZ{ ddejZdleejbeejejejfdeeddfdtZ|dejZdleejbeejejejfddfduZ}dve*edleejbeejejejfddfdwZ~dleejbeejejejfddfdxZdye*ejddfdzZd ed{ejddfd|Zdejfd}Zy)LocalCollectionzb LocalCollection is a class that represents a collection of vectors in the local storage. NNconfiglocationforce_disable_check_same_threadrGc 4|j|j\|_|_|j}|jj Dcic]7\}}|t jd|jft j9c}}|_|$|j Dcic]\}}|g c}}ni|_i|_ |jDcic]}|gc}|_ g|_ t jdt|_t|jj!t|jj!zt|jj!z|_|j"Dcic]}|t jdt c}|_i|_g|_|du|_d|_||_|t1|||_|j3ycc}}wcc}}wcc}wcc}w)a2 Create or load a collection from the local storage. Args: location: path to the collection directory. If None, the collection will be created in memory. force_disable_check_same_thread: force disable check_same_thread for sqlite3 connection. default: False rdtypeN)_resolve_vectors_configvectorsvectors_configmultivectors_configsparse_vectorsitemsnpzerossizefloat32sparse_vectors_idf multivectorspayloadbooldeletedlistkeys_all_vectors_keysdeleted_per_vectoridsids_inv persistentstoragerUr6 load_vectors)selfrUrVrWsparse_vectors_confignameparamss rQ__init__zLocalCollection.__init___s9=8T8T NN9 5T5!' 5 5!% 3 3 9 9 ;5 f "((Av{{+2::> >5  %0+@*E*E*G H,$T2X H   "&!9!9@ D"H@ .0 xx. ""$ %4&&++-. /4$$))+, -  7;6L6L# .2D"((1D) )# 7957 "$.   0;ZL A5 I@ # ss3CD # #K 0>> ;C  # #K 0 5 : 5 ;r~cZ|jD]}|j||xxdzcc<yr)rrers rQ_update_idf_removez"LocalCollection._update_idf_removes0>> ;C  # #K 0 5 : 5 ;r~dfncJtj||z dz|dzz dzS)Ng?r)mathlog)clsrrs rQ _compute_idfzLocalCollection._compute_idfs)xxR#"s(3a788r~cJ|jdj}g}|j|}t|j|jD]=\}}|j |d}|j ||} |j|| z?t|j|S)N) count_filterr)rvalues) countreziprrgetrappendr) rsrrnum_docs new_values idf_storervaluedocument_frequencyidfs rQ _rescore_idfzLocalCollection._rescore_idfs::4:066 ++K8 fnnfmm< +JC!*sA!6 ##$6AC   eck * + FNN:FFr~c6 |jtt}tt}tt}g}t|jj D]n\}}||j |j <|jj|j |jjt|jxsi|j}t|jtrt|ji}t|jj}|D]} |j!| } | || j| +|| jt#j$|j&| j(t"j*|j|| ft|j,j} | D]Y} |j!| } | || j| +|| jt/|j|| f[t|j0j} | D]d} |j!| } | || j| +|| jt#j2g|j|| ffq|j5D]b\} } t#j2| |j| <t#j6t9|jt:|j<| <d|j5D]h\} } | |j,| <t#j6t9|jt:|j<| <| D]}|j?|| j|j5D]p\} } | Dcgc]}t#j2|c}|j0| <t#j6t9|jt:|j<| <r|D]\}} d|j<| |<t#j6t9|jt:|_ yycc}w)NrYr)!rqrrj enumerateloadrnidrorrgrrrzr}r\rkrraonesr]rcrdr_r7rfarrayr`rblenrhrmrri)rsr\r_rf deleted_idsrpoint loaded_vectorall_dense_vector_namesruvall_sparse_vector_namesall_multivector_names named_vectorsrs rQrrzLocalCollection.load_vectorss << #!$'G(.N&t,LK' (9(9(;<. 8 U%(" ##EHH- ##$6u}}$E$KL!& ellD1%8%,,$GM*.dll.?.?.A)B&28D%))$/A} ,,Q/ ,,GGD$7$7$=$B$B"**U$**C;78+/t/B/B/G/G/I*J'38D%))$/A}&t,33A6&t,334G4IJ#**C;7 8)-T->->-C-C-E(F%18D%))$/A}$T*11!4$T*11"((2,?#**C;7 8Q. 8b(/}} X#m%'XXm%< T"02T\\9JRV0W''- X (6';';'= :#m,9##D)02T\\9JRV0W''-+:F++FD9: :(4'9'9'; X#mJW*X288F+;*X!!$'02T\\9JRV0W''- X ) 7 T56''-c2 788C $5TBDLW $H+YsR query_vectorct|tr4|\}}t|trtj|}||fS|}||fSt|tj r t }|}||fSt|tjr/|j}tj|j}||fSt|tjr|j}|j}||fSt|trt }tj|}||fSt|ttr t }|}||fSt|ttr t }|}||fStdt!|)NzUnsupported vector type )rztuplerjrarndarrayr}types NamedVectorrurNamedSparseVectorr rr& ValueErrortype)rrruqueryrs rQ_resolve_query_vector_namez*LocalCollection._resolve_query_vector_namesz. lE *&KD%%&%0V|-,V|+ bjj 1&D!F&V|% e&7&7 8$$DXXl112F V| e&=&= >$$D!((FV| d +&DXXl+FV| h/?&@ A&D!FV|  h/?&@ A&D!FV|7\8J7KLM Mr~ruct|jjtr@||jjvr|jj|St d|dt|jjt j r.|tk7rt d|d|jjSt d|jj)NVector  is not found in the collectionzMalformed config.vectors: )rzrUr\dictrrr{r})rsrus rQget_vector_paramsz!LocalCollection.get_vector_paramsGs dkk))4 0t{{***{{**400 74&0O!PQQ dkk))6+>+> ?** 74&0O!PQQ;;&& &5dkk6I6I5JKLLr~patternkeyc|jddjd}|jddjd}tdt||DS)a >>> LocalCollection._check_include_pattern('a', 'a') True >>> LocalCollection._check_include_pattern('a.b', 'b') False >>> LocalCollection._check_include_pattern('a.b', 'a.b') True >>> LocalCollection._check_include_pattern('a.b', 'a.b.c') True >>> LocalCollection._check_include_pattern('a.b[]', 'a.b[].c') True >>> LocalCollection._check_include_pattern('a.b[]', 'a.b.c') False >>> LocalCollection._check_include_pattern('a', 'a.b') True >>> LocalCollection._check_include_pattern('a.b', 'a') True >>> LocalCollection._check_include_pattern('a', 'aa.b.c') False >>> LocalCollection._check_include_pattern('a_b', 'a') False .[.[c3,K|] \}}||k(ywry.0prs rQ z9LocalCollection._check_include_pattern..pDda16D)replacesplitallrrrr pattern_parts key_partss rQ_check_include_patternz&LocalCollection._check_include_patternVsR0 T288= KKT*005 Dc-&CDDDr~ct|t|kDry|jddjd}|jddjd}tdt ||DS)NFrrrc3,K|] \}}||k(ywryrrs rQrz9LocalCollection._check_exclude_pattern..xrr)rrrrrrs rQ_check_exclude_patternz&LocalCollection._check_exclude_patternrsc w<#c( "T288= KKT*005 Dc-&CDDDr~rg predicatepathcpt|trNi}|dk7r|dz}n|}|jD]*\}}|||zs|j||||z||<,|St|trGg}|dz}t |D]0\} }||s|j |j|||2|S|S)NrErz[])rzrr`_filter_payloadrjrr) rrgrrresnew_pathrr res_arrayrs rQrzLocalCollection._filter_payloadzs gt $Crz#:%mmo U UX^,"225)XPS^TCH UJ  &I$;D'0 R UT?$$S%8%8 4%PQ R Nr~ with_payloadc@syttr|Sttrj|fdSttj rj|fdSttj rj|fdS|S)Nc8ttfdS)Nc(j|Sryrrrrs rQzDLocalCollection._process_payload....(B(B7C(Pr~)anymaprrrs`rQrz2LocalCollection._process_payload..sCPR^_r~cLttfdjS)Nc(j|Sryrrs rQrzDLocalCollection._process_payload....rr~)rrincluders`rQrz2LocalCollection._process_payload..s CP$,,r~cLttfdjS)Nc*j| Sry)rrs rQrzDLocalCollection._process_payload....sC,F,FwPS,T(Tr~)rrexcluders`rQrz2LocalCollection._process_payload..s CT$,,r~)rzrhrjrrPayloadSelectorIncludePayloadSelectorExclude)rrgrs` `rQ_process_payloadz LocalCollection._process_payloads  lD )N lD )&&  lF$A$A B&&  lF$A$A B&& r~r return_copycb|j|}|j||}|r t|S|Sry)rgrr )rsrrrrgprocessed_payloads rQ _get_payloadzLocalCollection._get_payloads9 ,,s# 11'<H.9x)*P?PPr~ with_vectorscz|dus|y|jDcic]5}|j||s!||j||j7}}|jDcic]'}|j||s||j||)}}|jDcic]5}|j||s!||j||j7}}i|||}t |t r|Dcic] }||vs|||}}t|dk(rt|vr |tS|Scc}wcc}wcc}wcc}w)NFr) r\rmtolistr_rfrzrjrr})rsrrru dense_vectorsr_rf all_vectorss rQ _get_vectorszLocalCollection._get_vectorss 5 L$8  **405 $,,t$S)002 2  ++ **405 $%%d+C0 0  )) **405 $##D)#.557 7  JI.ILI lD )?KcttWbOb4T!22cKc { q %8K%G23 37   ds:D) ,D.:D34 D8>D8payload_filterct|j||j|j}||jz}|||j|z}|S)zo Calculate mask for filtered payload and non-deleted points. True - accepted, False - rejected )payloadsrrorm)r2rgrormri)rsrr payload_maskmasks rQ_payload_and_non_deleted_maskz-LocalCollection._payload_and_non_deleted_masks].\\)LL#66  t||m+  "422;???D r~ query_filterlimitoffsetscore_thresholdc  j|\}g}d} d} t|ttrjvrt ddj} j jjtjjk(rd} tj} d} nt|tts2t|tjr`t!|j"dk(rHj$vrt ddj$} j'j(} nGj*vrt ddj*} j'j(} | dt!j,} t|tjr6t!|j"dk(rt/|| | } nt1|| | } nt|t2rt5|| | } nt|t6r%| r|j9fd }t;|| } n^t|t<rt?|| | } n?t|t@rtC|| | } n t|tDr$| r|j9fd }tG|| } nt|tHrtK|| | } nt|tLrtO|| | } nt|tPr$| r|j9fd }tS|| } n|t|tTrtW|| | } n^t|tXr7t[|| rj]|}t_|}ta|| } nt d tc|je| }tg| }|thjjk(s*t|t@tLt2tHtTt<frtjl| ddd}ntjl| }||nd}|D]}t!|||zk\rn||s| |}| r|tjn k(r8jp|}|!|thjjk(r||kr nb||kDrn[tstjt|tw|djy||j{||}|j}|||dS)NFzSparse vector rTz Multivector z Dense vector rc(j|SryrrFrurss rQrz(LocalCollection.search..DtGXGXYZ\`Gar~c(j|Sryr r s rQrz(LocalCollection.search..Lrr~c(j|Sryr r s rQrz(LocalCollection.search..Trr~zUnsupported query vector type )rrrscoreversionrgr)?rrzr r=r_rrUmodifierrModifierIDFrDOTr&rarrshaperfrdistancer\rgr#r+r r$r>transform_sparserBr'r,rr"r<rAr(r-rr!r;r@r)r.rr9rr8r?rrr%rBIGGER_IS_BETTERargsortinfrorrfloatrrr)rsrrrrrrrresultsparse_scoring rescore_idfr\rscoresrrequired_orderorderrrpoint_id scored_pointrus` @rQsearchzLocalCollection.searchs0"<<\Jl+-  lH->$? @4... >$7V!WXX))$/G{{))$/88FOOtL?Q>RST U11,D1Q*84 ];; ;z #!   @ JJv&tt,EJJv&E!-1 (C6{efn,93KE%BFF7"2||C(H*!]%C%CC..$""El))#|<((l; L MM, '= (@fgr~rprefetchusingkwargsc ,g} |t|tr|n|g} t| dkDr:| Dcgc]}|j||} }|j | |||| |||| } n|j || ||||||} t j| Scc}w)z Queries points in the local collection, resolving any prefetches first. Assumes all vectors have been homogenized so that there are no ids in the inputs r sourcesrrrr*rrrrrr*rrrrrr)points)rzrjr _prefetch_merge_sources_query_collectionr QueryResponse)rsrr)rrrrrrr*r+ prefetchesr. scored_pointss rQ query_pointszLocalCollection.query_pointss$  %/$%?hZJ z?Q HRSHt~~h7SGS!//))) /0 M!22))) /3 M""-887TsBc V|j|j|z|_g}|j3t|jtr |jn |jg}t |dkDrk|Dcgc]}|j ||}}|j ||j|jd|j|jdd|j S|j|j|j|j|jddd|jScc}w)NrFr-r/) rr)rzrjrr1r2rr*filterrr3)rsr)rinner_prefetchesinner_prefetchr.s rQr1zLocalCollection._prefetchs# >> %%^^f4HN    (%/0A0A4%H!!xO`O`Na   1 $M];I~v6G &&nnnnnn%__"" ( 8 8'  ))nnnn%__nn"" ( 8 8*  %s4D&r.c t|tjr|jtjj k(rt |||z} nQ|jtjjk(rt|||z} ntd|jd| D cgc]} | j} } |j| || } t| | D]'\}}|j|_ |j|_)| |dSt}|D]$}|D]} |j!| j&t#|dk(rgSt%|t'|}|j)||||||| |Scc} w)N) responsesrzFusion method z does not exist)rrrr/)rzr FusionQueryfusionFusionRRFrDBSFrrrretrieverrgrsetaddr_include_ids_in_filterrjr3)rsr.rrrr*rrrrfusedrrnfetched_pointsfetchedscored sources_idssourcefilter_with_sourcess rQr2zLocalCollection._merge_sourcess eV// 0||v}}000.PVW!3!337'QVY_Q_` >%,,!OPP*//588/C/!]],\+N$'~u#= /!( '  /> !%K! .#.EOOEHH-. .;1$ &<\4P[K\&]#--!4!!-!-$3.  +0s(E=c \|xst}|xsd}|xsd}|7|j|||z||\} } | |dD cgc] } t| c} St|tj r$|j ||jf||||||St|tjrW|j|jj|jj|jj||||||| St|tjrB|j|jj|jj ||||||| St|tj"r#|j|j |||||||St|tj$rB|j||j&||z|| \} } | |dD cgc] } t| c} St|tj(rW|j*tj,j.k(r|j1||z||| St3d |j*t|tj4r t7d |j ||f||||||Scc} wcc} w) z_ Performs the query on the collection, assuming it didn't have any prefetches. rN) scroll_filterrrrrrrrrrr) positivenegativestrategyr*rrrrrr) targetcontextr*rrrrrr)rVr*rrrrrr)rPorder_byrrr)rrrrzUnknown Sample variant: z(Cannot perform fusion without prefetches)r}scrollrecord_to_scored_pointrzr NearestQueryr(nearestRecommendQuery recommendrRrSrT DiscoverQuerydiscoverrUrVr OrderByQueryrW SampleQuerysampleSampleRANDOM_sample_randomlyrr>AssertionError) rsrr*rrrrrrrecords_records rQr3z!LocalCollection._query_collection,s,, 1 =*fn)) %JGQ BIAQRv*62R R v22 3;;#U]]3))) / v44 5>>111111))) /"  v33 4==~~,,..))) /!  v22 3== ))) /!  v22 3*fn)) %JGQBIAQRv*62R R v11 2||v}}333,,&.!-!-!- -!#;ELL>!JKK v11 2 !KL L;;#U^))) / MSnSs J$J)group_by group_size with_lookupwith_lookup_collectionc Ft|j} |Ct|tr'g}|D]}|j t || |}!n t || }|j ||||t|jd| | }t}|jD]}t|jtst|j|}|7ttd|D}|j|j||_ |D]Z}||vrtj|g||<t||j |k\r=||j j |\t|j#d|}t| t$rtj&| dd} | V| T|D]O}| j)|j*g| j,| j.}t1t3|d|_Qtj6|S)NT)rrr)r*rrrrc3NK|]}t|ttfs|ywryrzstrrrrs rQrz/LocalCollection.query_groups..#Y!z!cSVZ?XA#Y%%rhits collectionrrrnrrgroups)rrorzrjrset_prefetch_limit_recursivelyr7rr0rgrr3rDrr PointGrouprvrrq WithLookuprCrrrnextiterlookup GroupsResult)rsrjrr*r)rrrkrrrrlrm max_limittmprr0r{r group_values group_value groups_resultgrouprs rQ query_groupszLocalCollection.query_groupss4 %  (D)!#AJJ=aKL"H#:(IN""%dll#%+#  ]] 7EemmT2' x@L##Y|#Y YZL 11%--NEM+ 7 f,*0*;*;{QS*TF;'vk*//0J>{#((//6 7 7*26fmmo1Fv1N k3 ' ++&!!K  "'='I& 8/88 !,!9!9!,!9!99 $DL$7  8""-88r~c z|j||t|jd||} t} | D]} t | j t st| j |}|7ttd|D}|j| j || _|D]Z}|| vrtj|g| |<t| |j|k\r=| |jj| \t| jd|}t | t rtj"| dd} | V| T|D]O}| j%|j&g| j(| j*}t-t/|d|_Qtj2|S)NT)rrrrrrc3NK|]}t|ttfs|ywryrprrs rQrz0LocalCollection.search_groups..$rsrtrurwryrz)r(rrorrzrgrr3rjrDrrr}rvrrrqr~rCrrrrrrr)rsrrjrrrkrrrrlrmr0r{rrrrrrs rQ search_groupszLocalCollection.search_groupss@%%dll#%+   7EemmT2' x@L##Y|#Y YZL 11%--NEM+ 7 f,*0*;*;{QS*TF;'vk*//0J>{#((//6 7 7*26fmmo1Fv1N k3 ' ++&!!K  "'='I& 8/88 !,!9!9!,!9!99 $DL$7  8""-88r~ facet_filtercrtt}|j|}t|jD]\}}||s t |t st||}|,t} |D]P} t| ttjvr(t| } | r t| } | j| R| D]} || xxdz cc<t!|j#dd|D cgc]\} } t%j&| | }} } tj(|Scc} } w)Nrc|d |dfS)NrrrrPs rQrz'LocalCollection.facet..rs!uadmr~r)rr)rv)rrrrrgrzrr3rDrrr FacetValuer4rqrEsortedr`r FacetValueHit FacetResponse)rsrrr facet_hitsrrrgr values_setras_uuidrrrvs rQfacetzLocalCollection.facetEsE 3>c2B 11,?%dll3 #LC9gt,!'3/F~14J "7"5e6F6F"GG%Q-G Aq! "  #1 "  #7 #@!'  "+!u ! u  uE :  ""-- s9!D3rnc g}|D]z}||jvr|j|}|j|dk(r4|jtj||j |||j ||||S)Nrrrgr)rnrirrRecordrr)rsrnrrr r&rs rQrCzLocalCollection.retrievexs  Htxx'((8$C||C A% MM  --c<@,,S,?    r~rRrSrTlookup_from_collectionlookup_from_vector_namec `dttjdtttt ttj tttt fddffd }||n||nt} ||n| ||ng}||ng}|tjjk(rt|dk(rOtd|tjjk(r't|dk(rt|dk(r tdg} g} g} g} g}g}gjv}jv}|rj||| ||| n?|rj||||||nj ||| ||| t#|}| | | | |||fS)NexamplesaccrGc|D]}t|ttjr|jvrt d|dj|} |}t|t jr|j}|j|k(sj||j|yNPoint r) rzr rPointIdrnrrarrr) rrexamplervecrxcollection_vectors mentioned_idsrsrs rQexamples_into_vectorszJLocalCollection._preprocess_recommend_input..examples_into_vectorss$ (gx '>?jnn4(6':Y)Z[[$..1C,[9#>C!#rzz2!jjlJJsO!T)%,,W5JJw' (r~rzPositive list is emptyz&No positive or negative examples given)rr VectorInputr rjrrr}rRecommendStrategyAVERAGE_VECTORrr BEST_SCOREr_rfr\ignore_mentioned_ids_filter)rsrRrSrTrr*rrrsearch_in_vector_namepositive_vectorsnegative_vectorssparse_positive_vectorssparse_negative_vectorspositive_multivectorsnegative_multivectorssparsemultirxrrrs` @@@@rQ_preprocess_recommend_inputz+LocalCollection._preprocess_recommend_inputs$ (v112 (tDK($v/B/B*CT$tTY{J[E\\] ( ( (&0F/Q+W[ ).):@S'2 $&  (38'38 u..== =8}! !9:: 00;; ;8}!c(mq&8 !IJJ/1.0=?=?9;9;/1  9 99z666 !+!:!:  !(,C D !(,C D !+!8!8  !(,A B !(,A B!+!3!3  !(,< = !(,< =3<O    # # ! !   r~rrctj|}t|dkDrtj|nd}tj|d}|||ztj|dz }|S|}|S)Nraxis)rastackrmean)rrpositive_vectors_npnegative_vectors_npmean_positive_vectorrs rQ_recommend_average_densez(LocalCollection._recommend_average_denses!hh'78bb   *F r~ct|D]\}}t|t|||< t|D]\}}t|t|||< t|}|rt|}t ||}|S|}|Sry)rr9r8rDrC)rrirrmean_negative_vectors rQ_recommend_average_sparsez)LocalCollection._recommend_average_sparses ##34 =IAv "6 *"4V"< Q  =##34 =IAv "6 *"4V"< Q  = **:; #-.>#? 45IK_`F *F r~c R||ntjj}|j|||||||\}} } } } } }|tjjk(rH|r|j || }||fS| r|j | | }||fS| r t dtd|tjjk(rJ|s| rt|| }||fS| s| rt| | }||fS| s| rt| | }||fStdtd|dtj)NzjMultivectors do not support recommend average, consider using strategy=models.RecommendStrategy.BEST_SCOREz9No positive examples given with 'average_vector' strategyrRrSzANo positive or negative examples given with 'best_score' strategyz strategy `z+` is not a valid strategy, choose one from ) rrrrrr TypeErrorrrr r>r')rsrRrSrr*rrrTrrrrmulti_positive_vectorsmulti_negative_vectorsedited_query_filterrs rQ_construct_recommend_queryz*LocalCollection._construct_recommend_querys (389P9P9_9_  , ,      " #    # # " "  u..== =#<<$$  N000G)#==++  D000=(C !!\]] 00;; ;#3(--  (000!),C.4?V  000(+A-3>T  000!WXJ&QRWRiRiQjk r~c ~|j|||| | | | \} }| | nt}|j|| f||||||S)NrQ)rr}r()rsrRrSrrrrrrr*rrrTrrrs rQr]zLocalCollection.recommendcso-1,K,K     " # - ) )*/):@S{{/>,%%+  r~c ||ntjj}|j|||| | | |\}}| | nt}|j ||f|||||| || | S)N) rrrjrkrrrrrlrm)rrrrr}r)rsrjrRrSrrrkrrrr*rrrlrmrTrrrs rQrecommend_groupsz LocalCollection.recommend_groupss$ (389P9P9_9_,0,K,K     " # - ) )*/):@S!!/>,!%%+##9"  r~rbc|j||||\}}g}g}t|D cic]\} } | |  } } } t|D];\} } | D]1}|j| |j| |j3=g}|D]$}|D]}|j|j&t j ||||Scc} } w)Nrrrbr*) offsets_row offsets_colr#rn)_search_distance_matrixrrrrrSearchMatrixOffsetsResponse)rsrrrbr*rn all_scoresrrrr& offset_by_id row_offsetr6r'r# sample_scoresrs rQsearch_matrix_offsetsz%LocalCollection.search_matrix_offsetss66%U67 Z  ;DS>J-#x# J J)2:)> B %J - B "":.""< #@A B B ' +M& + ekk* + +00##   Ks Cc  |j||||\}}g}tt||D]G\}} | D]=} |jt j || j | j?It j|S)Nr)abr)pairs) rrjrrrSearchMatrixPairrrSearchMatrixPairsResponse) rsrrrbr*rnrr sample_idr sample_scores rQsearch_matrix_pairsz#LocalCollection.search_matrix_pairss66%U67 Z(,Sj-A(B  $I} -   **#|l>P>P  ..  r~cg}||nt}|jt|j|d|}|D]0}t||k(rn |j |j |2t|dkrggfSt |d}|Dcgc]}|j} }g} t|D]\} } t| D cgc] \} }| | k7s |}} }t||}| j}t|tr||n|}|j||f||dd}| j || | fScc}wcc}} w)NFr c|jSry)rrPs rQrz9LocalCollection._search_distance_matrix..s r~r)rrrrr) r}rerrnrrrrrrFrzrr()rsrrrbr*samplesr candidates candidaternr#sampled_id_indexsampledrrFids_to_includessampling_filtersampled_vector search_vectorsamples_scoress rQrz'LocalCollection._search_distance_matrixsu&().):@S** M<0E $ *I7|v%+y)  * w?jnn4(6':Y)Z[[$..1C"j&8&88!+!3!3K!@!E!L!L!N$ (A(AA!+!:!:;!G!L!+!8!8!Ec!J!Q!Q!S ''/!T)%,,W5 ''0# 1&,q/<8ZQ>'--%|AVWYLOT2z,q/SW7Xl1oa0%8Z UVXYHZ\a=b)00#\!_|TUW Q 2D9jVWYZI[]a>b)00(,q/LYZO\%g!cS+ \ /0././  [ %&<>SUbbbQ s8K c| |s td||n|}||nt}||n|} |j||| \} } | t|ng}|j ||| \} } }}| ||k(r|j | t ||}| | | ||fS)NNo target or context given)rr}rrjrrr)rsrUrVrr*rrrxrrr target_idrrrrs rQ_preprocess_discoverz$LocalCollection._preprocess_discovers >'9: :/E/Q+W[ ).):@S'2 $&  $(#:#:6:{#[ y#*#6$w-B  $ $Wj+ F \57Lm  Z4%7   +3<O   ! " !    r~c |j||||| | \} } }}}| et| tr-t| dtr t | | }npt | |}nct| t r t| |}nFtd| | r t| }n+| |r t|}n| |r t|}n td||nt}|j||f|||||| S)NrzUnsupported target vector typerrQ)rrzrjrrr(rr<rrr;r)r}r()rsrUrVrrrrrr*rrrrrrrrrrs rQr_zLocalCollection.discovers(  % %     " #    ! " !   $-.mA.6#1-AV#WL#6}F[#\LM<83MCYZ  !ABB "'<'(=>L  "'=-.DEL  "'<,-BCL9: :).):@S{{/>,%%+  r~r&ct|tr|dfSt|trd|fStdt |)NrrEzIncompatible point id type: )rzrqrrr)rr&s rQ _universal_idzLocalCollection._universal_idsB h $Q;  # &x< 6tH~6FGHHr~rPrWct|jdk(rgdfS||j|||||S| td|j |||||S)Nr)rPrrrrzGOffset is not supported in conjunction with `order_by` scroll parameter)rWrPrrr)rrn _scroll_by_idr_scroll_by_value)rsrPrrWrrrs rQrXzLocalCollection.scrolls txx=A t8O  %%+)) &   Y $$'%% %  r~rcv|j|}tjtj|S)N)r)rr CountResultra count_nonzero)rsrrs rQrzLocalCollection.count(s.11,?!!(8(8(>??r~c tjjfd}g}j|}|D]\} } |$j | j |kr,t ||dzk\rnO|| sE|j tj| j| |j| |t ||kDr|d|||jfS|dfS)Nc,j|dSNr)r)rFrss rQrz/LocalCollection._scroll_by_id..5sD6%=#3#33 34< r~c t|tjrtj|}t|t rt j|}g}|jjD]T\}}t|j||j} | ,| D]$} t| } | |j| ||f&V|j |jnt jj } | t jj"k(} |j%d| |j'|}g}t|j(}|D]\} }}|F| t jj k(r| |kr$,| t jj"k(r| |kDrOt+||k\r|dfS||sh|jt j,||j/|||j1|||dfS)Nrc |dSrrrPs rQrz2LocalCollection._scroll_by_value..rs 1r~)rreverser)rzr OrderByrconvert_order_byrqrrnr`r3rgrr1r direction DirectionASCDESCsortr start_fromrrrr)rsrWrPrrr value_and_ids external_id internal_idpayload_valuesrordering_valuershould_reverserr rs rQrz LocalCollection._scroll_by_valueRs h -!228|<y)NVector contains NaN valuesrrrr) rnrr rgrrzrrjr}r\r`rrraisnanrrrrCOSINElinalgnormEPSILONrrmr_rrrfnewaxiswhereri) rsrrr\r_named_vectorsrrvr, was_deletedprevious_vector _named_vector vector_norms rQ _update_pointzLocalCollection._update_points+hhuxx $161J u}} -PR  S ellD )*ELL9GllG,0<<+=+=+? > 'K[[-F!// <88F+//1O3OO1??foo&<&<<99>>&1D8,0+>+>+D+D+F > 'K[[-F11+>sCK"&"5"5k"B3"G''E!8>##K05<='' 4S9'' <<='' 4S9 >+/*;*;*A*A*C > &K[[-F!// <88F+//1O3OO1??foo&<&<<"$))..b."A!RZZ-"PKbhh{c'9;PPF68hhv6F!!+.s3<='' 4S9<='' 4S9 > Sr~c t|j}||j|j<|jj |j|j j t |j t|j nit|j t|jk(sJdtj|jd|_ t|jtrt|ji}n |j}|jjD]\}}|j!|}|j"d|kr+tj$||dzdz|j"df}|Xtj&|j"d}|||<tj|j(|d|j(|<tj*|}tj,|j/rJd|j1|} | j2t4j6j8k(r/tj:j=|} | t>kDr|| z n|}|||<||j|<tj|j(|d|j(|<|j@jD]\}}|j!|}t||kr:|t|z dz} tC| D]} |j tE|@tE}|||<tj|j(|d|j(|<|||<|jG||||j@|<tj|j(|d|j(|<|jHjD]\}}|j!|}t||krE|t|z dz} tC| D]&} |j tj*g(|Itj*g||<tj|j(|d|j(|<tj*|}tj,|j/rJd|j1|} | j2t4j6j8k(rWtj:j=|dddtjJf} |tjL| dk7| t>z}|||<||jH|<tj|j(|d|j(|<y) Nz)Payload and ids_inv must be the same sizerr rr'rrr()'rrnrrorrgr rrarirzrrjr}r\r`rrresizerrmrr)rrrrrr*r+r,r-r_ranger7rrfr.r/)rsrrr\rrr fake_vector vector_nprvr,diffrhr4s rQ _add_pointzLocalCollection._add_points$((m  EHH%  %--:S' 6Y[ \ 4<< C $55b7bb5yyq1 ellD )*ELL9GllG+/,,*<*<*>  &K[[-F""1%, " -#'A+}GZGZ[\G]9^ _ ~ ggm&9&9!&<= %0 c"79yy++K8!8'' 4HHV, 88I.224R6RR4// <??foo&<&<<99>>)4D487N D 0 I%. c",9 [)79yy++K8!8'' 4+ 4+/*=*=*C*C*E  &K[[-F=!S(S//!3t@A!(()<)>?@~13 %0 c"79yy++K8!8'' 4&, c"'' <3@##K079yy++K8!8'' 4% .+/*;*;*A*A*C  &K[[-F=!S(S//!3t7A!(("67~%'XXb\ c"79yy++K8!8'' 4HHV, 88I.224R6RR4// <??foo&<&<<"$))..."DQ ]"SK+*!!+.79yy++K8!8'' 4- r~ct|jtr tj|j}t|j tri}|j jD]K\}}||jvrt d|t|ts3t|t|||<M|j j|nt|jj!}t|j"j!}|r|dgk7s|r|dgk7rt d|d||js|j"s t d|j|j$vr|j'|n|j)||j*|j*j-|yy#t $r}t d|jd|d}~wwxYw)Nz Point id z is not a valid UUIDz-Wrong input: Not existing vector name error: rEzbWrong input: Unnamed vectors are not allowed when a collection has named vectors or multivectors: z, z+Wrong input: Not existing vector name error)rzrrquuidUUIDrrrr`rlrr9r8updaterjr\rkrfrnr5r<rqpersist) rsr_uuideupdated_sparse_vectorsrr vector_namesmultivector_namess rQ _upsert_pointzLocalCollection._upsert_pointKs ehh $ T %((+ ellD )%' "',||'9'9'; U# Vd&<&<<$'TU`Ta%bccfl3*62:LV:T*;7 U LL   6 7 1 1 34L $T%6%6%;%;%= > "!5!&7B4&? x#nB'8&9;<<(9(9 #NPP 88txx    u % OOE " << # LL  ' $C T 9UXXJ6J!KLRSS TsG G1G,,G1r0ct|tr|D]}|j|nt|tjr|}t|j trt |j i}n |j }t|jD]o\}}d}|j|j|}|jD cic] \}} || | } }} |jtj||| qntdt|t|j|jkDr9t!d|jddt|jdt"dd yycc} }w) NrzUnsupported type: z=Local mode is not recommended for collections with more than ,z% points. Current collection contains zd points. Consider using Qdrant in Docker or Qdrant Cloud for better performance with large datasets.zlarge-local-collection)categoryr stacklevel)rzrjrGrBatchr\r}rrnrr` PointStructrrrLARGE_DATA_THRESHOLDr UserWarning) rsr0rbatchr\rr&rgrurrs rQupsertzLocalCollection.upserttsc fd # *""5) *  -E%--.. >--!*599!5  X>>-#nnS1G6=mmoF74$#,FF""&&# '% 1$v,@A A txx=444 4 OPTPiPijkOlm77:488}oFnn%,   5Gs E:c|jD]\}}t|tr_t||j||}|j ||t |}||j||<|j||nY||jvr&tj||j||<n%tj||j||<d|j||<yr) r`rzrr9r_rr8rr\rarrfrm)rsrr\rr old_vector new_vectors rQ_update_named_vectorsz%LocalCollection._update_named_vectorss$+==? : K&,/&v.!00=cB '' K@/7 8B##K05'' K@ ,13&1A [)#.68hhv6F!!+.s389D # #K 0 5 :r~c|D]g}|j}|j|}|j}t|tr t |i}n|}|j |||j|iyry)rrnrrzrjr}rV_persist_by_id)rsr0rr&r vector_struct fixed_vectorss rQupdate_vectorszLocalCollection.update_vectorssh *ExxH((8$C!LLM-.!4m D -  & &sM :    ) *r~selectorc|j|}|D];}|j|}|D]}d|j||<|j|=yr)_selector_to_idsrnrmrX)rsr\r\rnr&rrs rQdelete_vectorszLocalCollection.delete_vectorssc##H- *H((8$C& > <='' 4S9 >    )  *r~c|D] }|j|}d|j|<"|j#|D]}|jj|yyr)rnrirqdelete)rsrnr&rs rQ _delete_idszLocalCollection._delete_idss_ "H((8$C !DLL  " << # . ##H- . $r~ delete_filterc|j|}|jjDcgc] \}}||s |}}}|Scc}}wry)rrnr`)rsrcrr&rrns rQ_filter_to_idszLocalCollection._filter_to_idssE11-@-1XX^^-=KMHccxKK Ls AAc`t|tr|St|tjr|j |St|tj r |j St|tjr|j |jStdt|)NzUnsupported selector type: ) rzrjrFilterre PointIdsListr0FilterSelectorr9rr)rsr\s rQr^z LocalCollection._selector_to_idss h %O &-- 0&&x0 0 &"5"5 6?? " &"7"7 8&&x7 7:4>:JKL Lr~cH|j|}|j|yry)r^rb)rsr\rns rQrazLocalCollection.deletes"##H- r~c|jf|j|}tj||j |dd|j |d}|jj |yy)NTF)rr)rr)rqrnrrNrrrA)rsr&rrs rQrXzLocalCollection._persist_by_idsn << #((8$C&&))#De)T((4(@E LL  ' $r~cT|j|}tt|}| t|nd}|D]o}|j|}|!i|j |||j |<n*|j |t |j ||||j|qy)N)rgrrk)r^r rr0rnrgr5rX) rsrgr\rrnjsonable_payloadrkr&rs rQ set_payloadzLocalCollection.set_payload s##H-#$6w$?@EH__S-AZ^ *H((8$C|$Mt||C'8$MFV]ab    ) *r~c|j|}|D]G}|j|}tt|xsi|j|<|j |Iyry)r^rnr rrgrX)rsrgr\rnr&rs rQoverwrite_payloadz!LocalCollection.overwrite_payload s]##H- *H((8$C ();G)D E KDLL     ) *r~rkc|j|}|D]Y}|j|}|D]2}||j|vs|j|j|4|j |[yry)r^rnrgpoprX)rsrkr\rnr&rrs rQdelete_payloadzLocalCollection.delete_payload* sx##H- *H((8$C /$,,s++LL%))#. /    )  *r~c|j|}|D]1}|j|}i|j|<|j|3yry)r^rnrgrX)rsr\rnr&rs rQ clear_payloadzLocalCollection.clear_payload< sM##H- *H((8$C "DLL     ) *r~update_operationsc|D]V}t|tjrt|jtjr&|j|jj ht|jtj r&|j|jjtdt|jt|tjr|j|j t|tjrV|jjxs|jj}|j|jj|zt|tj rV|j"jxs|j"j}|j#|j"j|t|tj$rV|j&jxs|j&j}|j'|j&j(|Zt|tj*r|j-|j,t|tj.r'|j1|j0jt|tj2rV|j4jxs|j4j}|j5|j4j6|Btdt|y)NzUnsupported upsert type: zUnsupported update operation: )rzrUpsertOperationrR PointsBatchrQ PointsListr0rrDeleteOperationraSetPayloadOperationrnr9rgOverwritePayloadOperationrpDeletePayloadOperationrsrkClearPayloadOperationruUpdateVectorsOperationr[DeleteVectorsOperationr_r)rsrv update_oppoints_selectors rQbatch_update_pointsz#LocalCollection.batch_update_pointsK sp+! UI)V%;%;<i..0B0BCKK 0 0 6 67 0 0&2C2CDKK 0 0 7 78$'@iFVFVAW@X%YZZIv'='=> I,,-Iv'A'AB"+"7"7">">"^)BWBWB^B^  !6!6!>!>PIv'G'GH//66\):U:U:\:\ &&y'B'B'J'JO\Iv'D'DE,,33Vy7O7O7V7V ##I$<$<$A$A?SIv'C'CD""9#:#:;Iv'D'DE##I$<$<$C$CDIv'D'DE,,33Vy7O7O7V7V ##I$<$<$C$C_U #A$y/AR!STTC! Ur~ new_configcp||jvrtd|d||jj|<y)Nrz! does not exist in the collection)r_rrU)rsrrs rQupdate_sparse_vectors_configz,LocalCollection.update_sparse_vectors_configr s; d11 1w{m3TUV V2< "";/r~ctjtjjtjj dd|j j ditjtj|jj|jj|jj|jj|jj|jjtj dddtj"dd tj$d d dd d ddS)Nrr)r\ shard_numberreplication_factorwrite_consistency_factoron_disk_payloadr_di')m ef_constructfull_scan_threshold )wal_capacity_mbwal_segments_aheadg?irT)deleted_thresholdvacuum_min_vector_numberdefault_segment_numberindexing_thresholdflush_interval_secmax_optimization_threads)rv hnsw_config wal_configoptimizer_configquantization_config)statusoptimizer_status vectors_countindexed_vectors_count points_countsegments_countpayload_schemarU)rCollectionInfoCollectionStatusGREENOptimizersStatusOneOfOKrCollectionConfigCollectionParamsrUr\rrrrr_ HnswConfig WalConfigOptimizersConfigrs rQinfozLocalCollection.infoz s$$**00#99<<"#++**.. KK//!%!9!9'+{{'E'E-1[[-Q-Q$(KK$?$?#';;#=#= #--!$(- "++$&'("(!8!8&)-1+,','(-. "%)5$ $ r~)NF)rGN)rE)T)TT)Fry)NrONTFN) NNNrOrTFNN)NNNTF)NNNNNFFN) NNNNrOTFNNN)NrOrTFNNN)NrO)TF)NNNNNNN) NNNrOrTFNNNNN)NNNrOrNTFNNNNNN)NrrON)NNNNNN) NNNrOrTFNNNN)NrONNTF)NrONTF)NrOTF)__name__ __module__ __qualname____doc__rOrCreateCollectionrrqrhrw staticmethodrr{rr[rrrr classmethodrrrrrrr rjrrrrr=r& NumpyArrayrrrrrrrrPayloadSelectorrPayloadr VectorStructrrgrarrrr(QueryPrefetchr4r7r1r2r3rDocumentImageInferenceObjectWithLookupInterfacerrVectorr r>r'rrrrrCrrrrrrr]rrrrrrrrrr:r*rrr_rrrXr rrrrerNr5r<rGrMrRrV PointVectorsr[rirhr_rbrer^rarXrnrprsruUpdateOperationrSparseVectorParamsrrrrr~rQrSrSXs" #'05 0''03-0*. 0  0d3c6.../3 tC,,,-tC9L9L4L/MM N33(!;;C;D; ;;C;D;9c9c9e99 G< Gc Gl GLC\1 K #tE{" # e  #tDK(( )     # #  #'' ( #(( )  #'' (      1  U#%68H%JZJZZ [[ !11f Mc Mf.A.A MESEsEtEE6ESEsEtEEIK&.ud{&;CF 0KO))D(3-1F1FFG) $ ))\KO Q QD(3-1F1FFGQ Q &.. ! QJO!!&+D(3-,E&F! &%% &!L&* /c]  V04 $JN38+/-O K #tE{" # e  #tDK(( )     # #  #'' (  #(( )  #'' (     O"u||,#O$%O& 'O(D(3-1F1FFG)O*D(3-/0+O,"%-O. f  !/Of(,37/3JN38+/#39 $394/039u||, 39  39  39D(3-1F1FFG39D(3-/039"%39}3939   39j&%..&#&$uGXGXBY&\ $/3+/JN386d5,,-.6{{6 6  6 } 6u||,6"%6D(3-1F1FFG6D(3-/06 e 6t(,#/3# $JO38+/h $h}hu||, h } h  hD(3-1F1FFGhD(3-/0h"%h e hp #FJ/3JN38+/;?>B1Y9Y9 MM K e     KK    NN KK  ! !    Y9}Y9 U^^(B=R9 UO e  MM#"$$ &      # #      #  R9,-R9.v}}-/R901R923R94D(3-1G1GGH5R96D(3-/07R98"%9R9:e778;R9<!)): ;=R9>   ?R9n04 1. 1.u||,1. 1.    1.lKO38  emm $D(3-1F1FFGD(3-/0  fmm  8<@;?6:/3#>B15[ 8F$6$678[ 8F$6$678[ 5223 [ u||, [ } [ !)): ;[ "*#[   T%[ T%[ V ! V ! T$u+  T$u+    [ ztE{+?CDK?P    v223v223   .<@;?/3#>B156:K18F$6$678K18F$6$678K1u||, K1 } K1 !)): ; K1"*#K15223K1  i.&:M:MuO_O__`   K1^<@;?/3JN38+/#>B156:" 8F$6$678" 8F$6$678" u||, "  "  " D(3-1F1FFG" D(3-/0" "%" }" !)): ;" "*#" 5223"  f  !" N<@;?04+/KO38#>B15;?>B6:!+ + 8F$6$678+ 8F$6$678 + v}}- +  + + "%+ D(3-1G1GGH+ D(3-/0+ }+ !)): ;+ "*#+ e778+ !)): ;+ 5223!+ "   #+ ^04#  u||,      }   * *  H04#  u||,    }   ( (  204# 3u||,33 3 } 3 tO$d4 +<&== > 3j++,:KZ] v}}emm+ ,2NcF../Nc=NNc]`Nc  [4 12D9I4JDQVQ^Q^L__ Ncd04:>/3#>B15- ++,- (6#5#567- u||, - } - !)): ; - "*#-   [     - b04:>/3JN38#>B15+/? ++,? (6#5#567? u||, ?  ?  ? D(3-1F1FFG? D(3-/0? }? !)): ;? "*#? "%?  f  !? BIV%;%;Ic3hII15,0*.JN38"  -" " 5==) " ' " D(3-1F1FFG " D(3-/0"  tELL!8EMM#:: ;" H@(5<<"8@FDVDV@15*.JN38 #  -# # ' # D(3-1F1FFG # D(3-/0 #  tELL!8EMM#:: ;# P15JN38 ?--?  -? ? D(3-1F1FFG ? D(3-/0 ? tELL!8EMM#:: ;?JKO38 !!u||,!D(3-1F1FFG ! D(3-/0 ! e !F76#5#57$7rZ 2 2ZtZx'(6#5#5'($'(R$U8F,>,>#?#MN$SW$L::!%c5el1J+K&K!L: :" *Xe.@.@%A *d **#* MM '' (  ! !    ! * *".tEMM2.t.ELLT&BXBX=Y M MM '' (  ! !    ! M f$$ %M(  MM '' (  ! !    !    (v'='=($(&"** MM '' (  ! !    ! *c]* *4** MM '' (  ! !    ! * * *sm* MM '' (  ! !    ! * *$ * MM '' (  ! !    !  *  *%U#E$9$9:%U %UN==,2,E,E= =% f++% r~rSrrct|dk(r|Stj|}|tj|g}|St |}|j |g|_|S|j j ||S)Nrhas_id)must_not)rrHasIdConditionrgr rr)rrignore_mentioned_idss rQrr s =Q!00 F}}/C.DE   -  (%9$:L !   ! ! ( ()= > r~rnct|dk(r|Stj|}|tj|g}|St |}|j |g|_|S|j j ||S)Nrr)must)rrrrgr rr)rrn include_idss rQrFrF s 3x1}''s3K}};-8   -    $!, L      $ $[ 1 r~rictj|jdd|j|j|j S)Nr)rrrrgr order_value)rrrrgrr)ris rQrYrY s9    99}}&&  r~r)rc |rt|jtr9tj||jDcgc]}t ||c}Stj|tSycc}w)N)rr))rzr)rjrrr|)r)rrs rQr|r| sh h'' .>>LTL]L]^q8EB^  >>? ?_sA6 )mrKrr> collectionsrrtypingrrrrr r copyr numpyra qdrant_clientr $qdrant_client.common.client_warningsr qdrant_client._pydantic_compatrrrOqdrant_client.conversionsrr&qdrant_client.conversions.common_typesr$qdrant_client.conversions.conversionrqdrant_client.httprqdrant_client.http.modelsr qdrant_client.http.models.modelsrrrrqdrant_client.hybrid.fusionrrqdrant_client.local.distancesrrrrrr r!r"r#r$r%#qdrant_client.local.multi_distancesr&r'r(r)r*r+r,r-r.$qdrant_client.local.json_path_parserr/r0qdrant_client.local.order_byr1#qdrant_client.local.payload_filtersr2+qdrant_client.local.payload_value_extractorr3r4(qdrant_client.local.payload_value_setterr5qdrant_client.local.persistencer6qdrant_client.local.sparser7r8r9$qdrant_client.local.sparse_distancesr:r;r<r=r>r?r@rArBrCrDr}r-rSrgrjrrrFrrYrrr|rr~rQrst 0&B_;F;%1``_       O7FPEA     V#V#VG% G% TJ5<<(9=emm9L \\,5<<(/3EMM/B \\,5<<E4E4E@U^^@C@ENN@r~