fix (operate): commented duplicate function

This commit is contained in:
GGrassia 2025-10-08 16:33:03 +02:00
parent 4535af4e2a
commit c35f74b44c

View file

@ -2,6 +2,7 @@ from __future__ import annotations
from functools import partial from functools import partial
import asyncio import asyncio
import re
import json import json
import json_repair import json_repair
from typing import Any, AsyncIterator, overload, Literal from typing import Any, AsyncIterator, overload, Literal
@ -2069,7 +2070,7 @@ async def extract_entities(
processed_chunks = 0 processed_chunks = 0
total_chunks = len(ordered_chunks) total_chunks = len(ordered_chunks)
async def _process_extraction_result( '''async def _process_extraction_result(
result: str, result: str,
chunk_key: str, chunk_key: str,
file_path: str = "unknown_source", file_path: str = "unknown_source",
@ -2116,7 +2117,7 @@ async def extract_entities(
if_relation if_relation
) )
return maybe_nodes, maybe_edges return maybe_nodes, maybe_edges'''
async def _process_single_content(chunk_key_dp: tuple[str, TextChunkSchema]): async def _process_single_content(chunk_key_dp: tuple[str, TextChunkSchema]):
"""Process a single chunk """Process a single chunk