Fix deprecation error message rather than silencing it

apache · Sep 9, 2021 · 5f0701b · 5f0701b
1 parent 47e8fa6
commit 5f0701b
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 5 deletions.
diff --git a/airflow/migrations/versions/092435bf5d12_add_max_active_runs_column_to_dagmodel_.py b/airflow/migrations/versions/092435bf5d12_add_max_active_runs_column_to_dagmodel_.py
@@ -44,7 +44,7 @@ def upgrade():
         batch_op.create_index(
             'idx_dag_run_running_dags',
             ["state", "dag_id"],
-            postgres_where=text("state='running'"),
+            postgresql_where=text("state='running'"),
             mssql_where=text("state='running'"),
             sqlite_where=text("state='running'"),
         )

diff --git a/airflow/migrations/versions/ccde3e26fe78_add_index_on_state_dag_id_for_queued_.py b/airflow/migrations/versions/ccde3e26fe78_add_index_on_state_dag_id_for_queued_.py
@@ -40,7 +40,7 @@ def upgrade():
         batch_op.create_index(
             'idx_dag_run_queued_dags',
             ["state", "dag_id"],
-            postgres_where=text("state='queued'"),
+            postgresql_where=text("state='queued'"),
             mssql_where=text("state='queued'"),
             sqlite_where=text("state='queued'"),
         )

diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py
@@ -108,7 +108,7 @@ class DagRun(Base, LoggingMixin):
             'idx_dag_run_running_dags',
             'state',
             'dag_id',
-            postgres_where=text("state='running'"),
+            postgresql_where=text("state='running'"),
             mssql_where=text("state='running'"),
             sqlite_where=text("state='running'"),
         ),
@@ -118,7 +118,7 @@ class DagRun(Base, LoggingMixin):
             'idx_dag_run_queued_dags',
             'state',
             'dag_id',
-            postgres_where=text("state='queued'"),
+            postgresql_where=text("state='queued'"),
             mssql_where=text("state='queued'"),
             sqlite_where=text("state='queued'"),
         ),

diff --git a/dev/provider_packages/prepare_provider_packages.py b/dev/provider_packages/prepare_provider_packages.py
@@ -2110,7 +2110,6 @@ def summarise_total_vs_bad_and_warnings(total: int, bad: int, warns: List[warnin
     ),
     ("SelectableGroups dict interface is deprecated. Use select.", "kombu"),
     ("The module cloudant is now deprecated. The replacement is ibmcloudant.", "cloudant"),
-    ("The 'postgres' dialect name has been renamed to 'postgresql'", 'sqlalchemy'),
 }
 
 # The set of warning messages generated by direct importing of some deprecated modules. We should only