From 46861909452923855a53c43536550bb5e46bb482 Mon Sep 17 00:00:00 2001 From: David Robertson Date: Thu, 18 Nov 2021 18:48:08 +0000 Subject: [PATCH] SlavedEventStore doesn't need StreamWorkerStore already has it via SlavedEventStore -> BaseEventStore -> CacheInvalidationWorkerStore -> StreamWorkerStore --- synapse/replication/slave/storage/events.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/synapse/replication/slave/storage/events.py b/synapse/replication/slave/storage/events.py index d8c831a02e..864b071976 100644 --- a/synapse/replication/slave/storage/events.py +++ b/synapse/replication/slave/storage/events.py @@ -17,7 +17,6 @@ from typing import TYPE_CHECKING from synapse.storage.database import DatabasePool from synapse.storage.databases.main.state import StateGroupWorkerStore -from synapse.storage.databases.main.stream import StreamWorkerStore from synapse.storage.databases.main.user_erasure_store import UserErasureWorkerStore from synapse.util.caches.stream_change_cache import StreamChangeCache @@ -42,7 +41,6 @@ class SlavedEventStore( StateGroupWorkerStore, UserErasureWorkerStore, BaseSlavedStore, - StreamWorkerStore, ): def __init__(self, database: DatabasePool, db_conn, hs: "HomeServer"): super().__init__(database, db_conn, hs)