Add return to add_triplet (#898)

* update

* add triplet results

* Update graphiti_core/graphiti.py

Co-authored-by: claude[bot] <209825114+claude[bot]@users.noreply.github.com>

---------

Co-authored-by: claude[bot] <209825114+claude[bot]@users.noreply.github.com>
This commit is contained in:
Preston Rasmussen 2025-09-08 15:39:05 -04:00 committed by GitHub
parent 7e6d93fa32
commit ce1ae30569
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 11 additions and 3 deletions

View file

@ -122,6 +122,11 @@ class AddBulkEpisodeResults(BaseModel):
community_edges: list[CommunityEdge]
class AddTripletResults(BaseModel):
nodes: list[EntityNode]
edges: list[EntityEdge]
class Graphiti:
def __init__(
self,
@ -1015,7 +1020,9 @@ class Graphiti:
return SearchResults(edges=edges, nodes=nodes)
async def add_triplet(self, source_node: EntityNode, edge: EntityEdge, target_node: EntityNode):
async def add_triplet(
self, source_node: EntityNode, edge: EntityEdge, target_node: EntityNode
) -> AddTripletResults:
if source_node.name_embedding is None:
await source_node.generate_name_embedding(self.embedder)
if target_node.name_embedding is None:
@ -1059,6 +1066,7 @@ class Graphiti:
await create_entity_node_embeddings(self.embedder, nodes)
await add_nodes_and_edges_bulk(self.driver, [], [], nodes, edges, self.embedder)
return AddTripletResults(edges=edges, nodes=nodes)
async def remove_episode(self, episode_uuid: str):
# Find the episode to be deleted

View file

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

2
uv.lock generated
View file

@ -783,7 +783,7 @@ wheels = [
[[package]]
name = "graphiti-core"
version = "0.20.3"
version = "0.20.4"
source = { editable = "." }
dependencies = [
{ name = "diskcache" },