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

update

Browse source
This commit is contained in:
prestonrasmussen 2025-09-08 14:27:31 -04:00
parent c5ebc9e2e1
commit a1005edc2a
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
graphiti_core/graphiti.py
View file

@ -113,6 +113,15 @@ class AddEpisodeResults(BaseModel):
community_edges: list[CommunityEdge] community_edges: list[CommunityEdge]
class AddBulkEpisodeResults(BaseModel):
episodes: list[EpisodicNode]
episodic_edges: list[EpisodicEdge]
nodes: list[EntityNode]
edges: list[EntityEdge]
communities: list[CommunityNode]
community_edges: list[CommunityEdge]
class Graphiti: class Graphiti:
def __init__( def __init__(
self, self,
@ -580,7 +589,7 @@ class Graphiti:
excluded_entity_types: list[str] | None = None, excluded_entity_types: list[str] | None = None,
edge_types: dict[str, type[BaseModel]] | None = None, edge_types: dict[str, type[BaseModel]] | None = None,
edge_type_map: dict[tuple[str, str], list[str]] | None = None, edge_type_map: dict[tuple[str, str], list[str]] | None = None,
) -> AddEpisodeResults: ) -> AddBulkEpisodeResults:
""" """
Process multiple episodes in bulk and update the graph. Process multiple episodes in bulk and update the graph.
@ -848,7 +857,7 @@ class Graphiti:
end = time() end = time()
logger.info(f'Completed add_episode_bulk in {(end - start) * 1000} ms') logger.info(f'Completed add_episode_bulk in {(end - start) * 1000} ms')
return AddEpisodeResults( return AddBulkEpisodeResults(
episode=episodes, episode=episodes,
episodic_edges=resolved_episodic_edges, episodic_edges=resolved_episodic_edges,
nodes=final_hydrated_nodes, nodes=final_hydrated_nodes,