diff options
| author | Erik Johnston <erik@matrix.org> | 2019-05-29 11:58:32 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2019-05-29 15:11:28 +0100 |
| commit | 7e8e683754cdc606a1440832d9b1eb47f930ddee (patch) | |
| tree | e1e1425a1dba5e6ea6d5252aea47f99cb288e8fb /synapse/storage/events.py | |
| parent | Add DB bg update to cleanup extremities. (diff) | |
| download | synapse-7e8e683754cdc606a1440832d9b1eb47f930ddee.tar.xz | |
Log actual number of entries deleted
Diffstat (limited to 'synapse/storage/events.py')
| -rw-r--r-- | synapse/storage/events.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index a9be143bd5..a9664928ca 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -2476,7 +2476,7 @@ class EventsStore( logger.info("Deleting up to %d forward extremities", len(to_delete)) - self._simple_delete_many_txn( + deleted = self._simple_delete_many_txn( txn=txn, table="event_forward_extremities", column="event_id", @@ -2484,7 +2484,9 @@ class EventsStore( keyvalues={}, ) - if to_delete: + logger.info("Deleted %d forward extremities", deleted) + + if deleted: # We now need to invalidate the caches of these rooms rows = self._simple_select_many_txn( txn, |