Skip to content

Commit 307d592

Browse files
authored
fix ivfflat probing on query time (#364)
1 parent 12bd3fc commit 307d592

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

core/vector_store/chunk_v2_store.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -399,7 +399,8 @@ async def query_similar(
399399
)
400400

401401
async with self.get_session_with_retry() as session:
402-
await session.execute(text("SET LOCAL ivfflat.probes = :probes"), {"probes": self.ivfflat_probes})
402+
# PostgreSQL SET doesn't support parameterized values; safe since ivfflat_probes is a validated int
403+
await session.execute(text(f"SET LOCAL ivfflat.probes = {self.ivfflat_probes}"))
403404
result = await session.execute(query)
404405
rows = result.all()
405406

core/vector_store/pgvector_store.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -458,7 +458,8 @@ async def query_similar(
458458
"""
459459
try:
460460
async with self.get_session_with_retry() as session:
461-
await session.execute(text("SET LOCAL ivfflat.probes = :probes"), {"probes": self.ivfflat_probes})
461+
# PostgreSQL SET doesn't support parameterized values; safe since ivfflat_probes is a validated int
462+
await session.execute(text(f"SET LOCAL ivfflat.probes = {self.ivfflat_probes}"))
462463
# Build query with cosine distance calculation, which is normalized to [0, 2].
463464
# A distance of 0 is perfect similarity.
464465
distance = VectorEmbedding.embedding.op("<=>")(query_embedding)

0 commit comments

Comments
 (0)