summary refs log tree commit diff
path: root/synapse/replication/tcp
diff options
context:
space:
mode:
authorDavid Robertson <davidr@element.io>2023-03-07 12:17:08 +0000
committerDavid Robertson <davidr@element.io>2023-03-07 12:17:08 +0000
commita95e906227aeb62224790bb7796313ebcd6db446 (patch)
tree916661272a63b1e86d05ab1a24a2b0a5ce223e25 /synapse/replication/tcp
parentMerge remote-tracking branch 'origin/release-v1.78' into matrix-org-hotfixes (diff)
parent1.79.0rc1 (diff)
downloadsynapse-a95e906227aeb62224790bb7796313ebcd6db446.tar.xz
Merge remote-tracking branch 'origin/release-v1.79' into matrix-org-hotfixes
Diffstat (limited to 'synapse/replication/tcp')
-rw-r--r--synapse/replication/tcp/redis.py1
-rw-r--r--synapse/replication/tcp/streams/events.py1
2 files changed, 0 insertions, 2 deletions
diff --git a/synapse/replication/tcp/redis.py b/synapse/replication/tcp/redis.py

index fd1c0ec6af..dfc061eb5e 100644 --- a/synapse/replication/tcp/redis.py +++ b/synapse/replication/tcp/redis.py
@@ -328,7 +328,6 @@ class RedisDirectTcpReplicationClientFactory(SynapseRedisFactory): outbound_redis_connection: txredisapi.ConnectionHandler, channel_names: List[str], ): - super().__init__( hs, uuid="subscriber", diff --git a/synapse/replication/tcp/streams/events.py b/synapse/replication/tcp/streams/events.py
index 14b6705862..ad9b760713 100644 --- a/synapse/replication/tcp/streams/events.py +++ b/synapse/replication/tcp/streams/events.py
@@ -139,7 +139,6 @@ class EventsStream(Stream): current_token: Token, target_row_count: int, ) -> StreamUpdateResult: - # the events stream merges together three separate sources: # * new events # * current_state changes