Use a local fn

discovery-provider/alembic/env.py

@@ -3,9 +3,9 @@
 import os
 import re
 
-from alembic import context, op
+from alembic import context
 from alembic.ddl.base import AddColumn, DropColumn, visit_add_column, visit_drop_column
-from sqlalchemy import engine_from_config, pool, inspect
+from sqlalchemy import engine_from_config, pool
 from sqlalchemy.ext.compiler import compiles
 from sqlalchemy.schema import CreateIndex, CreateTable, DropIndex, DropTable
 
@@ -114,12 +114,6 @@ def _add_if_exists(element, compiler, **kw):
     )
 
 
-def column_exists(table_name, column_name):
-    bind = op.get_context().bind
-    insp = inspect(bind)
-    columns = insp.get_columns(table_name)
-    return any(c["name"] == column_name for c in columns)
-
 if context.is_offline_mode():
     run_migrations_offline()
 else:

discovery-provider/alembic/versions/0d2067242dd5_change_reaction_column_names.py

@@ -5,16 +5,20 @@
 Create Date: 2022-05-09 22:03:16.838837
 
 """
-import sqlalchemy as sa
+import sqlalchemy as sa, inspect
 from alembic import op
-from alembic.env import column_exists
 
 # revision identifiers, used by Alembic.
 revision = "0d2067242dd5"
 down_revision = "35198266d709"
 branch_labels = None
 depends_on = None
 
+def column_exists(table_name, column_name):
+    bind = op.get_context().bind
+    insp = inspect(bind)
+    columns = insp.get_columns(table_name)
+    return any(c["name"] == column_name for c in columns)
 
 def upgrade():
     # Handle lack of idempotency for this migration