diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-08-14 07:24:26 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-14 07:24:26 -0400 |
| commit | 894dae74fe8e79911c3c001c8b84620ef3985bf6 (patch) | |
| tree | 3ba58a280c6db5eb89e116ef528061592ce8f987 /synapse/storage/background_updates.py | |
| parent | Remove a space at the start of a changelog entry. (diff) | |
| download | synapse-894dae74fe8e79911c3c001c8b84620ef3985bf6.tar.xz | |
Convert misc database code to async (#8087)
Diffstat (limited to 'synapse/storage/background_updates.py')
| -rw-r--r-- | synapse/storage/background_updates.py | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/synapse/storage/background_updates.py b/synapse/storage/background_updates.py index f43463df53..90a1f9e8b1 100644 --- a/synapse/storage/background_updates.py +++ b/synapse/storage/background_updates.py @@ -18,8 +18,6 @@ from typing import Optional from canonicaljson import json -from twisted.internet import defer - from synapse.metrics.background_process_metrics import run_as_background_process from . import engines @@ -308,9 +306,8 @@ class BackgroundUpdater(object): update_name (str): Name of update """ - @defer.inlineCallbacks - def noop_update(progress, batch_size): - yield self._end_background_update(update_name) + async def noop_update(progress, batch_size): + await self._end_background_update(update_name) return 1 self.register_background_update_handler(update_name, noop_update) @@ -409,12 +406,11 @@ class BackgroundUpdater(object): else: runner = create_index_sqlite - @defer.inlineCallbacks - def updater(progress, batch_size): + async def updater(progress, batch_size): if runner is not None: logger.info("Adding index %s to %s", index_name, table) - yield self.db_pool.runWithConnection(runner) - yield self._end_background_update(update_name) + await self.db_pool.runWithConnection(runner) + await self._end_background_update(update_name) return 1 self.register_background_update_handler(update_name, updater) |