_event_persist_queue shouldn't be in worker store

This commit is contained in:
Erik Johnston 2018-02-23 10:49:18 +00:00
parent 27b094f382
commit 3bd760628b
1 changed files with 4 additions and 4 deletions

View File

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