summary refs log tree commit diff
path: root/synapse/replication/slave/storage/push_rule.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-05-11 11:19:09 +0100
committerErik Johnston <erik@matrix.org>2020-05-14 17:09:58 +0100
commit342796d6ac442886019391887060b007eaeb3718 (patch)
treef6b563ab3e69bbefe0cd9c0a60348158cc0a26c0 /synapse/replication/slave/storage/push_rule.py
parentMove events ID gens to EventWorkerStore (diff)
downloadsynapse-342796d6ac442886019391887060b007eaeb3718.tar.xz
Move push rules ID gen to push rules worker
Diffstat (limited to 'synapse/replication/slave/storage/push_rule.py')
-rw-r--r--synapse/replication/slave/storage/push_rule.py8
1 files changed, 0 insertions, 8 deletions
diff --git a/synapse/replication/slave/storage/push_rule.py b/synapse/replication/slave/storage/push_rule.py

index 5d5816d7eb..6adb19463a 100644 --- a/synapse/replication/slave/storage/push_rule.py +++ b/synapse/replication/slave/storage/push_rule.py
@@ -15,19 +15,11 @@ # limitations under the License. from synapse.storage.data_stores.main.push_rule import PushRulesWorkerStore -from synapse.storage.database import Database -from ._slaved_id_tracker import SlavedIdTracker from .events import SlavedEventStore class SlavedPushRuleStore(SlavedEventStore, PushRulesWorkerStore): - def __init__(self, database: Database, db_conn, hs): - self._push_rules_stream_id_gen = SlavedIdTracker( - db_conn, "push_rules_stream", "stream_id" - ) - super(SlavedPushRuleStore, self).__init__(database, db_conn, hs) - def get_push_rules_stream_token(self): return ( self._push_rules_stream_id_gen.get_current_token(),