tileradotorg/synapse
1
0
Fork 0
forked from MirrorHub/synapse
Code Pull requests Activity

Fix use of async/await in media code (#7184)

Browse source
This commit is contained in:
Patrick Cloke 2020-03-31 09:33:02 -04:00 committed by GitHub
parent 62a7289133
commit 0a7b0882c1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
changelog.d/7184.misc Normal file
View file

@ -0,0 +1 @@
Convert some of synapse.rest.media to async/await.

4
synapse/storage/data_stores/main/media_repository.py
View file

@ -340,7 +340,7 @@ class MediaRepositoryStore(MediaRepositoryBackgroundUpdateStore):
"get_expired_url_cache", _get_expired_url_cache_txn "get_expired_url_cache", _get_expired_url_cache_txn
) )
def delete_url_cache(self, media_ids): async def delete_url_cache(self, media_ids):
if len(media_ids) == 0: if len(media_ids) == 0:
return return
@ -349,7 +349,7 @@ class MediaRepositoryStore(MediaRepositoryBackgroundUpdateStore):
def _delete_url_cache_txn(txn): def _delete_url_cache_txn(txn):
txn.executemany(sql, [(media_id,) for media_id in media_ids]) txn.executemany(sql, [(media_id,) for media_id in media_ids])
return self.db.runInteraction("delete_url_cache", _delete_url_cache_txn) return await self.db.runInteraction("delete_url_cache", _delete_url_cache_txn)
def get_url_cache_media_before(self, before_ts): def get_url_cache_media_before(self, before_ts):
sql = ( sql = (