diff --git a/app/pipeline_app.py b/app/pipeline_app.py
index 66de353..d7d371d 100644
--- a/app/pipeline_app.py
+++ b/app/pipeline_app.py
@@ -8,6 +8,14 @@ sys.path.insert(0, root_dir)
 sys.path.insert(0, app_dir)
 
 from ahserver.webapp import webapp
+from ahserver.serverenv import ServerEnv
+
+
+def get_module_dbname(mname):
+    """Map module name to database. Pipeline business modules use 'pipeline', shared services use 'sage'."""
+    if 'pipeline' in mname:
+        return 'pipeline'
+    return 'sage'
 
 
 def init():
@@ -37,6 +45,7 @@ def init():
     from global_func import set_globalvariable
 
     set_globalvariable()
+    ServerEnv().get_module_dbname = get_module_dbname
     load_pybricks()
     load_appbase()
     load_rbac()