From 010b63ee4bab4cc9acace2b6bda5fe0654998805 Mon Sep 17 00:00:00 2001 From: prha <1040172+prha@users.noreply.github.com> Date: Tue, 5 Nov 2024 14:52:46 -0800 Subject: [PATCH] partial revert - stop threaded check of alembic version (#25754) ## Summary & Motivation Revert partially the change to check alembic revision within the stamp call from https://github.com/dagster-io/dagster/pull/25740/ ## How I Tested These Changes BK --- python_modules/dagster/dagster/_core/storage/sql.py | 5 ----- 1 file changed, 5 deletions(-) diff --git a/python_modules/dagster/dagster/_core/storage/sql.py b/python_modules/dagster/dagster/_core/storage/sql.py index 2e63e875162bc..ecf45941eec78 100644 --- a/python_modules/dagster/dagster/_core/storage/sql.py +++ b/python_modules/dagster/dagster/_core/storage/sql.py @@ -64,11 +64,6 @@ def run_alembic_downgrade( def stamp_alembic_rev(alembic_config: Config, conn: Connection, rev: str = "head") -> None: with _alembic_lock: - migration_context = MigrationContext.configure(conn) - db_revision = migration_context.get_current_revision() - if db_revision is not None: - # sanity check that another thread hasn't stamped a revision - return alembic_config.attributes["connection"] = conn stamp(alembic_config, rev)