summary refs log tree commit diff
path: root/synapse/storage/data_stores
diff options
context:
space:
mode:
authorPatrick Cloke <clokep@users.noreply.github.com>2020-04-07 16:56:34 -0400
committerGitHub <noreply@github.com>2020-04-07 21:56:34 +0100
commit1722b8a527b8caa0f76706bf4acaf240e167daf4 (patch)
tree31de34cf0519928988dfcae63fdb7c0d5574ffc1 /synapse/storage/data_stores
parentAdd typing information to federation_server. (#7219) (diff)
downloadsynapse-1722b8a527b8caa0f76706bf4acaf240e167daf4.tar.xz
Convert delete_url_cache_media to async/await. (#7241)
Diffstat (limited to 'synapse/storage/data_stores')
-rw-r--r--synapse/storage/data_stores/main/media_repository.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/storage/data_stores/main/media_repository.py b/synapse/storage/data_stores/main/media_repository.py
index cf195f8aa6..8aecd414c2 100644
--- a/synapse/storage/data_stores/main/media_repository.py
+++ b/synapse/storage/data_stores/main/media_repository.py
@@ -367,7 +367,7 @@ class MediaRepositoryStore(MediaRepositoryBackgroundUpdateStore):
             "get_url_cache_media_before", _get_url_cache_media_before_txn
         )
 
-    def delete_url_cache_media(self, media_ids):
+    async def delete_url_cache_media(self, media_ids):
         if len(media_ids) == 0:
             return
 
@@ -380,6 +380,6 @@ class MediaRepositoryStore(MediaRepositoryBackgroundUpdateStore):
 
             txn.executemany(sql, [(media_id,) for media_id in media_ids])
 
-        return self.db.runInteraction(
+        return await self.db.runInteraction(
             "delete_url_cache_media", _delete_url_cache_media_txn
         )