Edit on GitHub

Create a dedicated table to store the content of seeds.

 1"""Create a dedicated table to store the content of seeds."""
 2
 3from sqlglot import exp
 4
 5from sqlmesh.utils.migration import index_text_type
 6
 7
 8def migrate(state_sync, **kwargs):  # type: ignore
 9    engine_adapter = state_sync.engine_adapter
10    seeds_table = "_seeds"
11    if state_sync.schema:
12        seeds_table = f"{state_sync.schema}.{seeds_table}"
13
14    index_type = index_text_type(engine_adapter.dialect)
15
16    engine_adapter.create_state_table(
17        seeds_table,
18        {
19            "name": exp.DataType.build(index_type),
20            "identifier": exp.DataType.build(index_type),
21            "content": exp.DataType.build("text"),
22        },
23        primary_key=("name", "identifier"),
24    )
def migrate(state_sync, **kwargs): 
 9def migrate(state_sync, **kwargs):  # type: ignore
10    engine_adapter = state_sync.engine_adapter
11    seeds_table = "_seeds"
12    if state_sync.schema:
13        seeds_table = f"{state_sync.schema}.{seeds_table}"
14
15    index_type = index_text_type(engine_adapter.dialect)
16
17    engine_adapter.create_state_table(
18        seeds_table,
19        {
20            "name": exp.DataType.build(index_type),
21            "identifier": exp.DataType.build(index_type),
22            "content": exp.DataType.build("text"),
23        },
24        primary_key=("name", "identifier"),
25    )