summary refs log tree commit diff
path: root/synapse/replication/tcp/streams.py
diff options
context:
space:
mode:
authorErik Johnston <erikj@jki.re>2019-02-15 18:15:16 +0000
committerhera <matrix@hera.matrix.org>2019-02-15 18:15:21 +0000
commitc10c71e70d4ac3b87a7ace9d12e8df5fdb5b9b94 (patch)
treeb30c7778ef9f162a3f653304ea55dea4a3c22666 /synapse/replication/tcp/streams.py
parentMerge pull request #4655 from matrix-org/hawkowl/registration-worker (diff)
downloadsynapse-c10c71e70d4ac3b87a7ace9d12e8df5fdb5b9b94.tar.xz
Emergency changes
Diffstat (limited to 'synapse/replication/tcp/streams.py')
-rw-r--r--synapse/replication/tcp/streams.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/streams.py b/synapse/replication/tcp/streams.py

index 728746bd12..d49973634e 100644 --- a/synapse/replication/tcp/streams.py +++ b/synapse/replication/tcp/streams.py
@@ -265,8 +265,8 @@ class PresenceStream(Stream): store = hs.get_datastore() presence_handler = hs.get_presence_handler() - self.current_token = store.get_current_presence_token - self.update_function = presence_handler.get_all_presence_updates + self.current_token = lambda: 0 + self.update_function = lambda _a, _b: [] super(PresenceStream, self).__init__(hs)