summary refs log tree commit diff
path: root/tests/storage/test_room.py
diff options
context:
space:
mode:
authorPatrick Cloke <clokep@users.noreply.github.com>2020-07-30 07:20:41 -0400
committerGitHub <noreply@github.com>2020-07-30 07:20:41 -0400
commitb3a97d6dac7f9f619b02e213bb8a745d65983d0d (patch)
tree6f5172267973b93553eda36c60821463a00eb90d /tests/storage/test_room.py
parentEnsure that remove_pusher is always async (#7981) (diff)
downloadsynapse-b3a97d6dac7f9f619b02e213bb8a745d65983d0d.tar.xz
Convert some of the data store to async. (#7976)
Diffstat (limited to 'tests/storage/test_room.py')
-rw-r--r--tests/storage/test_room.py24
1 files changed, 14 insertions, 10 deletions
diff --git a/tests/storage/test_room.py b/tests/storage/test_room.py

index a5f250d477..d07b985a8e 100644 --- a/tests/storage/test_room.py +++ b/tests/storage/test_room.py
@@ -37,11 +37,13 @@ class RoomStoreTestCase(unittest.TestCase): self.alias = RoomAlias.from_string("#a-room-name:test") self.u_creator = UserID.from_string("@creator:test") - yield self.store.store_room( - self.room.to_string(), - room_creator_user_id=self.u_creator.to_string(), - is_public=True, - room_version=RoomVersions.V1, + yield defer.ensureDeferred( + self.store.store_room( + self.room.to_string(), + room_creator_user_id=self.u_creator.to_string(), + is_public=True, + room_version=RoomVersions.V1, + ) ) @defer.inlineCallbacks @@ -88,11 +90,13 @@ class RoomEventsStoreTestCase(unittest.TestCase): self.room = RoomID.from_string("!abcde:test") - yield self.store.store_room( - self.room.to_string(), - room_creator_user_id="@creator:text", - is_public=True, - room_version=RoomVersions.V1, + yield defer.ensureDeferred( + self.store.store_room( + self.room.to_string(), + room_creator_user_id="@creator:text", + is_public=True, + room_version=RoomVersions.V1, + ) ) @defer.inlineCallbacks