this repo has no description
popular/rapidfire: track deletions
+4
-2
+2
-1
feeds/popular.py
+2
-1
feeds/popular.py
···
50
50
temperature * exp( -1 * ( ( unixepoch('now') - create_ts ) / 1800.0 ) ) < 1.0
51
51
and create_ts < unixepoch('now', '-15 minutes')
52
52
""")
53
+
self.logger.debug('deleted {} old posts'.format(self.db_cnx.changes()))
53
54
54
55
def commit_changes(self):
56
+
self.delete_old_posts()
55
57
self.logger.debug('committing changes')
56
-
self.delete_old_posts()
57
58
self.transaction_commit(self.db_cnx)
58
59
self.wal_checkpoint(self.db_cnx, 'RESTART')
59
60
+2
-1
feeds/rapidfire.py
+2
-1
feeds/rapidfire.py
···
59
59
self.db_cnx.execute(
60
60
"delete from posts where create_ts < unixepoch('now', '-15 minutes')"
61
61
)
62
+
self.logger.debug('deleted {} old posts'.format(self.db_cnx.changes()))
62
63
63
64
def commit_changes(self):
65
+
self.delete_old_posts()
64
66
self.logger.debug('committing changes')
65
-
self.delete_old_posts()
66
67
self.transaction_commit(self.db_cnx)
67
68
self.wal_checkpoint(self.db_cnx, 'RESTART')
68
69