MirrorHub/synapse
0
0
Fork 1
mirror of https://mau.dev/maunium/synapse.git synced 2024-11-04 13:49:15 +01:00
Code Issues Projects Releases Wiki Activity

Fix port script for changes merged from develop

Browse source
This commit is contained in:
David Baker 2016-04-07 16:43:54 +01:00
parent 9c99ab4572
commit 2d5c693fd3
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
synapse/storage/schema/delta/31/pushers.py
View file

@ -27,7 +27,7 @@ def token_to_stream_ordering(token):
return int(token[1:].split('_')[0]) return int(token[1:].split('_')[0])
def run_upgrade(cur, database_engine, *args, **kwargs): def run_create(cur, database_engine, *args, **kwargs):
logger.info("Porting pushers table, delta 31...") logger.info("Porting pushers table, delta 31...")
cur.execute(""" cur.execute("""
CREATE TABLE IF NOT EXISTS pushers2 ( CREATE TABLE IF NOT EXISTS pushers2 (
@ -73,3 +73,6 @@ def run_upgrade(cur, database_engine, *args, **kwargs):
cur.execute("DROP TABLE pushers") cur.execute("DROP TABLE pushers")
cur.execute("ALTER TABLE pushers2 RENAME TO pushers") cur.execute("ALTER TABLE pushers2 RENAME TO pushers")
logger.info("Moved %d pushers to new table", count) logger.info("Moved %d pushers to new table", count)
def run_upgrade(cur, database_engine, *args, **kwargs):
pass