Ensure that remove_pusher is always async (#7981)

matrix-org · Jul 30, 2020 · 3950ae5 · 3950ae5
1 parent a53e016
commit 3950ae5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/changelog.d/7981.misc b/changelog.d/7981.misc
@@ -0,0 +1 @@
+Convert various parts of the codebase to async/await.
diff --git a/synapse/app/generic_worker.py b/synapse/app/generic_worker.py
@@ -628,7 +628,7 @@ def start_listening(self, listeners: Iterable[ListenerConfig]):
 
         self.get_tcp_replication().start_replication(self)
 
-    def remove_pusher(self, app_id, push_key, user_id):
+    async def remove_pusher(self, app_id, push_key, user_id):
         self.get_tcp_replication().send_remove_pusher(app_id, push_key, user_id)
 
     def build_replication_data_handler(self):
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		Convert various parts of the codebase to async/await.