|
@@ -1,29 +1,21 @@
|
|
|
+import concurrent.futures
|
|
|
import json
|
|
|
import threading
|
|
|
-import concurrent.futures
|
|
|
-import time
|
|
|
-import traceback
|
|
|
from concurrent.futures import ThreadPoolExecutor
|
|
|
from datetime import datetime
|
|
|
from typing import Dict
|
|
|
|
|
|
from sqlalchemy import func
|
|
|
|
|
|
-from pqai_agent import logging_service
|
|
|
-from pqai_agent.agents.message_push_agent import MessagePushAgent
|
|
|
from pqai_agent.agents.multimodal_chat_agent import MultiModalChatAgent
|
|
|
from pqai_agent.data_models.agent_configuration import AgentConfiguration
|
|
|
from pqai_agent.data_models.agent_test_task import AgentTestTask
|
|
|
from pqai_agent.data_models.agent_test_task_conversations import AgentTestTaskConversations
|
|
|
from pqai_agent.data_models.service_module import ServiceModule
|
|
|
-from pqai_agent.utils.prompt_utils import format_agent_profile
|
|
|
+from pqai_agent.logging import logger
|
|
|
from pqai_agent_server.const.status_enum import TestTaskConversationsStatus, TestTaskStatus, get_test_task_status_desc
|
|
|
-from concurrent.futures import ThreadPoolExecutor
|
|
|
-
|
|
|
from scripts.evaluate_agent import evaluate_agent
|
|
|
|
|
|
-logger = logging_service.logger
|
|
|
-
|
|
|
|
|
|
class TaskManager:
|
|
|
"""任务管理器"""
|