diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py index 95364778cc..7d6886e0b8 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -22,7 +22,7 @@ import logging import random -from typing import TYPE_CHECKING +from typing import TYPE_CHECKING, Sequence from prometheus_client import Counter @@ -317,7 +317,7 @@ class ReplicationStreamer: def _batch_updates( - updates: list[tuple[Token, StreamRow]], + updates: Sequence[tuple[Token, StreamRow]], ) -> list[tuple[Token | None, StreamRow]]: """Takes a list of updates of form [(token, row)] and sets the token to None for all rows where the next row has the same token. This is used to