From a8ec45b1bded1392cc8b7c708815fb9fc5eed3e6 Mon Sep 17 00:00:00 2001 From: Naseem Ali <34807727+Naseem77@users.noreply.github.com> Date: Sun, 12 Oct 2025 19:42:52 +0300 Subject: [PATCH] fix: wrap embeddings with vecf32() in FalkorDB single save paths (#991) Fixes #972. Entity and edge single save operations now properly convert embeddings to vecf32 type, matching bulk save behavior and preventing type mismatch errors during vector similarity searches. --- graphiti_core/models/edges/edge_db_queries.py | 1 + graphiti_core/models/nodes/node_db_queries.py | 1 + 2 files changed, 2 insertions(+) diff --git a/graphiti_core/models/edges/edge_db_queries.py b/graphiti_core/models/edges/edge_db_queries.py index 92e294fb..ef4578e2 100644 --- a/graphiti_core/models/edges/edge_db_queries.py +++ b/graphiti_core/models/edges/edge_db_queries.py @@ -68,6 +68,7 @@ def get_entity_edge_save_query(provider: GraphProvider, has_aoss: bool = False) MATCH (target:Entity {uuid: $edge_data.target_uuid}) MERGE (source)-[e:RELATES_TO {uuid: $edge_data.uuid}]->(target) SET e = $edge_data + SET e.fact_embedding = vecf32($edge_data.fact_embedding) RETURN e.uuid AS uuid """ case GraphProvider.NEPTUNE: diff --git a/graphiti_core/models/nodes/node_db_queries.py b/graphiti_core/models/nodes/node_db_queries.py index 5a6960dd..06158732 100644 --- a/graphiti_core/models/nodes/node_db_queries.py +++ b/graphiti_core/models/nodes/node_db_queries.py @@ -133,6 +133,7 @@ def get_entity_node_save_query(provider: GraphProvider, labels: str, has_aoss: b MERGE (n:Entity {{uuid: $entity_data.uuid}}) SET n:{labels} SET n = $entity_data + SET n.name_embedding = vecf32($entity_data.name_embedding) RETURN n.uuid AS uuid """ case GraphProvider.KUZU: