From fa59de4a090787e5129fc135466cf92bf1372479 Mon Sep 17 00:00:00 2001 From: Donald Zou Date: Tue, 2 Dec 2025 14:08:55 +0800 Subject: [PATCH] Update PeerJobs.py --- src/modules/PeerJobs.py | 26 ++++++++++++++------------ 1 file changed, 14 insertions(+), 12 deletions(-) diff --git a/src/modules/PeerJobs.py b/src/modules/PeerJobs.py index 10f66e4a..f9ac4103 100644 --- a/src/modules/PeerJobs.py +++ b/src/modules/PeerJobs.py @@ -194,18 +194,20 @@ class PeerJobs: def cleanJob(self, init = False): failingJobs = self.JobLogger.getFailingJobs() - with self.engine.begin() as conn: - print(conn.dialect.name) - for job in failingJobs: - conn.execute( - self.peerJobTable.update().values( - { - "ExpireDate": datetime.now() - } - ).where(self.peerJobTable.columns.JobID == job.get('JobID')) - ) - self.JobLogger.deleteLogs(JobID=job.get('JobID')) - self.JobLogger.log(job.get('JobID'), Message=f"Job is removed due to being stale.") + # with self.engine.begin() as conn: + # print(conn.dialect.name) + # for job in failingJobs: + # conn.execute( + # self.peerJobTable.update().values( + # { + # "ExpireDate": datetime.now() + # } + # ).where(self.peerJobTable.columns.JobID == job.get('JobID')) + # ) + # self.JobLogger.deleteLogs(JobID=job.get('JobID')) + # self.JobLogger.log(job.get('JobID'), Message=f"Job is removed due to being stale.") + + with self.engine.connect() as conn: if init and conn.dialect.name == 'sqlite': print("[WGDashboard] SQLite Vacuuming...") self.JobLogger.vacuum()