diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-09-01 08:39:04 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-01 08:39:04 -0400 |
| commit | da77520cd1c414c9341da287967feb1bab14cbec (patch) | |
| tree | ada9ea71a1271598a8bc2e9ab7c39a79ca928dac /synapse/storage/databases/main/profile.py | |
| parent | Make MultiWriterIDGenerator work for streams that use negative stream IDs (#8... (diff) | |
| download | synapse-da77520cd1c414c9341da287967feb1bab14cbec.tar.xz | |
Convert additional databases to async/await part 2 (#8200)
Diffstat (limited to 'synapse/storage/databases/main/profile.py')
| -rw-r--r-- | synapse/storage/databases/main/profile.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/synapse/storage/databases/main/profile.py b/synapse/storage/databases/main/profile.py index 301875a672..d2e0685e9e 100644 --- a/synapse/storage/databases/main/profile.py +++ b/synapse/storage/databases/main/profile.py @@ -138,7 +138,9 @@ class ProfileStore(ProfileWorkerStore): desc="delete_remote_profile_cache", ) - def get_remote_profile_cache_entries_that_expire(self, last_checked): + async def get_remote_profile_cache_entries_that_expire( + self, last_checked: int + ) -> Dict[str, str]: """Get all users who haven't been checked since `last_checked` """ @@ -153,7 +155,7 @@ class ProfileStore(ProfileWorkerStore): return self.db_pool.cursor_to_dict(txn) - return self.db_pool.runInteraction( + return await self.db_pool.runInteraction( "get_remote_profile_cache_entries_that_expire", _get_remote_profile_cache_entries_that_expire_txn, ) |