4224ed9e9473_revise_osm_primary_keys.py

"""revise osm primary keys

Revision ID: 4224ed9e9473
Revises: 5163f5a4135e
Create Date: 2022-02-24 18:43:33.749064

"""
import os

from alembic import op

here = os.path.dirname(os.path.realpath(__file__))

# revision identifiers, used by Alembic.
revision = "4224ed9e9473"
down_revision = "5163f5a4135e"
branch_labels = None
depends_on = None

revision_dir = f"{here}/{revision}"


# idea from https://github.com/tbobm/alembic-sequeled
def process_migration(script_name: str):
    filename = f"{revision_dir}/{script_name}.sql"

    query = "\n".join(open(filename))
    if len(query) > 0:
        op.execute(query)


def upgrade():
    process_migration("upgrade")


def downgrade():
    process_migration("downgrade")