Skip to content

Commit 26086d0

Browse files
authored
Fix!: use dummy sqlmesh version if it doesn't exist prior to migrating (#1643)
* Fix: use dummy sqlmesh version if it doesn't exist prior to migrating * Simplify
1 parent 7890c09 commit 26086d0

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

sqlmesh/core/state_sync/engine_adapter.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import pandas as pd
2626
from sqlglot import __version__ as SQLGLOT_VERSION
2727
from sqlglot import exp
28+
from sqlglot.helper import seq_get
2829

2930
from sqlmesh.core import constants as c
3031
from sqlmesh.core.audit import ModelAudit
@@ -478,10 +479,16 @@ def _get_versions(self, lock_for_update: bool = False) -> Versions:
478479
query = exp.select("*").from_(self.versions_table)
479480
if lock_for_update:
480481
query.lock(copy=False)
482+
481483
row = self.engine_adapter.fetchone(query, quote_identifiers=True)
482484
if not row:
483485
return no_version
484-
return Versions(schema_version=row[0], sqlglot_version=row[1], sqlmesh_version=row[2])
486+
487+
return Versions(
488+
schema_version=row[0],
489+
sqlglot_version=row[1],
490+
sqlmesh_version=seq_get(row, 2) or "0.0.0",
491+
)
485492

486493
def _get_environment(
487494
self, environment: str, lock_for_update: bool = False

0 commit comments

Comments
 (0)