[fix] no such table during engine init (#6185)

This commit is contained in:
Brock Vojkovic
2026-06-07 12:04:12 +08:00
committed by GitHub
parent e260a732c8
commit 9d49a9f344
+14 -6
View File
@@ -327,7 +327,6 @@ class SQLiteAppl(abc.ABC):
if self._init_done:
return False
self._init_done = True
logger.debug("init DB: %s", self.db_url)
self.properties.init(conn)
@@ -342,6 +341,7 @@ class SQLiteAppl(abc.ABC):
raise sqlite3.DatabaseError("Expected DB schema v%s, DB schema is v%s" % (self.DB_SCHEMA, ver))
logger.debug("DB_SCHEMA = %s", ver)
self._init_done = True
return True
def create_schema(self, conn: sqlite3.Connection):
@@ -369,6 +369,9 @@ class SQLiteProperties(SQLiteAppl):
"""
_locks: dict[str, threading.Lock] = {}
_locks_lock = threading.Lock()
SQLITE_JOURNAL_MODE: str = "WAL"
DDL_PROPERTIES: str = """\
@@ -406,11 +409,16 @@ CREATE TABLE IF NOT EXISTS properties (
if self._init_done:
return False
self._init_done = True
logger.debug("init properties of DB: %s", self.db_url)
res = conn.execute(self.SQL_TABLE_EXISTS)
if res.fetchone() is None: # DB schema needs to be be created
self.create_schema(conn)
with self._locks_lock:
db_lock = self._locks.setdefault(self.db_url, threading.Lock())
with db_lock:
if self._init_done:
return False
logger.debug("init properties of DB: %s", self.db_url)
res = conn.execute(self.SQL_TABLE_EXISTS)
if res.fetchone() is None: # DB schema needs to be be created
self.create_schema(conn)
self._init_done = True
return True
def __call__(self, name: str, default: t.Any = None) -> t.Any: