Skip to content

Commit 8b73068

Browse files
fix
1 parent e0890a7 commit 8b73068

1 file changed

Lines changed: 3 additions & 8 deletions

File tree

  • integrations/falkordb/src/haystack_integrations/document_stores/falkordb

integrations/falkordb/src/haystack_integrations/document_stores/falkordb/document_store.py

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -511,9 +511,7 @@ def count_documents_by_filter(self, filters: dict[str, Any]) -> int:
511511
rows = result.result_set
512512
return int(rows[0][0]) if rows else 0
513513

514-
def count_unique_metadata_by_filter(
515-
self, filters: dict[str, Any], metadata_fields: list[str]
516-
) -> dict[str, int]:
514+
def count_unique_metadata_by_filter(self, filters: dict[str, Any], metadata_fields: list[str]) -> dict[str, int]:
517515
"""
518516
Return the number of unique values for each metadata field among matching documents.
519517
@@ -557,9 +555,7 @@ def get_metadata_fields_info(self) -> dict[str, dict[str, str]]:
557555

558556
info: dict[str, dict[str, str]] = {}
559557
for key in sorted(all_keys):
560-
res = self.graph.query(
561-
f"MATCH (d:{self.node_label}) WHERE d.{key} IS NOT NULL RETURN d.{key} LIMIT 1"
562-
)
558+
res = self.graph.query(f"MATCH (d:{self.node_label}) WHERE d.{key} IS NOT NULL RETURN d.{key} LIMIT 1")
563559
if not res.result_set:
564560
continue
565561
val = res.result_set[0][0]
@@ -585,8 +581,7 @@ def get_metadata_field_min_max(self, metadata_field: str) -> dict[str, Any]:
585581
self._ensure_connected()
586582
field = metadata_field[5:] if metadata_field.startswith("meta.") else metadata_field
587583
result = self.graph.query(
588-
f"MATCH (d:{self.node_label}) WHERE d.{field} IS NOT NULL "
589-
f"RETURN min(d.{field}), max(d.{field})"
584+
f"MATCH (d:{self.node_label}) WHERE d.{field} IS NOT NULL RETURN min(d.{field}), max(d.{field})"
590585
)
591586
if not result.result_set:
592587
return {"min": None, "max": None}

0 commit comments

Comments
 (0)