equal
deleted
inserted
replaced
22 def cleanup_old_transactions(repo=self.repo, lifetime=lifetime): |
22 def cleanup_old_transactions(repo=self.repo, lifetime=lifetime): |
23 mindate = datetime.now() - lifetime |
23 mindate = datetime.now() - lifetime |
24 session = repo.internal_session() |
24 session = repo.internal_session() |
25 try: |
25 try: |
26 session.system_sql( |
26 session.system_sql( |
27 'DELETE FROM transaction WHERE tx_time < %(time)s', |
27 'DELETE FROM transactions WHERE tx_time < %(time)s', |
28 {'time': mindate}) |
28 {'time': mindate}) |
29 # cleanup deleted entities |
29 # cleanup deleted entities |
30 session.system_sql( |
30 session.system_sql( |
31 'DELETE FROM deleted_entities WHERE dtime < %(time)s', |
31 'DELETE FROM deleted_entities WHERE dtime < %(time)s', |
32 {'time': mindate}) |
32 {'time': mindate}) |