redis-om-python/aredis_om/model/cli/migrate.py

import click

from aredis_om.model.migrations.migrator import Migrator


@click.command()
@click.option("--module", default="aredis_om")
def migrate(module: str):
    migrator = Migrator(module)
    migrator.detect_migrations()

    if migrator.migrations:
        print("Pending migrations:")
        for migration in migrator.migrations:
            print(migration)

        if input("Run migrations? (y/n) ") == "y":
            migrator.run()