summary refs log tree commit diff
path: root/synapse/replication/slave
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-12-04 15:45:42 +0000
committerErik Johnston <erik@matrix.org>2019-12-04 15:45:42 +0000
commita7f20500ff39399634d4623e284fb2f9892776ae (patch)
tree8052882125ba484783bea3d5d3d9e76c7afbc0d3 /synapse/replication/slave
parentMove get_user_count_txn out of base store (diff)
downloadsynapse-a7f20500ff39399634d4623e284fb2f9892776ae.tar.xz
_CURRENT_STATE_CACHE_NAME is public
Diffstat (limited to 'synapse/replication/slave')
-rw-r--r--synapse/replication/slave/storage/_base.py4
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)