summary refs log tree commit diff
path: root/synapse/replication/http/_base.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-10-29 13:00:51 +0000
committerErik Johnston <erik@matrix.org>2019-10-29 13:00:51 +0000
commite577a4b2ad01233ed70b3ab0a9e52aab42e88231 (patch)
treecff16626eb9135baffe1874576d4145b2664b883 /synapse/replication/http/_base.py
parentMerge pull request #6263 from matrix-org/erikj/caches_return_deferreds (diff)
downloadsynapse-e577a4b2ad01233ed70b3ab0a9e52aab42e88231.tar.xz
Port replication http server endpoints to async/await
Diffstat (limited to 'synapse/replication/http/_base.py')
-rw-r--r--synapse/replication/http/_base.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/replication/http/_base.py b/synapse/replication/http/_base.py
index 03560c1f0e..9be37cd998 100644
--- a/synapse/replication/http/_base.py
+++ b/synapse/replication/http/_base.py
@@ -110,14 +110,14 @@ class ReplicationEndpoint(object):
         return {}
 
     @abc.abstractmethod
-    def _handle_request(self, request, **kwargs):
+    async def _handle_request(self, request, **kwargs):
         """Handle incoming request.
 
         This is called with the request object and PATH_ARGS.
 
         Returns:
-            Deferred[dict]: A JSON serialisable dict to be used as response
-            body of request.
+            tuple[int, dict]: HTTP status code and a JSON serialisable dict
+            to be used as response body of request.
         """
         pass