diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-08-03 07:12:55 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-03 07:12:55 -0400 |
| commit | 3b415e23a52dfde90d387821e42cdb3a4eb4e068 (patch) | |
| tree | 0fc06433e0da098b964c9fbf9bf5e7d1f13e7713 /synapse/replication/http/streams.py | |
| parent | Convert ACME code to async/await. (#7989) (diff) | |
| download | synapse-3b415e23a52dfde90d387821e42cdb3a4eb4e068.tar.xz | |
Convert replication code to async/await. (#7987)
Diffstat (limited to '')
| -rw-r--r-- | synapse/replication/http/streams.py | 2 |
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): |