Update PeerJobs.py

This commit is contained in:
Donald Zou
2025-12-02 13:59:48 +08:00
parent 9f609b01de
commit 66ffc12864

View File

@@ -192,8 +192,10 @@ class PeerJobs:
self.deleteJob(j)
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(