catch error when there are concurrent attempts to update the postgres…

… schema
unioslo · Aug 24, 2020 · 2a37c11 · 2a37c11
1 parent c9eb0d4
commit 2a37c11
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/tsdfileapi/db.py b/tsdfileapi/db.py
@@ -268,9 +268,12 @@ def __init__(self, pool, verbose=False, schema=None, requestor=None):
         self.requestor = requestor
 
     def initialise(self):
-        with postgres_session(self.pool) as session:
-            for stmt in self.generator_class.db_init_sql:
-                    session.execute(stmt)
+        try:
+            with postgres_session(self.pool) as session:
+                for stmt in self.generator_class.db_init_sql:
+                        session.execute(stmt)
+        except psycopg2.InternalError as e:
+            pass # throws a tuple concurrently updated when restarting many processes
         return True
 
     def tables_list(self):