|
@@ -4,10 +4,11 @@ from r2r import R2RClient
|
|
|
from fastapi import UploadFile
|
|
|
from app.libs.util import verify_jwt_expiration
|
|
|
from config.llm import tool_settings
|
|
|
-import nest_asyncio
|
|
|
+
|
|
|
+# import nest_asyncio
|
|
|
|
|
|
# 使得异步代码可以在已运行的事件循环中嵌套
|
|
|
-nest_asyncio.apply()
|
|
|
+# nest_asyncio.apply()
|
|
|
|
|
|
client = R2RAsyncClient(tool_settings.R2R_BASE_URL)
|
|
|
client_sync = R2RClient(tool_settings.R2R_BASE_URL)
|
|
@@ -63,6 +64,7 @@ class R2R:
|
|
|
metadata=metadata if metadata else None,
|
|
|
ingestion_mode="fast",
|
|
|
id=None,
|
|
|
+ run_with_orchestration=False,
|
|
|
)
|
|
|
|
|
|
async def ingest_fileinfo(self, file: UploadFile, metadata: Optional[dict]):
|