diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-08-12 09:28:48 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-12 09:28:48 -0400 |
| commit | a3a59bab7bb3b69dcfc5620e6f3ac51af3f0f965 (patch) | |
| tree | eeec255478ccc92af2111519681831bca5aad289 /synapse/storage/databases/main/transactions.py | |
| parent | Fix typing for notifier (#8064) (diff) | |
| download | synapse-a3a59bab7bb3b69dcfc5620e6f3ac51af3f0f965.tar.xz | |
Convert appservice, group server, profile and more databases to async (#8066)
Diffstat (limited to 'synapse/storage/databases/main/transactions.py')
| -rw-r--r-- | synapse/storage/databases/main/transactions.py | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/synapse/storage/databases/main/transactions.py b/synapse/storage/databases/main/transactions.py index 8804c0e4ac..52668dbdf9 100644 --- a/synapse/storage/databases/main/transactions.py +++ b/synapse/storage/databases/main/transactions.py @@ -18,8 +18,6 @@ from collections import namedtuple from canonicaljson import encode_canonical_json -from twisted.internet import defer - from synapse.metrics.background_process_metrics import run_as_background_process from synapse.storage._base import SQLBaseStore, db_to_json from synapse.storage.database import DatabasePool @@ -126,8 +124,7 @@ class TransactionStore(SQLBaseStore): desc="set_received_txn_response", ) - @defer.inlineCallbacks - def get_destination_retry_timings(self, destination): + async def get_destination_retry_timings(self, destination): """Gets the current retry timings (if any) for a given destination. Args: @@ -142,7 +139,7 @@ class TransactionStore(SQLBaseStore): if result is not SENTINEL: return result - result = yield self.db_pool.runInteraction( + result = await self.db_pool.runInteraction( "get_destination_retry_timings", self._get_destination_retry_timings, destination, |