clean_agent

agent.py

@@ -192,7 +192,6 @@ def restore_interrupted_processes():
 def restore_parsing_processes():
     """恢复解析中断的流程"""
     try:
-        
         # 查询parsing_status=1的请求
         sql = "SELECT request_id FROM knowledge_request WHERE parsing_status = 1"
         rows = MysqlHelper.get_values(sql)
@@ -218,7 +217,6 @@ def restore_parsing_processes():
 def restore_extraction_processes():
     """恢复提取中断的流程"""
     try:
-        
         # 查询extraction_status=1的请求和query
         sql = "SELECT request_id, query FROM knowledge_request WHERE extraction_status = 1"
         rows = MysqlHelper.get_values(sql)
@@ -245,7 +243,6 @@ def restore_extraction_processes():
 def restore_expansion_processes():
     """恢复扩展中断的流程"""
     try:
-        
         # 查询expansion_status=1的请求和query
         sql = "SELECT request_id, query FROM knowledge_request WHERE expansion_status = 1"
         rows = MysqlHelper.get_values(sql)
@@ -792,7 +789,6 @@ async def expand(request: ExpandRequest):
         def _execute_expand_sync():
             try:
                 # 直接调用同步函数，使用线程池
-                from agents.expand_agent.agent import execute_expand_agent_with_api
                 result = execute_expand_agent_with_api(requestId, query)
                 # 更新状态为处理完成
                 _update_expansion_status(requestId, 2)