diff options
author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2020-01-07 14:18:43 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-01-07 14:18:43 +0000 |
commit | 85db7f73be15cc088f5e378980021e335001ce87 (patch) | |
tree | f6efe9db7d54e76af87b14cac70461b6a3a3d09f /synapse/storage/background_updates.py | |
parent | Async/await for background updates (#6647) (diff) | |
download | synapse-85db7f73be15cc088f5e378980021e335001ce87.tar.xz |
Add a background update to clear tombstoned rooms from the directory (#6648)
* Add a background update to clear tombstoned rooms from the directory * use the ABC metaclass
Diffstat (limited to 'synapse/storage/background_updates.py')
-rw-r--r-- | synapse/storage/background_updates.py | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/synapse/storage/background_updates.py b/synapse/storage/background_updates.py index b4825acc7b..bd547f35cf 100644 --- a/synapse/storage/background_updates.py +++ b/synapse/storage/background_updates.py @@ -436,6 +436,21 @@ class BackgroundUpdater(object): "background_updates", keyvalues={"update_name": update_name} ) + def _background_update_progress(self, update_name: str, progress: dict): + """Update the progress of a background update + + Args: + update_name: The name of the background update task + progress: The progress of the update. + """ + + return self.db.runInteraction( + "background_update_progress", + self._background_update_progress_txn, + update_name, + progress, + ) + def _background_update_progress_txn(self, txn, update_name, progress): """Update the progress of a background update |