gmakstutis/graphiti
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

edge operations update (#539)

Browse source 
* edge operations update

* bump version

* edge name

* update
This commit is contained in:
Preston Rasmussen 2025-05-28 16:33:20 -04:00 • committed by GitHub
parent 5fe2f588a6
commit a9a6ee6bf0
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 11 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
graphiti_core/utils/maintenance/edge_operations.py
View file

@ -160,6 +160,14 @@ async def extract_edges(
invalid_at = edge_data.get('invalid_at', None)
valid_at_datetime = None
invalid_at_datetime = None
source_node_uuid = node_uuids_by_name_map.get(edge_data.get('source_entity_name', ''), '')
target_node_uuid = node_uuids_by_name_map.get(edge_data.get('target_entity_name', ''), '')
if source_node_uuid == '' or target_node_uuid == '':
logger.warning(
f'WARNING: source or target node not filled {edge_data.get("edge_name")}. source_node_uuid: {source_node_uuid} and target_node_uuid: {target_node_uuid} '
)
continue
if valid_at:
try:
@ -177,12 +185,8 @@ async def extract_edges(
except ValueError as e:
logger.warning(f'WARNING: Error parsing invalid_at date: {e}. Input: {invalid_at}')
edge = EntityEdge(
source_node_uuid=node_uuids_by_name_map.get(
edge_data.get('source_entity_name', ''), ''
),
target_node_uuid=node_uuids_by_name_map.get(
edge_data.get('target_entity_name', ''), ''
),
source_node_uuid=source_node_uuid,
target_node_uuid=target_node_uuid,
name=edge_data.get('relation_type', ''),
group_id=group_id,
fact=edge_data.get('fact', ''),

2
pyproject.toml
View file

@ -1,7 +1,7 @@
[project]
name = "graphiti-core"
description = "A temporal graph building library"
version = "0.12.0"
version = "0.12.0pre2"
authors = [
{ "name" = "Paul Paliychuk", "email" = "paul@getzep.com" },
{ "name" = "Preston Rasmussen", "email" = "preston@getzep.com" },