Need to do _background_update_progress_txn in actual transaction
parent
e395eb1108
commit
26db18bc90
|
@ -158,15 +158,17 @@ class SearchStore(BackgroundUpdateStore):
|
|||
)
|
||||
conn.set_session(autocommit=False)
|
||||
|
||||
pg = dict(progress)
|
||||
pg["have_added_indexes"] = True
|
||||
|
||||
self._background_update_progress_txn(
|
||||
conn.cursor(), self.EVENT_SEARCH_ORDER_UPDATE_NAME, progress
|
||||
)
|
||||
|
||||
yield self.runWithConnection(create_index)
|
||||
|
||||
pg = dict(progress)
|
||||
pg["have_added_indexes"] = True
|
||||
|
||||
yield self.runInteraction(
|
||||
self.EVENT_SEARCH_ORDER_UPDATE_NAME,
|
||||
self._background_update_progress_txn,
|
||||
self.EVENT_SEARCH_ORDER_UPDATE_NAME, progress,
|
||||
)
|
||||
|
||||
INSERT_CLUMP_SIZE = 1000
|
||||
|
||||
def reindex_search_txn(txn):
|
||||
|
|
Loading…
Reference in New Issue