diff --git a/stage4/graph_outbox.py b/stage4/graph_outbox.py index b01fad6..471afff 100644 --- a/stage4/graph_outbox.py +++ b/stage4/graph_outbox.py @@ -121,11 +121,12 @@ def sync_relations() -> None: relations = get_relations() print(f" graph_outbox: {len(relations)} связей → AGE") - # Удалить старые вершины/ёбра для идемпотентности + # Удалить старые вершины/рёбра для идемпотентности + # AGE: рёбра нужно удалить до вершин → DETACH DELETE _cypher( "SET search_path TO ag_catalog;" f"SELECT * FROM cypher('{GRAPH_NAME}', $$ " - f"MATCH (v) DELETE v $$) AS (v agtype);" + f"MATCH (v) DETACH DELETE v $$) AS (v agtype);" ) # Вершины: уникальный set atom_id (создаём напрямую)