From 342796d6ac442886019391887060b007eaeb3718 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Mon, 11 May 2020 11:19:09 +0100 Subject: Move push rules ID gen to push rules worker --- synapse/replication/slave/storage/push_rule.py | 8 -------- 1 file changed, 8 deletions(-) (limited to 'synapse/replication/slave/storage/push_rule.py') 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(), -- cgit 1.5.1