We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 48ebc1e commit 43ff46fCopy full SHA for 43ff46f
1 file changed
sqlmesh/core/state_sync/engine_adapter.py
@@ -359,13 +359,17 @@ def _get_snapshots_with_same_version(
359
return [Snapshot(**json.loads(row[0])) for row in snapshot_rows]
360
361
def _get_versions(self, lock_for_update: bool = False) -> Versions:
362
+ no_version = Versions(schema_version=0, sqlglot_version="0.0.0")
363
+
364
if not self.engine_adapter.table_exists(self.versions_table):
- return Versions(schema_version=0, sqlglot_version="0.0.0")
365
+ return no_version
366
367
query = exp.select("*").from_(self.versions_table)
368
if lock_for_update:
369
query.lock(copy=False)
370
row = self.engine_adapter.fetchone(query)
371
+ if not row:
372
373
return Versions(schema_version=row[0], sqlglot_version=row[1])
374
375
def _get_environment(
0 commit comments