Edit on GitHub

Remove the obsolete _plan_dags table.

 1"""Remove the obsolete _plan_dags table."""
 2
 3
 4def migrate_schemas(engine_adapter, schema, **kwargs):  # type: ignore
 5    plan_dags_table = "_plan_dags"
 6    if schema:
 7        plan_dags_table = f"{schema}.{plan_dags_table}"
 8
 9    engine_adapter.drop_table(plan_dags_table)
10
11
12def migrate_rows(engine_adapter, schema, **kwargs):  # type: ignore
13    pass
def migrate_schemas(engine_adapter, schema, **kwargs): 
 5def migrate_schemas(engine_adapter, schema, **kwargs):  # type: ignore
 6    plan_dags_table = "_plan_dags"
 7    if schema:
 8        plan_dags_table = f"{schema}.{plan_dags_table}"
 9
10    engine_adapter.drop_table(plan_dags_table)
def migrate_rows(engine_adapter, schema, **kwargs): 
13def migrate_rows(engine_adapter, schema, **kwargs):  # type: ignore
14    pass