Skip to content

Commit b927405

Browse files
committed
add some envs for tools and memory
1 parent d37ff9d commit b927405

File tree

3 files changed

+36
-7
lines changed

3 files changed

+36
-7
lines changed

veadk/memory/long_term_memory.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,15 @@ def model_post_init(self, __context: Any) -> None:
104104

105105
# Once user define backend config, use it directly
106106
if self.backend_config:
107+
if "index" not in self.backend_config:
108+
logger.warning(
109+
"Attribute `index` not provided in backend_config, use `index` or `app_name` instead."
110+
)
111+
self.backend_config["index"] = self.index or self.app_name
112+
113+
logger.debug(
114+
f"Init {self.backend}, Use provided backend config: {self.backend_config}"
115+
)
107116
self._backend = _get_backend_cls(self.backend)(**self.backend_config)
108117
return
109118

veadk/memory/long_term_memory_backends/vikingdb_memory_backend.py

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,23 @@ class VikingDBLTMBackend(BaseLongTermMemoryBackend):
4949
region: str = "cn-beijing"
5050
"""VikingDB memory region"""
5151

52+
memory_type: list[str] = Field(default_factory=list)
53+
5254
def model_post_init(self, __context: Any) -> None:
55+
# We get memory type from:
56+
# 1. user input
57+
# 2. environment variable
58+
# 3. default value
59+
if not self.memory_type:
60+
env_memory_type = os.getenv("DATABASE_VIKING_MEMORY_TYPE")
61+
if env_memory_type:
62+
# "event_1, event_2" -> ["event_1", "event_2"]
63+
self.memory_type = [x.strip() for x in env_memory_type.split(",")]
64+
else:
65+
self.memory_type = ["sys_event_v1", "event_v1"]
66+
67+
logger.info(f"Using memory type: {self.memory_type}")
68+
5369
# check whether collection exist, if not, create it
5470
if not self._collection_exist():
5571
self._create_collection()
@@ -135,10 +151,7 @@ def save_memory(self, user_id: str, event_strings: list[str], **kwargs) -> bool:
135151
def search_memory(
136152
self, user_id: str, query: str, top_k: int, **kwargs
137153
) -> list[str]:
138-
filter = {
139-
"user_id": user_id,
140-
"memory_type": ["sys_event_v1", "event_v1"],
141-
}
154+
filter = {"user_id": user_id, "memory_type": self.memory_type}
142155

143156
logger.debug(
144157
f"Request for search memory in VikingDB: filter={filter}, collection_name={self.index}, query={query}, limit={top_k}"

veadk/tools/builtin_tools/run_code.py

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,16 @@ def run_code(code: str, language: str, tool_context: ToolContext) -> str:
3636

3737
tool_id = getenv("AGENTKIT_TOOL_ID")
3838
host = getenv("AGENTKIT_TOOL_HOST") # temporary host for code run tool
39+
service = getenv(
40+
"AGENTKIT_TOOL_SERVICE_CODE"
41+
) # temporary service for code run tool
42+
region = getenv("AGENTKIT_TOOL_REGION", "cn-beijing")
43+
3944
session_id = tool_context._invocation_context.session.id
4045

41-
logger.debug(f"Running code in language: {language}, session_id={session_id}")
46+
logger.debug(
47+
f"Running code in language: {language}, session_id={session_id}, code={code}, tool_id={tool_id}, host={host}, service={service}, region={region}"
48+
)
4249

4350
access_key = getenv("VOLCENGINE_ACCESS_KEY")
4451
secret_key = getenv("VOLCENGINE_SECRET_KEY")
@@ -59,9 +66,9 @@ def run_code(code: str, language: str, tool_context: ToolContext) -> str:
5966
action="InvokeTool",
6067
ak=access_key,
6168
sk=secret_key,
62-
service="agentkit_stg",
69+
service=service,
6370
version="2025-10-30",
64-
region="cn-beijing",
71+
region=region,
6572
host=host,
6673
)
6774

0 commit comments

Comments
 (0)