OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

fix missing continue

pull/7517/head
Erik Johnston 2020-05-18 15:42:59 +01:00
parent d2012df31c
commit 6a539b6378
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
synapse/replication/tcp/handler.py
View File

@ -89,13 +89,13 @@ class ReplicationCommandHandler:
self._streams_to_replicate.append(stream) self._streams_to_replicate.append(stream)
continue continue
# Only add EventStream and BackfillStream as a source on the if isinstance(stream, (EventsStream, BackfillStream)):
# instance in charge of event persistence. # Only add EventStream and BackfillStream as a source on the
if ( # instance in charge of event persistence.
isinstance(stream, (EventsStream, BackfillStream)) if hs.config.worker.writers.events == hs.get_instance_name():
and hs.config.worker.writers.events == hs.get_instance_name() self._streams_to_replicate.append(stream)
):
self._streams_to_replicate.append(stream) continue
# Only add any other streams if we're on master. # Only add any other streams if we're on master.
if hs.config.worker_app is not None: if hs.config.worker_app is not None: