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,