From 6a539b63785cbe19094d6cc72582fce0fb6e2625 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Mon, 18 May 2020 15:42:59 +0100 Subject: [PATCH] fix missing continue --- synapse/replication/tcp/handler.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py index 335ee2b5c7..03300e5336 100644 --- a/synapse/replication/tcp/handler.py +++ b/synapse/replication/tcp/handler.py @@ -89,13 +89,13 @@ class ReplicationCommandHandler: self._streams_to_replicate.append(stream) continue - # Only add EventStream and BackfillStream as a source on the - # instance in charge of event persistence. - if ( - isinstance(stream, (EventsStream, BackfillStream)) - and hs.config.worker.writers.events == hs.get_instance_name() - ): - self._streams_to_replicate.append(stream) + if isinstance(stream, (EventsStream, BackfillStream)): + # Only add EventStream and BackfillStream as a source on the + # instance in charge of event persistence. + if hs.config.worker.writers.events == hs.get_instance_name(): + self._streams_to_replicate.append(stream) + + continue # Only add any other streams if we're on master. if hs.config.worker_app is not None: