Edit on GitHub

Add dev version to the intervals table.

 1"""Add dev version to the intervals table."""
 2
 3from sqlglot import exp
 4
 5
 6def migrate_schemas(engine_adapter, schema, **kwargs):  # type: ignore
 7    intervals_table = "_intervals"
 8    if schema:
 9        intervals_table = f"{schema}.{intervals_table}"
10
11    alter_table_exp = exp.Alter(
12        this=exp.to_table(intervals_table),
13        kind="TABLE",
14        actions=[
15            exp.ColumnDef(
16                this=exp.to_column("last_altered_ts"),
17                kind=exp.DataType.build("BIGINT", dialect=engine_adapter.dialect),
18            )
19        ],
20    )
21    engine_adapter.execute(alter_table_exp)
22
23
24def migrate_rows(engine_adapter, schema, **kwargs):  # type: ignore
25    pass
def migrate_schemas(engine_adapter, schema, **kwargs): 
 7def migrate_schemas(engine_adapter, schema, **kwargs):  # type: ignore
 8    intervals_table = "_intervals"
 9    if schema:
10        intervals_table = f"{schema}.{intervals_table}"
11
12    alter_table_exp = exp.Alter(
13        this=exp.to_table(intervals_table),
14        kind="TABLE",
15        actions=[
16            exp.ColumnDef(
17                this=exp.to_column("last_altered_ts"),
18                kind=exp.DataType.build("BIGINT", dialect=engine_adapter.dialect),
19            )
20        ],
21    )
22    engine_adapter.execute(alter_table_exp)
def migrate_rows(engine_adapter, schema, **kwargs): 
25def migrate_rows(engine_adapter, schema, **kwargs):  # type: ignore
26    pass