diff --git a/airflow-core/src/airflow/utils/db.py b/airflow-core/src/airflow/utils/db.py index 4ab7226fcb487..f091f0868b0d5 100644 --- a/airflow-core/src/airflow/utils/db.py +++ b/airflow-core/src/airflow/utils/db.py @@ -1210,7 +1210,7 @@ def downgrade(*, to_revision, from_revision=None, show_sql_only=False, session: log.info("Attempting downgrade to revision %s", to_revision) config = _get_alembic_config() # Check if downgrade is less than 3.0.0 and requires that `ab_user` fab table is present - if _revision_greater(config, _REVISION_HEADS_MAP["3.0.0"], to_revision): + if _revision_greater(config, _REVISION_HEADS_MAP["2.10.3"], to_revision): unitest_mode = conf.getboolean("core", "unit_test_mode") if unitest_mode: try: