Skip to content

Commit f8e3623

Browse files
authored
Chore: set schema_version default value directly in the pydantic model (#1652)
* Chore: set schema_version default value directly in the pydantic model * Set defaults in Versions
1 parent 7848b81 commit f8e3623

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

sqlmesh/core/state_sync/base.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,9 +35,9 @@
3535
class Versions(PydanticModel):
3636
"""Represents the various versions of dependencies in the state sync."""
3737

38-
schema_version: int
39-
sqlglot_version: str
40-
sqlmesh_version: str
38+
schema_version: int = 0
39+
sqlglot_version: str = "0.0.0"
40+
sqlmesh_version: str = "0.0.0"
4141

4242
@property
4343
def minor_sqlglot_version(self) -> t.Tuple[int, int]:

sqlmesh/core/state_sync/engine_adapter.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -471,7 +471,7 @@ def _get_snapshots_with_same_version(
471471
return [Snapshot(**json.loads(row[0])) for row in snapshot_rows]
472472

473473
def _get_versions(self, lock_for_update: bool = False) -> Versions:
474-
no_version = Versions(schema_version=0, sqlglot_version="0.0.0", sqlmesh_version="0.0.0")
474+
no_version = Versions()
475475

476476
if not self.engine_adapter.table_exists(self.versions_table):
477477
return no_version
@@ -485,9 +485,7 @@ def _get_versions(self, lock_for_update: bool = False) -> Versions:
485485
return no_version
486486

487487
return Versions(
488-
schema_version=row[0],
489-
sqlglot_version=row[1],
490-
sqlmesh_version=seq_get(row, 2) or "0.0.0",
488+
schema_version=row[0], sqlglot_version=row[1], sqlmesh_version=seq_get(row, 2)
491489
)
492490

493491
def _get_environment(

0 commit comments

Comments
 (0)