From 75019b9b2214da4c370cce68c9aab48de5134d85 Mon Sep 17 00:00:00 2001 From: Don Tang Date: Wed, 29 Oct 2025 14:14:33 +0800 Subject: [PATCH] Fix malformed query exception on neptune edge_fulltext_search --- graphiti_core/search/search_utils.py | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/graphiti_core/search/search_utils.py b/graphiti_core/search/search_utils.py index 4c0e84fa..9157e8d0 100644 --- a/graphiti_core/search/search_utils.py +++ b/graphiti_core/search/search_utils.py @@ -214,17 +214,16 @@ async def edge_fulltext_search( for r in res['hits']['hits']: input_ids.append({'id': r['_source']['uuid'], 'score': r['_score']}) + filter_query = filter_query + ' AND id(e)=id ' if filter_query else ' WHERE id(e)=id ' + # Match the edge ids and return the values query = ( """ - UNWIND $ids as id - MATCH (n:Entity)-[e:RELATES_TO]->(m:Entity) - WHERE e.group_id IN $group_ids - AND id(e)=id - """ - + filter_query - + """ - AND id(e)=id + UNWIND $ids as id + MATCH (n:Entity)-[e:RELATES_TO]->(m:Entity) + """ + + filter_query + + """ WITH e, id.score as score, startNode(e) AS n, endNode(e) AS m RETURN e.uuid AS uuid, @@ -240,7 +239,7 @@ async def edge_fulltext_search( e.invalid_at AS invalid_at, properties(e) AS attributes ORDER BY score DESC LIMIT $limit - """ + """ ) records, _, _ = await driver.execute_query(