forked from MirrorHub/synapse
Move and rename variable
This commit is contained in:
parent
5f27ed75ad
commit
c945af8799
1 changed files with 3 additions and 3 deletions
|
@ -1825,8 +1825,10 @@ class EventsStore(EventsWorkerStore):
|
||||||
)
|
)
|
||||||
|
|
||||||
def _purge_history_txn(
|
def _purge_history_txn(
|
||||||
self, txn, room_id, token, delete_local_events,
|
self, txn, room_id, token_str, delete_local_events,
|
||||||
):
|
):
|
||||||
|
token = RoomStreamToken.parse(token_str)
|
||||||
|
|
||||||
# Tables that should be pruned:
|
# Tables that should be pruned:
|
||||||
# event_auth
|
# event_auth
|
||||||
# event_backward_extremities
|
# event_backward_extremities
|
||||||
|
@ -1855,8 +1857,6 @@ class EventsStore(EventsWorkerStore):
|
||||||
# furthermore, we might already have the table from a previous (failed)
|
# furthermore, we might already have the table from a previous (failed)
|
||||||
# purge attempt, so let's drop the table first.
|
# purge attempt, so let's drop the table first.
|
||||||
|
|
||||||
token = RoomStreamToken.parse(token)
|
|
||||||
|
|
||||||
txn.execute("DROP TABLE IF EXISTS events_to_purge")
|
txn.execute("DROP TABLE IF EXISTS events_to_purge")
|
||||||
|
|
||||||
txn.execute(
|
txn.execute(
|
||||||
|
|
Loading…
Reference in a new issue