diff options
| author | Erik Johnston <erik@matrix.org> | 2019-12-04 15:45:42 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2019-12-04 15:45:42 +0000 |
| commit | a7f20500ff39399634d4623e284fb2f9892776ae (patch) | |
| tree | 8052882125ba484783bea3d5d3d9e76c7afbc0d3 /synapse/replication/slave | |
| parent | Move get_user_count_txn out of base store (diff) | |
| download | synapse-a7f20500ff39399634d4623e284fb2f9892776ae.tar.xz | |
_CURRENT_STATE_CACHE_NAME is public
Diffstat (limited to 'synapse/replication/slave')
| -rw-r--r-- | synapse/replication/slave/storage/_base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/slave/storage/_base.py b/synapse/replication/slave/storage/_base.py index 71e5877aca..6ece1d6745 100644 --- a/synapse/replication/slave/storage/_base.py +++ b/synapse/replication/slave/storage/_base.py @@ -19,7 +19,7 @@ from typing import Dict import six from synapse.storage._base import SQLBaseStore -from synapse.storage.data_stores.main.cache import _CURRENT_STATE_CACHE_NAME +from synapse.storage.data_stores.main.cache import CURRENT_STATE_CACHE_NAME from synapse.storage.engines import PostgresEngine from ._slaved_id_tracker import SlavedIdTracker @@ -63,7 +63,7 @@ class BaseSlavedStore(SQLBaseStore): if stream_name == "caches": self._cache_id_gen.advance(token) for row in rows: - if row.cache_func == _CURRENT_STATE_CACHE_NAME: + if row.cache_func == CURRENT_STATE_CACHE_NAME: room_id = row.keys[0] members_changed = set(row.keys[1:]) self._invalidate_state_caches(room_id, members_changed) |