Remove aggregated rows after aggregation process

beeper · Jan 16, 2023 · 90878d6 · 90878d6
1 parent 47eccd0
commit 90878d6
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/synapse/storage/databases/main/beeper.py b/synapse/storage/databases/main/beeper.py
@@ -217,13 +217,15 @@ def aggregate_txn(txn: LoggingTransaction) -> None:
             txn.execute(sql)
             orders = list(txn)
             if not orders:
+                logger.info("No user counts aggregated")
                 return
 
             max_stream_ordering = max(orders)
             txn.execute(
                 "UPDATE beeper_user_notification_counts_stream_ordering SET stream_ordering = ?",
                 max_stream_ordering,
             )
+            txn.execute("DELETE FROM beeper_user_notification_counts WHERE aggregated")
 
             logger.info(f"Aggregated {len(orders)} notification count rows")