From d1c307d1a69289928a4ee83d88e25ed5fc1c24d2 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期二, 19 十一月 2024 22:22:47 +0800
Subject: [PATCH] fix
---
app/task/sync_resources.py | 15 ++++++++++-----
1 files changed, 10 insertions(+), 5 deletions(-)
diff --git a/app/task/sync_resources.py b/app/task/sync_resources.py
index 5fddf33..15ed55d 100644
--- a/app/task/sync_resources.py
+++ b/app/task/sync_resources.py
@@ -1,3 +1,5 @@
+import asyncio
+
from fastapi import Depends
from Log import logger
@@ -9,11 +11,12 @@
from app.service.ragflow import RagflowService
-async def sync_resource():
- await sync_knowledge()
- await sync_dialog()
- await sync_agent()
- await sync_llm()
+def sync_resource():
+ asyncio.run(sync_knowledge())
+ asyncio.run(sync_dialog())
+ asyncio.run(sync_agent())
+ asyncio.run(sync_llm())
+
async def sync_knowledge(db=Depends(get_db)):
@@ -24,12 +27,14 @@
if rapp.app_type == AgentType.RAGFLOW:
token = ""
ragflow_service = RagflowService(settings.fwr_base_url)
+ ragflow_service.get_knowledge_list()
elif rapp.app_type ==AgentType.BISHENG:
token = ""
bisheng_service = BishengService(settings.sgb_base_url)
else:
logger.error("娉ㄥ唽鏈煡搴旂敤锛歿}".format(rapp.app_type))
+
async def sync_dialog():
...
--
Gitblit v1.8.0