Include any state groups from the second purge txn

matrix-org · Jul 18, 2022 · f895ace · f895ace
1 parent 110ad87
commit f895ace
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/synapse/storage/databases/main/purge_events.py b/synapse/storage/databases/main/purge_events.py
@@ -332,10 +332,12 @@ async def purge_room(self, room_id: str) -> List[int]:
             isolation_level=IsolationLevel.READ_COMMITTED,
         )
 
-        await self.db_pool.runInteraction(
-            "purge_room",
-            self._purge_room_txn,
-            room_id=room_id,
+        state_groups_to_delete.extend(
+            await self.db_pool.runInteraction(
+                "purge_room",
+                self._purge_room_txn,
+                room_id=room_id,
+            ),
         )
 
         return state_groups_to_delete