Update operate.py
This commit is contained in:
parent
516b4dfb22
commit
ef41871b88
1 changed files with 2 additions and 2 deletions
|
|
@ -124,14 +124,14 @@ async def _handle_single_relationship_extraction(
|
||||||
async def _merge_nodes_then_upsert(
|
async def _merge_nodes_then_upsert(
|
||||||
entity_name: str,
|
entity_name: str,
|
||||||
nodes_data: list[dict],
|
nodes_data: list[dict],
|
||||||
knwoledge_graph_inst: BaseGraphStorage,
|
knowledge_graph_inst: BaseGraphStorage,
|
||||||
global_config: dict,
|
global_config: dict,
|
||||||
):
|
):
|
||||||
already_entitiy_types = []
|
already_entitiy_types = []
|
||||||
already_source_ids = []
|
already_source_ids = []
|
||||||
already_description = []
|
already_description = []
|
||||||
|
|
||||||
already_node = await knwoledge_graph_inst.get_node(entity_name)
|
already_node = await knowledge_graph_inst.get_node(entity_name)
|
||||||
if already_node is not None:
|
if already_node is not None:
|
||||||
already_entitiy_types.append(already_node["entity_type"])
|
already_entitiy_types.append(already_node["entity_type"])
|
||||||
already_source_ids.extend(
|
already_source_ids.extend(
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue