update

app/services/file/impl/r2r_file.py

@@ -84,10 +84,13 @@ class R2RFileService(OSSFileService):
         """
         print("filtersfiltersfiltersfiltersfiltersfiltersfiltersfiltersfiltersfilters")
         print(filters)
+        """
         loop = asyncio.get_event_loop()  # 获取当前事件循环
         loop.run_until_complete(r2r.init())  # 确保 r2r 已初始化
         search_results = loop.run_until_complete(r2r.search(query, filters=filters))
-
+        """
+        asyncio.run(r2r.init())
+        search_results = asyncio.run(r2r.search(query, filters=filters))
         if not search_results:
             return files
 
@@ -107,11 +110,15 @@ class R2RFileService(OSSFileService):
         offset: int = 0,
         limit: int = 100,
     ) -> dict:
+        """
         loop = asyncio.get_event_loop()  # 获取当前事件循环
         loop.run_until_complete(r2r.init())  # 确保 r2r 已初始化
         list_results = loop.run_until_complete(
             r2r.list(ids=ids, offset=offset, limit=limit)
         )
+        """
+        asyncio.run(r2r.init())
+        list_results = asyncio.run(r2r.list(ids=ids, offset=offset, limit=limit))
         return list_results
 
     @staticmethod
@@ -120,11 +127,17 @@ class R2RFileService(OSSFileService):
         offset: int = 0,
         limit: int = 100,
     ) -> dict:
+        """
         loop = asyncio.get_event_loop()  # 获取当前事件循环
         loop.run_until_complete(r2r.init())  # 确保 r2r 已初始化
         list_results = loop.run_until_complete(
             r2r.list_documents(id=id, offset=offset, limit=limit)
         )
+        """
+        asyncio.run(r2r.init())
+        list_results = asyncio.run(
+            r2r.list_documents(id=id, offset=offset, limit=limit)
+        )
         return list_results
 
     # TODO 删除s3&r2r文件