Skip table creation on error
This commit is contained in:
parent
1aa741a25b
commit
f275ba36a1
1 changed files with 9 additions and 6 deletions
15
src/Db/Db.py
15
src/Db/Db.py
|
@ -208,12 +208,15 @@ class Db(object):
|
||||||
|
|
||||||
# Check schema tables
|
# Check schema tables
|
||||||
for table_name, table_settings in self.schema.get("tables", {}).items():
|
for table_name, table_settings in self.schema.get("tables", {}).items():
|
||||||
changed = cur.needTable(
|
try:
|
||||||
table_name, table_settings["cols"],
|
changed = cur.needTable(
|
||||||
table_settings.get("indexes", []), version=table_settings.get("schema_changed", 0)
|
table_name, table_settings["cols"],
|
||||||
)
|
table_settings.get("indexes", []), version=table_settings.get("schema_changed", 0)
|
||||||
if changed:
|
)
|
||||||
changed_tables.append(table_name)
|
if changed:
|
||||||
|
changed_tables.append(table_name)
|
||||||
|
except Exception as err:
|
||||||
|
self.log.error("Error creating table %s: %s" % (table_name, Debug.formatException(err)))
|
||||||
|
|
||||||
cur.execute("COMMIT")
|
cur.execute("COMMIT")
|
||||||
self.log.debug("Db check done in %.3fs, changed tables: %s" % (time.time() - s, changed_tables))
|
self.log.debug("Db check done in %.3fs, changed tables: %s" % (time.time() - s, changed_tables))
|
||||||
|
|
Loading…
Reference in a new issue