From 7245cb5a33d7b0780a805419bbf00a309943080f Mon Sep 17 00:00:00 2001 From: prestonrasmussen Date: Wed, 24 Sep 2025 17:16:50 -0400 Subject: [PATCH] remove build duplicate edges --- graphiti_core/graphiti.py | 1 - .../utils/maintenance/edge_operations.py | 26 ------------------- 2 files changed, 27 deletions(-) diff --git a/graphiti_core/graphiti.py b/graphiti_core/graphiti.py index c61dc247..e27ea9c6 100644 --- a/graphiti_core/graphiti.py +++ b/graphiti_core/graphiti.py @@ -79,7 +79,6 @@ from graphiti_core.utils.maintenance.community_operations import ( update_community, ) from graphiti_core.utils.maintenance.edge_operations import ( - build_duplicate_of_edges, build_episodic_edges, extract_edges, resolve_extracted_edge, diff --git a/graphiti_core/utils/maintenance/edge_operations.py b/graphiti_core/utils/maintenance/edge_operations.py index 5de8d22a..259c1db3 100644 --- a/graphiti_core/utils/maintenance/edge_operations.py +++ b/graphiti_core/utils/maintenance/edge_operations.py @@ -65,32 +65,6 @@ def build_episodic_edges( return episodic_edges -def build_duplicate_of_edges( - episode: EpisodicNode, - created_at: datetime, - duplicate_nodes: list[tuple[EntityNode, EntityNode]], -) -> list[EntityEdge]: - is_duplicate_of_edges: list[EntityEdge] = [] - for source_node, target_node in duplicate_nodes: - if source_node.uuid == target_node.uuid: - continue - - is_duplicate_of_edges.append( - EntityEdge( - source_node_uuid=source_node.uuid, - target_node_uuid=target_node.uuid, - name='IS_DUPLICATE_OF', - group_id=episode.group_id, - fact=f'{source_node.name} is a duplicate of {target_node.name}', - episodes=[episode.uuid], - created_at=created_at, - valid_at=created_at, - ) - ) - - return is_duplicate_of_edges - - def build_community_edges( entity_nodes: list[EntityNode], community_node: CommunityNode,