Skip to content

Commit c74858e

Browse files
committed
Fix test
1 parent a24fe73 commit c74858e

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

langchain_postgres/vectorstore/async_vectorstore.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -849,8 +849,6 @@ async def is_valid_index(
849849
async def aget_by_ids(self, ids: Sequence[str]) -> list[Document]:
850850
"""Get documents by ids."""
851851

852-
quoted_ids = [f"'{id_val}'" for id_val in ids]
853-
854852
columns = self.metadata_columns + [
855853
self.id_column,
856854
self.content_column,
@@ -861,7 +859,7 @@ async def aget_by_ids(self, ids: Sequence[str]) -> list[Document]:
861859
column_names = ", ".join(f'"{col}"' for col in columns)
862860

863861
placeholders = ", ".join(f":id_{i}" for i in range(len(ids)))
864-
param_dict = {f"id_{i}": id for i, id in enumerate(quoted_ids)}
862+
param_dict = {f"id_{i}": id for i, id in enumerate(ids)}
865863

866864
query = f'SELECT {column_names} FROM "{self.schema_name}"."{self.table_name}" WHERE "{self.id_column}" IN ({placeholders});'
867865

tests/unit_tests/v2/test_async_pg_vectorstore_index.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
from tests.utils import VECTORSTORE_CONNECTION_STRING_ASYNCPG as CONNECTION_STRING
2020

2121
DEFAULT_TABLE = "default" + str(uuid.uuid4()).replace("-", "_")
22-
DEFAULT_INDEX_NAME = DEFAULT_TABLE + DEFAULT_INDEX_NAME_SUFFIX
22+
DEFAULT_INDEX_NAME = DEFAULT_TABLE + "index"
2323
VECTOR_SIZE = 768
2424

2525
embeddings_service = DeterministicFakeEmbedding(size=VECTOR_SIZE)

0 commit comments

Comments
 (0)