1 files changed, 4 insertions, 8 deletions
diff --git a/synapse/storage/deviceinbox.py b/synapse/storage/deviceinbox.py
index b71ac3ae39..b0ab70bafe 100644
--- a/synapse/storage/deviceinbox.py
+++ b/synapse/storage/deviceinbox.py
@@ -388,14 +388,10 @@ class DeviceInboxStore(BackgroundUpdateStore):
@defer.inlineCallbacks
def _background_drop_index_device_inbox(self, progress, batch_size):
def reindex_txn(conn):
- conn.set_session(autocommit=True)
- try:
- txn = conn.cursor()
- txn.execute(
- "DROP INDEX IF EXISTS device_inbox_stream_id"
- )
- finally:
- conn.set_session(autocommit=False)
+ txn = conn.cursor()
+ txn.execute(
+ "DROP INDEX IF EXISTS device_inbox_stream_id"
+ )
yield self.runWithConnection(reindex_txn)
|