mirror of
https://github.com/element-hq/synapse
synced 2024-08-20 14:20:23 +00:00
Fix a couple of errors when deleting pushers
This commit is contained in:
parent
6df1c79c22
commit
ee32d622ce
1 changed files with 2 additions and 2 deletions
|
@ -136,7 +136,7 @@ class PusherStore(SQLBaseStore):
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def delete_pusher_by_app_id_pushkey_user_id(self, app_id, pushkey, user_id):
|
def delete_pusher_by_app_id_pushkey_user_id(self, app_id, pushkey, user_id):
|
||||||
def delete_pusher_txn(txn, stream_id):
|
def delete_pusher_txn(txn, stream_id):
|
||||||
self._simple_delete_one(
|
self._simple_delete_one_txn(
|
||||||
txn,
|
txn,
|
||||||
"pushers",
|
"pushers",
|
||||||
{"app_id": app_id, "pushkey": pushkey, "user_name": user_id}
|
{"app_id": app_id, "pushkey": pushkey, "user_name": user_id}
|
||||||
|
@ -145,7 +145,7 @@ class PusherStore(SQLBaseStore):
|
||||||
txn,
|
txn,
|
||||||
"deleted_pushers",
|
"deleted_pushers",
|
||||||
{"app_id": app_id, "pushkey": pushkey, "user_id": user_id},
|
{"app_id": app_id, "pushkey": pushkey, "user_id": user_id},
|
||||||
{"stream_id", stream_id},
|
{"stream_id": stream_id},
|
||||||
)
|
)
|
||||||
with self._pushers_id_gen.get_next() as stream_id:
|
with self._pushers_id_gen.get_next() as stream_id:
|
||||||
yield self.runInteraction(
|
yield self.runInteraction(
|
||||||
|
|
Loading…
Reference in a new issue