lifecycle: migrate: ensure template schema exists before migrating (#8952)
This commit is contained in:
committed by
GitHub
parent
285dc8cff0
commit
15c7be1979
@ -64,6 +64,7 @@ def release_lock(cursor: Cursor):
|
|||||||
"""Release database lock"""
|
"""Release database lock"""
|
||||||
if not LOCKED:
|
if not LOCKED:
|
||||||
return
|
return
|
||||||
|
LOGGER.info("releasing database lock")
|
||||||
cursor.execute("SELECT pg_advisory_unlock(%s)", (ADV_LOCK_UID,))
|
cursor.execute("SELECT pg_advisory_unlock(%s)", (ADV_LOCK_UID,))
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
12
lifecycle/system_migrations/template_schema.py
Normal file
12
lifecycle/system_migrations/template_schema.py
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
from lifecycle.migrate import BaseMigration
|
||||||
|
|
||||||
|
|
||||||
|
class Migration(BaseMigration):
|
||||||
|
def needs_migration(self) -> bool:
|
||||||
|
self.cur.execute(
|
||||||
|
"SELECT schema_name FROM information_schema.schemata WHERE schema_name = 'template';"
|
||||||
|
)
|
||||||
|
return not bool(self.cur.rowcount)
|
||||||
|
|
||||||
|
def run(self):
|
||||||
|
self.cur.execute("CREATE SCHEMA IF NOT EXISTS template; COMMIT;")
|
||||||
Reference in New Issue
Block a user