mirrors/synapse
mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2025-03-14 11:48:44 +00:00
Code Activity

Make port script aware of handle_state_group_seq

Browse source
This commit is contained in:
Erik Johnston 2018-01-11 15:25:47 +00:00
parent a81bcae7db
commit 3c62aac038
1 changed files with 16 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
scripts/synapse_port_db
View file

@ -425,6 +425,20 @@ class Porter(object):
else: else:
return return
def handle_state_group_seq(self):
"""Updates postgres handle_state_group_seq with last state_group ID
"""
def handle_state_group_seq_txn(txn):
txn.execute("""
SELECT setval('state_group_id_seq',
SELECT COALESCE(MAX(id), 0) FROM state_groups
)
""")
return self.postgres_store.runInteraction(
"handle_state_group_seq", handle_state_group_seq_txn,
)
def setup_db(self, db_config, database_engine): def setup_db(self, db_config, database_engine):
db_conn = database_engine.module.connect( db_conn = database_engine.module.connect(
**{ **{
@ -548,6 +562,8 @@ class Porter(object):
consumeErrors=True, consumeErrors=True,
) )
yield self.handle_state_group_seq()
self.progress.done() self.progress.done()
except: except:
global end_error_exec_info global end_error_exec_info