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

Update PeerJobs.py

Browse Source
This commit is contained in:
Donald Zou
2025-12-02 14:08:55 +08:00
parent 4756556c82
commit fa59de4a09
1 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/modules/PeerJobs.py
View File

@@ -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()