fix: Add missing await statement to LanceDBAdapter and PGVectorAdapter
Added missing await statement to batch search for LanceDB and PGVector adapters Fix #COG-170
This commit is contained in:
parent
195929e245
commit
dc46304a8d
2 changed files with 2 additions and 2 deletions
|
|
@ -152,7 +152,7 @@ class LanceDBAdapter(VectorDBInterface):
|
||||||
):
|
):
|
||||||
query_vectors = await self.embedding_engine.embed_text(query_texts)
|
query_vectors = await self.embedding_engine.embed_text(query_texts)
|
||||||
|
|
||||||
return asyncio.gather(
|
return await asyncio.gather(
|
||||||
*[self.search(
|
*[self.search(
|
||||||
collection_name = collection_name,
|
collection_name = collection_name,
|
||||||
query_vector = query_vector,
|
query_vector = query_vector,
|
||||||
|
|
|
||||||
|
|
@ -200,7 +200,7 @@ class PGVectorAdapter(SQLAlchemyAdapter, VectorDBInterface):
|
||||||
):
|
):
|
||||||
query_vectors = await self.embedding_engine.embed_text(query_texts)
|
query_vectors = await self.embedding_engine.embed_text(query_texts)
|
||||||
|
|
||||||
return asyncio.gather(
|
return await asyncio.gather(
|
||||||
*[
|
*[
|
||||||
self.search(
|
self.search(
|
||||||
collection_name=collection_name,
|
collection_name=collection_name,
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue