diff --git a/graphiti_core/utils/maintenance/edge_operations.py b/graphiti_core/utils/maintenance/edge_operations.py index bd030400..ad9267bf 100644 --- a/graphiti_core/utils/maintenance/edge_operations.py +++ b/graphiti_core/utils/maintenance/edge_operations.py @@ -274,8 +274,14 @@ async def resolve_extracted_edges( # Determine which edge types are relevant for each edge edge_types_lst: list[dict[str, BaseModel]] = [] for extracted_edge in extracted_edges: - source_node_labels = uuid_entity_map[extracted_edge.source_node_uuid].labels + ['Entity'] - target_node_labels = uuid_entity_map[extracted_edge.target_node_uuid].labels + ['Entity'] + source_node = uuid_entity_map.get(extracted_edge.source_node_uuid) + target_node = uuid_entity_map.get(extracted_edge.target_node_uuid) + source_node_labels = ( + source_node.labels + ['Entity'] if source_node is not None else ['Entity'] + ) + target_node_labels = ( + target_node.labels + ['Entity'] if target_node is not None else ['Entity'] + ) label_tuples = [ (source_label, target_label) for source_label in source_node_labels diff --git a/pyproject.toml b/pyproject.toml index 833fcd90..841dddd5 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,7 +1,7 @@ [project] name = "graphiti-core" description = "A temporal graph building library" -version = "0.17.5" +version = "0.17.6" authors = [ { "name" = "Paul Paliychuk", "email" = "paul@getzep.com" }, { "name" = "Preston Rasmussen", "email" = "preston@getzep.com" },