Skip to content
This repository was archived by the owner on Mar 26, 2024. It is now read-only.

Commit e6b5f31

Browse files
committed
Use READ COMITTED isolation level when purging rooms
1 parent 853eb1e commit e6b5f31

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

synapse/storage/databases/main/purge_events.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
from typing import Any, List, Set, Tuple, cast
1717

1818
from synapse.api.errors import SynapseError
19+
from synapse.storage.engines._base import IsolationLevel
1920
from synapse.storage.database import LoggingTransaction
2021
from synapse.storage.databases.main import CacheInvalidationWorkerStore
2122
from synapse.storage.databases.main.state import StateGroupWorkerStore
@@ -320,7 +321,10 @@ async def purge_room(self, room_id: str) -> List[int]:
320321
The list of state groups to delete.
321322
"""
322323
return await self.db_pool.runInteraction(
323-
"purge_room", self._purge_room_txn, room_id
324+
"purge_room",
325+
self._purge_room_txn,
326+
room_id=room_id,
327+
isolation_level=IsolationLevel.READ_COMMITTED,
324328
)
325329

326330
def _purge_room_txn(self, txn: LoggingTransaction, room_id: str) -> List[int]:

0 commit comments

Comments
 (0)