summary refs log tree commit diff
path: root/synapse/replication/http/streams.py
diff options
context:
space:
mode:
authorPatrick Cloke <clokep@users.noreply.github.com>2020-08-03 07:12:55 -0400
committerGitHub <noreply@github.com>2020-08-03 07:12:55 -0400
commit3b415e23a52dfde90d387821e42cdb3a4eb4e068 (patch)
tree0fc06433e0da098b964c9fbf9bf5e7d1f13e7713 /synapse/replication/http/streams.py
parentConvert ACME code to async/await. (#7989) (diff)
downloadsynapse-3b415e23a52dfde90d387821e42cdb3a4eb4e068.tar.xz
Convert replication code to async/await. (#7987)
Diffstat (limited to '')
-rw-r--r--synapse/replication/http/streams.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/http/streams.py b/synapse/replication/http/streams.py
index bde97eef32..309159e304 100644
--- a/synapse/replication/http/streams.py
+++ b/synapse/replication/http/streams.py
@@ -54,7 +54,7 @@ class ReplicationGetStreamUpdates(ReplicationEndpoint):
         self.streams = hs.get_replication_streams()
 
     @staticmethod
-    def _serialize_payload(stream_name, from_token, upto_token):
+    async def _serialize_payload(stream_name, from_token, upto_token):
         return {"from_token": from_token, "upto_token": upto_token}
 
     async def _handle_request(self, request, stream_name):