diff options
Diffstat (limited to 'synapse/replication/http/streams.py')
| -rw-r--r-- | synapse/replication/http/streams.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/replication/http/streams.py b/synapse/replication/http/streams.py index 9c1fc9fb25..11a0270699 100644 --- a/synapse/replication/http/streams.py +++ b/synapse/replication/http/streams.py @@ -51,6 +51,8 @@ class ReplicationGetStreamUpdates(ReplicationEndpoint): # them ourselves we end up in an import loop). self.streams = hs.get_replication_streamer().get_streams() + self.instance_name = hs.config.worker_name or "master" + @staticmethod def _serialize_payload(stream_name, from_token, upto_token, limit): return {"from_token": from_token, "upto_token": upto_token, "limit": limit} |