summary refs log tree commit diff
path: root/synapse/storage/events.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2018-02-23 10:49:18 +0000
committerErik Johnston <erik@matrix.org>2018-02-23 10:49:18 +0000
commit3bd760628bc0b178f6709b9ea3439a44ebcebab2 (patch)
treeff140dcd7bc2153d559ccd42aa2d9d2fb237fde5 /synapse/storage/events.py
parentSplit out get_events and co into a worker store (diff)
downloadsynapse-3bd760628bc0b178f6709b9ea3439a44ebcebab2.tar.xz
_event_persist_queue shouldn't be in worker store
Diffstat (limited to '')
-rw-r--r--synapse/storage/events.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py
index 681a33314d..32da81c47b 100644
--- a/synapse/storage/events.py
+++ b/synapse/storage/events.py
@@ -200,10 +200,6 @@ def _retry_on_integrity_error(func):
 
 
 class EventsWorkerStore(SQLBaseStore):
-    def __init__(self, db_conn, hs):
-        super(EventsWorkerStore, self).__init__(db_conn, hs)
-
-        self._event_persist_queue = _EventPeristenceQueue()
 
     @defer.inlineCallbacks
     def get_event(self, event_id, check_redacted=True,
@@ -583,6 +579,10 @@ class EventsStore(EventsWorkerStore):
             psql_only=True,
         )
 
+
+
+        self._event_persist_queue = _EventPeristenceQueue()
+
         self._state_resolution_handler = hs.get_state_resolution_handler()
 
     def persist_events(self, events_and_contexts, backfilled=False):