diff options
author | Richard van der Hoff <richard@matrix.org> | 2020-02-03 16:27:05 +0000 |
---|---|---|
committer | Richard van der Hoff <richard@matrix.org> | 2020-02-03 16:29:30 +0000 |
commit | 52642860dabac96467d7a7947976c53eb5dc4c82 (patch) | |
tree | fc27a43949a57b5ca4c52b9e30fa07440f587505 /synapse/handlers/federation.py | |
parent | make FederationHandler._notify_persisted_event async (diff) | |
download | synapse-52642860dabac96467d7a7947976c53eb5dc4c82.tar.xz |
make FederationHandler._clean_room_for_join async
Diffstat (limited to '')
-rw-r--r-- | synapse/handlers/federation.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py index 19cd55b8cf..e252e69888 100644 --- a/synapse/handlers/federation.py +++ b/synapse/handlers/federation.py @@ -2883,17 +2883,17 @@ class FederationHandler(BaseHandler): await self.pusher_pool.on_new_notifications(event_stream_id, max_stream_id) - def _clean_room_for_join(self, room_id): + async def _clean_room_for_join(self, room_id: str) -> None: """Called to clean up any data in DB for a given room, ready for the server to join the room. Args: - room_id (str) + room_id """ if self.config.worker_app: - return self._clean_room_for_join_client(room_id) + await self._clean_room_for_join_client(room_id) else: - return self.store.clean_room_for_join(room_id) + await self.store.clean_room_for_join(room_id) def user_joined_room(self, user, room_id): """Called when a new user has joined the room |