This commit is contained in:
Yannick Stephan
2025-02-17 23:21:14 +01:00
parent 80272cbf16
commit ba65329898

View File

@@ -228,14 +228,14 @@ async def _merge_nodes_then_upsert(
async def _merge_edges_then_upsert( async def _merge_edges_then_upsert(
src_id: str, src_id: str,
tgt_id: str, tgt_id: str,
edges_data: list[dict[str, Any]], edges_data: list[dict],
knowledge_graph_inst: BaseGraphStorage, knowledge_graph_inst: BaseGraphStorage,
global_config: dict[str, str], global_config: dict,
): ):
already_weights: list[float] = [] already_weights = []
already_source_ids: list[str] = [] already_source_ids = []
already_description: list[str] = [] already_description = []
already_keywords: list[str] = [] already_keywords = []
if await knowledge_graph_inst.has_edge(src_id, tgt_id): if await knowledge_graph_inst.has_edge(src_id, tgt_id):
already_edge = await knowledge_graph_inst.get_edge(src_id, tgt_id) already_edge = await knowledge_graph_inst.get_edge(src_id, tgt_id)
@@ -254,11 +254,11 @@ async def _merge_edges_then_upsert(
) )
) )
# Get description with empty string default if missing or None # Get description with empty string default if missing or None
if "description" in already_edge and already_edge["description"] is not None: if "description" in already_edge and already_edge["description"] is not None:
already_description.append(already_edge["description"]) already_description.append(already_edge["description"])
# Get keywords with empty string default if missing or None # Get keywords with empty string default if missing or None
if "keywords" in already_edge and already_edge["keywords"] is not None: if "keywords" in already_edge and already_edge["keywords"] is not None:
already_keywords.extend( already_keywords.extend(
split_string_by_multi_markers( split_string_by_multi_markers(