Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-21 07:14:17 -05:00
Code Issues Packages Projects Releases Wiki Activity

Don't disable autocommit

Browse Source
This commit is contained in:
Erik Johnston 2017-01-10 15:11:27 +00:00
parent caddadfc5a
commit 5a32e9273e
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
synapse/storage/deviceinbox.py
View File

@ -388,14 +388,10 @@ class DeviceInboxStore(BackgroundUpdateStore):
@defer.inlineCallbacks @defer.inlineCallbacks
def _background_drop_index_device_inbox(self, progress, batch_size): def _background_drop_index_device_inbox(self, progress, batch_size):
def reindex_txn(conn): def reindex_txn(conn):
conn.set_session(autocommit=True) txn = conn.cursor()
try: txn.execute(
txn = conn.cursor() "DROP INDEX IF EXISTS device_inbox_stream_id"
txn.execute( )
"DROP INDEX IF EXISTS device_inbox_stream_id"
)
finally:
conn.set_session(autocommit=False)
yield self.runWithConnection(reindex_txn) yield self.runWithConnection(reindex_txn)