summary refs log tree commit diff
path: root/synapse/storage/transactions.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2016-08-31 11:12:02 +0100
committerErik Johnston <erik@matrix.org>2016-08-31 11:12:02 +0100
commitef0cc648cfe74a13268c0df8fc679e0c4f29ecbe (patch)
tree802d9ab422f6956ef8217a20dc87b792f3589294 /synapse/storage/transactions.py
parentMerge pull request #1056 from matrix-org/kegan/appservice-url-is-optional (diff)
downloadsynapse-ef0cc648cfe74a13268c0df8fc679e0c4f29ecbe.tar.xz
Clean up old sent transactions
Diffstat (limited to 'synapse/storage/transactions.py')
-rw-r--r--synapse/storage/transactions.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/storage/transactions.py b/synapse/storage/transactions.py
index 58d4de4f1d..1c588bd46b 100644
--- a/synapse/storage/transactions.py
+++ b/synapse/storage/transactions.py
@@ -387,8 +387,10 @@ class TransactionStore(SQLBaseStore):
     def _cleanup_transactions(self):
         now = self._clock.time_msec()
         month_ago = now - 30 * 24 * 60 * 60 * 1000
+        six_hours_ago = now - 6 * 60 * 60 * 1000
 
         def _cleanup_transactions_txn(txn):
             txn.execute("DELETE FROM received_transactions WHERE ts < ?", (month_ago,))
+            txn.execute("DELETE FROM sent_transactions WHERE ts < ?", (six_hours_ago,))
 
         return self.runInteraction("_persist_in_mem_txns", _cleanup_transactions_txn)