diff options
| author | Erik Johnston <erik@matrix.org> | 2018-02-23 10:49:18 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2018-02-23 10:49:18 +0000 |
| commit | 3bd760628bc0b178f6709b9ea3439a44ebcebab2 (patch) | |
| tree | ff140dcd7bc2153d559ccd42aa2d9d2fb237fde5 | |
| parent | Split out get_events and co into a worker store (diff) | |
| download | synapse-3bd760628bc0b178f6709b9ea3439a44ebcebab2.tar.xz | |
_event_persist_queue shouldn't be in worker store
| -rw-r--r-- | synapse/storage/events.py | 8 |
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): |