From 4a8f06d4ae1c2898c4d22b46c7d327ece8d4a5f7 Mon Sep 17 00:00:00 2001 From: neo Date: Mon, 14 Sep 2026 15:43:34 +0500 Subject: [PATCH] =?UTF-8?q?stage4:=20AGE=20graph=20=E2=80=94=20DETACH=20DE?= =?UTF-8?q?LETE=20=D0=B4=D0=BB=D1=8F=20=D0=B8=D0=B4=D0=B5=D0=BC=D0=BF?= =?UTF-8?q?=D0=BE=D1=82=D0=B5=D0=BD=D1=82=D0=BD=D0=BE=D0=B3=D0=BE=20sync?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- stage4/graph_outbox.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 (создаём напрямую)