added lock upon creating a new Session

MobilityData · Jan 11, 2024 · d465ab0 · d465ab0
1 parent f650561
commit d465ab0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/api/src/database/database.py b/api/src/database/database.py
@@ -90,10 +90,13 @@ def start_session(self):
             if global_session is not None and global_session.is_active:
                 self.logger.info("Database session reused.")
                 return global_session
+            lock.acquire()
             global_session = Session(self.engine, autoflush=False)
             self.logger.info("Singleton Database session started.")
         except Exception as error:
             raise Exception(f"Error creating database session: {error}")
+        finally:
+            lock.release()
         return self.is_connected()