diff --git a/src/modules/PeerJobs.py b/src/modules/PeerJobs.py index 6577221f..d3033f8d 100644 --- a/src/modules/PeerJobs.py +++ b/src/modules/PeerJobs.py @@ -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(