1- from pathlib import Path
2- from dotenv import load_dotenv
3-
41from dp .agent .adapter .adk import CalculationMCPToolset
5- from google .adk .agents import LlmAgent , BaseAgent
6- from google .adk .models .lite_llm import LiteLlm
7- from google .adk .runners import Runner
2+ from google .adk .agents import BaseAgent
83from google .adk .tools .mcp_tool .mcp_session_manager import SseServerParams
94
10- from agents .matmaster_agent import llm_config
11- from agents .matmaster_agent .llm_config import MatMasterLlmConfig
12- from agents .matmaster_agent .logger import matmodeler_logging_handler
13-
14- from agents .matmaster_agent .base_agents .job_agent import (
15- BaseAsyncJobAgent ,
16- ResultCalculationMCPLlmAgent ,
17- SubmitCoreCalculationMCPLlmAgent ,
18- )
19-
20- from agents .matmaster_agent .constant import (
21- MATMASTER_AGENT_NAME ,
22- BohriumExecutor ,
23- BohriumStorge ,
24- LOCAL_EXECUTOR
5+ from agents .matmaster_agent .ABACUS_agent .constant import (
6+ ABACUS_CALCULATOR_BOHRIUM_EXECUTOR ,
7+ ABACUS_CALCULATOR_BOHRIUM_STORAGE ,
8+ ABACUS_CALCULATOR_URL ,
259)
26-
2710from agents .matmaster_agent .ABACUS_agent .prompt import (
28- ABACUS_AGENT_NAME ,
2911 ABACUS_AGENT_DESCRIPTION ,
3012 ABACUS_AGENT_INSTRUCTION ,
31- ABACUS_SUBMIT_CORE_AGENT_NAME ,
32- ABACUS_SUBMIT_CORE_AGENT_DESCRIPTION ,
33- ABACUS_SUBMIT_CORE_AGENT_INSTRUCTION ,
34- ABACUS_SUBMIT_RENDER_AGENT_NAME ,
35- ABACUS_RESULT_CORE_AGENT_NAME ,
36- ABACUS_RESULT_CORE_AGENT_INSTRUCTION ,
37- ABACUS_RESULT_TRANSFER_AGENT_NAME ,
38- ABACUS_RESULT_TRANSFER_AGENT_INSTRUCTION ,
39- ABACUS_TRANSFER_AGENT_NAME ,
40- ABACUS_TRANSFER_AGENT_INSTRCUTION ,
41- ABACUS_SUBMIT_AGENT_NAME ,
42- ABACUS_SUBMIT_AGENT_DESCRIPTION ,
43- ABACUS_RESULT_AGENT_NAME ,
44- ABACUS_RESULT_AGENT_DESCRIPTION
45- )
46-
47- from agents .matmaster_agent .ABACUS_agent .constant import (
48- ABACUS_CALCULATOR_URL ,
49- ABACUS_CALCULATOR_BOHRIUM_EXECUTOR ,
50- ABACUS_CALCULATOR_BOHRIUM_STORAGE ,
13+ ABACUS_AGENT_NAME ,
5114)
15+ from agents .matmaster_agent .base_agents .job_agent import BaseAsyncJobAgent
16+ from agents .matmaster_agent .constant import MATMASTER_AGENT_NAME
17+ from agents .matmaster_agent .logger import matmodeler_logging_handler
5218
5319mcp_tools_abacus = CalculationMCPToolset (
5420 connection_params = SseServerParams (
5521 url = ABACUS_CALCULATOR_URL ,
56- sse_read_timeout = 3600 ,
22+ sse_read_timeout = 3600 ,
5723 ),
58- executor = ABACUS_CALCULATOR_BOHRIUM_EXECUTOR ,
59- storage = ABACUS_CALCULATOR_BOHRIUM_STORAGE ,
24+ executor = ABACUS_CALCULATOR_BOHRIUM_EXECUTOR ,
25+ storage = ABACUS_CALCULATOR_BOHRIUM_STORAGE ,
6026 async_mode = True ,
6127 wait = False ,
62- logging_callback = matmodeler_logging_handler
28+ logging_callback = matmodeler_logging_handler ,
6329)
6430
31+
6532class ABACUSCalculatorAgent (BaseAsyncJobAgent ):
6633 def __init__ (self , llm_config ):
6734 super ().__init__ (
@@ -72,11 +39,14 @@ def __init__(self, llm_config):
7239 agent_instruction = ABACUS_AGENT_INSTRUCTION ,
7340 dflow_flag = False ,
7441 supervisor_agent = MATMASTER_AGENT_NAME ,
75- sync_tools = ['abacus_prepare' ,
76- 'abacus_modify_input' ,
77- 'abacus_modify_stru' ,
78- 'abacus_collect_data' ]
42+ sync_tools = [
43+ 'abacus_prepare' ,
44+ 'abacus_modify_input' ,
45+ 'abacus_modify_stru' ,
46+ 'abacus_collect_data' ,
47+ ],
7948 )
8049
50+
8151def init_abacus_calculation_agent (llm_config ) -> BaseAgent :
8252 return ABACUSCalculatorAgent (llm_config )
0 commit comments