diff --git a/src/modules/PeerJobLogger.py b/src/modules/PeerJobLogger.py index 349335dd..46435fbd 100644 --- a/src/modules/PeerJobLogger.py +++ b/src/modules/PeerJobLogger.py @@ -92,4 +92,9 @@ class PeerJobLogger: (self.jobLogTable.c.JobID == JobID if JobID is not None else True), ) ) - ) \ No newline at end of file + ) + + def vacuum(self): + with self.engine.begin() as conn: + if conn.dialect.name == 'sqlite': + conn.execute('VACUUM;') \ No newline at end of file diff --git a/src/modules/PeerJobs.py b/src/modules/PeerJobs.py index 3b0635b9..845ac102 100644 --- a/src/modules/PeerJobs.py +++ b/src/modules/PeerJobs.py @@ -205,6 +205,8 @@ class PeerJobs: self.JobLogger.deleteLogs(JobID=job.get('JobID')) self.JobLogger.log(job.get('JobID'), Message=f"Job is removed due to being stale.") if init and conn.dialect.name == 'sqlite': + print("[WGDashboard] SQLite Vacuuming...") + self.JobLogger.vacuum() conn.execute('VACUUM;') def __runJob_Compare(self, x: float | datetime, y: float | datetime, operator: str):