diff --git a/common/database_helpers.py b/common/database_helpers.py
index d238b0a9..40b475c8 100644
--- a/common/database_helpers.py
+++ b/common/database_helpers.py
@@ -54,6 +54,10 @@ def __init__(self, table):
         super().__init__(table)
         self.include_related_entities = False
 
+    def commit_changes(self):
+        log.info("Closing DB session")
+        self.session.close()
+
     def execute_query(self):
         self.commit_changes()