Autoflush Session.

src/sync.py

@@ -29,7 +29,6 @@ from models import PlayLog, ActivityLog
 
 
 
-
 class SyncJob(threading.Thread):
     """
     Job periodically checking for data at one of the main nodes to be synchronized.
@@ -44,7 +43,6 @@ class SyncJob(threading.Thread):
     sync_interval = None
     sync_batch_size = None
 
-    # Create a scoped local database session to be thread safe
     Session = None
 
 
@@ -62,19 +60,16 @@ class SyncJob(threading.Thread):
         self.sync_batch_size = self.config.get("sync_batch_size")
         self.logger.info("Initialized Sync Job - Synchronizing API Nodes every %s seconds and with a max batch-size of %s." % (self.sync_interval, self.sync_batch_size))
 
-
+        # Create a scoped local database session to be thread safe
         engine = create_engine(self.config.get_database_uri())
-        session_factory = sessionmaker(bind=engine)
+        session_factory = sessionmaker(autoflush=True, autocommit=False, bind=engine)
         self.Session = scoped_session(session_factory)
-
+    
 
     def run(self):
         """
         Starts the Job.
         """
-
-        # with self.app.app_context():
-        
         self.synchronize()
         while not self.exit_event.wait(self.sync_interval):
             self.synchronize()