From 2de46d97cf82f93bf31d4b43d1027da148489e9f Mon Sep 17 00:00:00 2001 From: Donald Zou Date: Tue, 2 Dec 2025 13:33:36 +0800 Subject: [PATCH] Update PeerJobs.py --- src/modules/PeerJobs.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/modules/PeerJobs.py b/src/modules/PeerJobs.py index 6795fda1..3b0635b9 100644 --- a/src/modules/PeerJobs.py +++ b/src/modules/PeerJobs.py @@ -191,7 +191,7 @@ class PeerJobs: for j in needToDelete: self.deleteJob(j) - def cleanJob(self): + def cleanJob(self, init = False): failingJobs = self.JobLogger.getFailingJobs() with self.engine.begin() as conn: for job in failingJobs: @@ -204,6 +204,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': + conn.execute('VACUUM;') def __runJob_Compare(self, x: float | datetime, y: float | datetime, operator: str): if operator == "eq":