Deploy 4992b4c

app/services/vector_store.py

@@ -238,15 +238,16 @@ class VectorStore:
                 ]
                 qdrant_filter = Filter(must=must_conditions)
 
-            results = self.client.search(
+            response = self.client.query_points(
                 collection_name=self.collection,
-                query_vector=NamedVector(name=_DENSE_VEC, vector=query_vector),
+                query=query_vector,
+                using=_DENSE_VEC,
                 limit=top_k,
                 query_filter=qdrant_filter,
                 with_payload=True,
             )
 
-            return [Chunk(**hit.payload) for hit in results if hit.payload]
+            return [Chunk(**hit.payload) for hit in response.points if hit.payload]
 
         except Exception as exc:
             raise RetrievalError(
@@ -268,12 +269,10 @@ class VectorStore:
         if not indices:
             return []
         try:
-            results = self.client.search(
+            response = self.client.query_points(
                 collection_name=self.collection,
-                query_vector=NamedSparseVector(
-                    name=_SPARSE_VEC,
-                    vector=SparseVector(indices=indices, values=values),
-                ),
+                query=SparseVector(indices=indices, values=values),
+                using=_SPARSE_VEC,
                 limit=top_k,
                 query_filter=Filter(
                     must=[
@@ -285,7 +284,7 @@ class VectorStore:
                 ),
                 with_payload=True,
             )
-            return [Chunk(**hit.payload) for hit in results if hit.payload]
+            return [Chunk(**hit.payload) for hit in response.points if hit.payload]
 
         except Exception as exc:
             # Sparse index may not exist on old collections — log and continue.
@@ -349,9 +348,10 @@ class VectorStore:
         returned by the main dense search in retrieve.py).
         """
         try:
-            results = self.client.search(
+            response = self.client.query_points(
                 collection_name=self.collection,
-                query_vector=NamedVector(name=_DENSE_VEC, vector=query_vector),
+                query=query_vector,
+                using=_DENSE_VEC,
                 limit=top_k,
                 query_filter=Filter(
                     must=[
@@ -363,7 +363,7 @@ class VectorStore:
                 ),
                 with_payload=True,
             )
-            return [Chunk(**hit.payload) for hit in results if hit.payload]
+            return [Chunk(**hit.payload) for hit in response.points if hit.payload]
         except Exception as exc:
             logger.warning(
                 "search_by_raptor_level(level=%d) failed: %s — skipping RAPTOR results.", level, exc

pytest.ini

@@ -6,3 +6,4 @@ python_functions = test_*
 addopts = -x --tb=short -q
 filterwarnings =
     ignore::DeprecationWarning:slowapi.*
+    ignore:The default value of `allowed_objects` will change:langchain_core._api.deprecation.LangChainPendingDeprecationWarning