Edit on GitHub

Add new 'sqlmesh_version' column to the version state table.

 1"""Add new 'sqlmesh_version' column to the version state table."""
 2
 3from sqlglot import exp
 4
 5
 6def migrate(state_sync, **kwargs):  # type: ignore
 7    engine_adapter = state_sync.engine_adapter
 8    versions_table = "_versions"
 9    if state_sync.schema:
10        versions_table = f"{state_sync.schema}.{versions_table}"
11
12    alter_table_exp = exp.AlterTable(
13        this=exp.to_table(versions_table),
14        actions=[
15            exp.ColumnDef(
16                this=exp.to_column("sqlmesh_version"),
17                kind=exp.DataType.build("text"),
18            )
19        ],
20    )
21
22    engine_adapter.execute(alter_table_exp)
def migrate(state_sync, **kwargs): 
 7def migrate(state_sync, **kwargs):  # type: ignore
 8    engine_adapter = state_sync.engine_adapter
 9    versions_table = "_versions"
10    if state_sync.schema:
11        versions_table = f"{state_sync.schema}.{versions_table}"
12
13    alter_table_exp = exp.AlterTable(
14        this=exp.to_table(versions_table),
15        actions=[
16            exp.ColumnDef(
17                this=exp.to_column("sqlmesh_version"),
18                kind=exp.DataType.build("text"),
19            )
20        ],
21    )
22
23    engine_adapter.execute(alter_table_exp)