diff options
| author | Erik Johnston <erik@matrix.org> | 2019-12-20 10:48:24 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-12-20 10:48:24 +0000 |
| commit | 75d8f26ac85efd3816d454927f40b6e4c3032df1 (patch) | |
| tree | 1e88634b8ac0b8418239015d11e97c9e557477f8 /synapse/storage/purge_events.py | |
| parent | Change EventContext to use the Storage class (#6564) (diff) | |
| download | synapse-75d8f26ac85efd3816d454927f40b6e4c3032df1.tar.xz | |
Split state groups into a separate data store (#6296)
Diffstat (limited to 'synapse/storage/purge_events.py')
| -rw-r--r-- | synapse/storage/purge_events.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/storage/purge_events.py b/synapse/storage/purge_events.py index a368182034..d6a7bd7834 100644 --- a/synapse/storage/purge_events.py +++ b/synapse/storage/purge_events.py @@ -58,7 +58,7 @@ class PurgeEventsStorage(object): sg_to_delete = yield self._find_unreferenced_groups(state_groups) - yield self.stores.main.purge_unreferenced_state_groups(room_id, sg_to_delete) + yield self.stores.state.purge_unreferenced_state_groups(room_id, sg_to_delete) @defer.inlineCallbacks def _find_unreferenced_groups(self, state_groups): @@ -102,7 +102,7 @@ class PurgeEventsStorage(object): # groups that are referenced. current_search -= referenced - edges = yield self.stores.main.get_previous_state_groups(current_search) + edges = yield self.stores.state.get_previous_state_groups(current_search) prevs = set(edges.values()) # We don't bother re-handling groups we've already seen |