Skip to content

Commit 2d5437b

Browse files
committed
Use hit _id in Antfly benchmark client
1 parent c636ff5 commit 2d5437b

1 file changed

Lines changed: 5 additions & 10 deletions

File tree

  • vectordb_bench/backend/clients/antfly

vectordb_bench/backend/clients/antfly/antfly.py

Lines changed: 5 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,6 @@ def _metadata_query_body(self, query: list[float], k: int) -> dict[str, Any]:
248248
return {
249249
"embeddings": {"vec": self._serialize_query_vector(query)},
250250
"limit": k,
251-
"fields": ["id"],
252251
**self.case_config.search_param(),
253252
}
254253

@@ -270,14 +269,11 @@ def _parse_metadata_hits(self, data: dict) -> list[int]:
270269
hits = hits_obj.get("hits") or []
271270
results = []
272271
for hit in hits:
273-
if "id" in hit:
274-
results.append(int(hit["id"]))
275-
else:
276-
doc_key = hit.get("_id", "")
277-
try:
278-
results.append(int(doc_key.split(":", 1)[1]))
279-
except (IndexError, ValueError):
280-
log.warning(f"Could not parse id from _id: {doc_key}")
272+
doc_key = hit.get("_id", "")
273+
try:
274+
results.append(int(doc_key.split(":", 1)[1]))
275+
except (IndexError, ValueError):
276+
log.warning(f"Could not parse id from _id: {doc_key}")
281277
return results
282278

283279
def _parse_store_hits(self, data: dict) -> list[int]:
@@ -364,7 +360,6 @@ def search_embedding(
364360
)
365361
r.raise_for_status()
366362
return self._parse_store_hits(r.json())
367-
368363
r = self.client.post(
369364
f"/tables/{self.collection_name}/query",
370365
json=self._metadata_query_body(query, k),

0 commit comments

Comments
 (0)