|
@@ -7,7 +7,6 @@ from dataclasses import fields
|
|
from applications.utils.neo4j import AsyncNeo4jRepository
|
|
from applications.utils.neo4j import AsyncNeo4jRepository
|
|
from applications.utils.neo4j import Document, GraphChunk, ChunkRelations
|
|
from applications.utils.neo4j import Document, GraphChunk, ChunkRelations
|
|
from applications.utils.mysql import ContentChunks
|
|
from applications.utils.mysql import ContentChunks
|
|
-from applications.utils.async_utils import run_tasks_with_asyncio_task_group
|
|
|
|
|
|
|
|
|
|
|
|
class BuildGraph(AsyncNeo4jRepository):
|
|
class BuildGraph(AsyncNeo4jRepository):
|
|
@@ -70,10 +69,3 @@ class BuildGraph(AsyncNeo4jRepository):
|
|
chunk_list = await self.get_chunk_list_from_es(doc_id)
|
|
chunk_list = await self.get_chunk_list_from_es(doc_id)
|
|
for chunk in chunk_list:
|
|
for chunk in chunk_list:
|
|
await self.add_single_chunk(chunk)
|
|
await self.add_single_chunk(chunk)
|
|
- # await run_tasks_with_asyncio_task_group(
|
|
|
|
- # task_list=chunk_list,
|
|
|
|
- # handler=self.add_single_chunk,
|
|
|
|
- # description="build graph",
|
|
|
|
- # unit="chunk",
|
|
|
|
- # max_concurrency=10,
|
|
|
|
- # )
|
|
|