Tweak integrity error recovery to work as intended

This commit is contained in:
Benjamin Saunders 2016-08-04 20:38:08 -07:00
parent a5d7968b3e
commit a2b7102eea
2 changed files with 4 additions and 1 deletions

View file

@ -580,6 +580,7 @@ class EventsStore(SQLBaseStore):
for table in (
"events",
"event_auth",
"event_json",
"event_content_hashes",
"event_destinations",
@ -593,6 +594,8 @@ class EventsStore(SQLBaseStore):
"event_to_state_groups",
"rejections",
"redactions",
"room_memberships",
"state_events"
):
txn.executemany(
"DELETE FROM %s WHERE event_id = ?" % (table,),