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):