protect the migration with advisory lock

uc-cdis · May 16, 2019 · fa01acd · fa01acd
1 parent 7879d2b
commit fa01acd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/datamodelutils/postgres_admin.py b/datamodelutils/postgres_admin.py
@@ -301,6 +301,7 @@ def _create_tables(driver, create_all, timeout):
     logger.info('Creating tables (timeout: %d)', timeout)
     with driver.session_scope() as session:
         connection = session.connection()
+        connection.execute("SELECT pg_advisory_lock(%s)", hash(create_all) % 2 ** 63)
         logger.info("Setting lock_timeout to %d", timeout)
 
         timeout_str = '{}s'.format(int(timeout+1))