fix: add env.get_module_dbname() for dynamic database lookup

This commit is contained in:
yumoqing 2026-05-08 15:30:32 +08:00
parent 0a270f2c59
commit 9597cfa7b8
2 changed files with 12 additions and 0 deletions

View File

@ -127,6 +127,8 @@ class HermesReasoningEngine:
dbname = 'default' dbname = 'default'
try: try:
env = ServerEnv()
dbname = env.get_module_dbname('harnessed_reasoning')
config = getConfig() config = getConfig()
db = DBPools() db = DBPools()
db.databases = config.databases db.databases = config.databases
@ -200,6 +202,8 @@ class HermesReasoningEngine:
skills = [] skills = []
try: try:
env = ServerEnv()
dbname = env.get_module_dbname('harnessed_reasoning')
config = getConfig() config = getConfig()
db = DBPools() db = DBPools()
db.databases = config.databases db.databases = config.databases
@ -635,6 +639,8 @@ class HermesReasoningEngine:
'created_at': datetime.now(), 'created_at': datetime.now(),
'updated_at': datetime.now(), 'updated_at': datetime.now(),
} }
env = ServerEnv()
dbname = env.get_module_dbname('harnessed_reasoning')
config = getConfig() config = getConfig()
db = DBPools() db = DBPools()
db.databases = config.databases db.databases = config.databases
@ -649,6 +655,8 @@ class HermesReasoningEngine:
async def _update_session_status(self, session_id: str, status: str): async def _update_session_status(self, session_id: str, status: str):
"""Update session status.""" """Update session status."""
try: try:
env = ServerEnv()
dbname = env.get_module_dbname('harnessed_reasoning')
config = getConfig() config = getConfig()
db = DBPools() db = DBPools()
db.databases = config.databases db.databases = config.databases
@ -674,6 +682,8 @@ class HermesReasoningEngine:
pass pass
try: try:
env = ServerEnv()
dbname = env.get_module_dbname('harnessed_reasoning')
config = getConfig() config = getConfig()
db = DBPools() db = DBPools()
db.databases = config.databases db.databases = config.databases
@ -713,6 +723,8 @@ class HermesReasoningEngine:
pass pass
try: try:
env = ServerEnv()
dbname = env.get_module_dbname('harnessed_reasoning')
config = getConfig() config = getConfig()
db = DBPools() db = DBPools()
db.databases = config.databases db.databases = config.databases