Mirrors/WGDashboard
1
0
Fork 0
mirror of https://github.com/donaldzou/WGDashboard.git synced 2025-12-16 16:36:17 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Update PeerJobs.py

Browse Source
This commit is contained in:
Donald Zou
2025-12-02 13:33:36 +08:00
parent bd6d27f282
commit 2de46d97cf
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/modules/PeerJobs.py
View File

@@ -191,7 +191,7 @@ class PeerJobs:
for j in needToDelete: for j in needToDelete:
self.deleteJob(j) self.deleteJob(j)
def cleanJob(self): def cleanJob(self, init = False):
failingJobs = self.JobLogger.getFailingJobs() failingJobs = self.JobLogger.getFailingJobs()
with self.engine.begin() as conn: with self.engine.begin() as conn:
for job in failingJobs: for job in failingJobs:
@@ -204,6 +204,8 @@ class PeerJobs:
) )
self.JobLogger.deleteLogs(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.") 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): def __runJob_Compare(self, x: float | datetime, y: float | datetime, operator: str):
if operator == "eq": if operator == "eq":