diff options
| author | Brendan Abolivier <babolivier@matrix.org> | 2020-09-04 10:19:42 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-04 10:19:42 +0100 |
| commit | 9f8abdcc3828e942f09cc62e29dff93dbaa01ec7 (patch) | |
| tree | 5811a075386a883af3e9da43c6123beb812d70c4 /synapse/replication/tcp/handler.py | |
| parent | Add type hints to more handlers (#8244) (diff) | |
| download | synapse-9f8abdcc3828e942f09cc62e29dff93dbaa01ec7.tar.xz | |
Revert "Add experimental support for sharding event persister. (#8170)" (#8242)
* Revert "Add experimental support for sharding event persister. (#8170)" This reverts commit 82c1ee1c22a87b9e6e3179947014b0f11c0a1ac3. * Changelog
Diffstat (limited to 'synapse/replication/tcp/handler.py')
| -rw-r--r-- | synapse/replication/tcp/handler.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py index b323841f73..1c303f3a46 100644 --- a/synapse/replication/tcp/handler.py +++ b/synapse/replication/tcp/handler.py @@ -109,7 +109,7 @@ class ReplicationCommandHandler: if isinstance(stream, (EventsStream, BackfillStream)): # Only add EventStream and BackfillStream as a source on the # instance in charge of event persistence. - if hs.get_instance_name() in hs.config.worker.writers.events: + if hs.config.worker.writers.events == hs.get_instance_name(): self._streams_to_replicate.append(stream) continue |