Cache needs StreamWorkerStore

for _membership_stream_cache

synapse/replication/slave/storage/events.py

@@ -48,10 +48,10 @@ logger = logging.getLogger(__name__)
 
 class SlavedEventStore(
     RoomMemberWorkerStore,
-    StreamWorkerStore,
     StateGroupWorkerStore,
     UserErasureWorkerStore,
     BaseSlavedStore,
+    StreamWorkerStore,
 ):
     def __init__(self, database: DatabasePool, db_conn, hs: "HomeServer"):
         super().__init__(database, db_conn, hs)

synapse/storage/databases/main/cache.py

@@ -34,6 +34,7 @@ from synapse.storage.databases.main.event_push_actions import (
     EventPushActionsWorkerStore,
 )
 from synapse.storage.databases.main.relations import RelationsWorkerStore
+from synapse.storage.databases.main.stream import StreamWorkerStore
 from synapse.storage.engines import PostgresEngine
 from synapse.storage.util.id_generators import MultiWriterIdGenerator
 from synapse.util.caches.descriptors import _CachedFunction
@@ -57,6 +58,7 @@ class CacheInvalidationWorkerStore(
     EventFederationWorkerStore,
     RelationsWorkerStore,
     EventPushActionsWorkerStore,
+    StreamWorkerStore,
 ):
     # This class must be mixed in with a child class which provides the following
     # attribute. TODO: can we get static analysis to enforce this?