init_db() only once on initial import of db

pAI-OS · Jul 20, 2024 · c01bd62 · c01bd62
1 parent 2a1dc26
commit c01bd62
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 4 deletions.
diff --git a/backend/db.py b/backend/db.py
@@ -17,6 +17,9 @@ def init_db():
     alembic_cfg.set_main_option("sqlalchemy.url", f"sqlite:///{db_path}")
     command.upgrade(alembic_cfg, "head")
 
+# Call init_db() when the module is first imported
+init_db()
+
 async def execute_query(query, params=None):
     # TODO: logger.adebug from structlog
     logger.debug(f"Executing query: {query} with params: {params}")

diff --git a/backend/managers/AssetsManager.py b/backend/managers/AssetsManager.py
@@ -18,7 +18,7 @@ def __init__(self):
         if not hasattr(self, '_initialized'):
             with self._lock:
                 if not hasattr(self, '_initialized'):
-                    db.init_db()
+                    # db.init_db()
                     self._initialized = True
 
     async def create_asset(self, user_id, title, creator, subject, description):

diff --git a/backend/managers/ChannelsManager.py b/backend/managers/ChannelsManager.py
@@ -17,7 +17,7 @@ def __init__(self):
         if not hasattr(self, '_initialized'):
             with self._lock:
                 if not hasattr(self, '_initialized'):
-                    db.init_db()
+                    # db.init_db()
                     self._initialized = True
 
     async def create_channel(self, name, uri):

diff --git a/backend/managers/ConfigManager.py b/backend/managers/ConfigManager.py
@@ -20,7 +20,7 @@ def __init__(self, tenant=None):
                 if not hasattr(self, '_initialized'):
                     self.encryption = Encryption()
                     self.tenant = tenant
-                    db.init_db()
+                    # db.init_db()
                     self._initialized = True
 
     # CRUD operations

diff --git a/backend/managers/UsersManager.py b/backend/managers/UsersManager.py
@@ -17,7 +17,7 @@ def __init__(self):
         if not hasattr(self, '_initialized'):
             with self._lock:
                 if not hasattr(self, '_initialized'):
-                    db.init_db()
+                    # db.init_db()
                     self._initialized = True
 
     async def create_user(self, name, email):