diff --git a/synapse/storage/databases/main/sticky_events.py b/synapse/storage/databases/main/sticky_events.py index 7d968fd7c2..ff8fb7a328 100644 --- a/synapse/storage/databases/main/sticky_events.py +++ b/synapse/storage/databases/main/sticky_events.py @@ -14,9 +14,7 @@ import logging from itertools import chain from typing import ( TYPE_CHECKING, - Any, Collection, - Iterable, cast, ) @@ -90,15 +88,6 @@ class StickyEventsWorkerStore(StateGroupWorkerStore, CacheInvalidationWorkerStor writers=hs.config.worker.writers.events, ) - def process_replication_rows( - self, - stream_name: str, - instance_name: str, - token: int, - rows: Iterable[Any], - ) -> None: - super().process_replication_rows(stream_name, instance_name, token, rows) - def process_replication_position( self, stream_name: str, instance_name: str, token: int ) -> None: