diff options
| -rw-r--r-- | synapse/storage/registration.py | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/synapse/storage/registration.py b/synapse/storage/registration.py index ff0a2a9e8b..530bbe6b45 100644 --- a/synapse/storage/registration.py +++ b/synapse/storage/registration.py @@ -112,10 +112,15 @@ class RegistrationStore(SQLBaseStore): @defer.inlineCallbacks def user_delete_access_tokens_apart_from(self, user_id, token_id): - yield self._execute( - "delete_access_tokens_apart_from", None, + yield self.runInteraction( + "user_delete_access_tokens_apart_from", + self._user_delete_access_tokens_apart_from, user_id, token_id + ) + + def _user_delete_access_tokens_apart_from(self, txn, user_id, token_id): + txn.execute( "DELETE FROM access_tokens WHERE user_id = ? AND id != ?", - user_id, token_id + (user_id, token_id) ) @defer.inlineCallbacks |