Remove aggregated rows after aggregation process

Author: Fizzadar

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")