You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2021/09/10 13:36:43 UTC
[airflow] branch v2-1-test updated: Fix deprecation error message
rather than silencing it (#18126)
This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v2-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v2-1-test by this push:
new 54f3a77 Fix deprecation error message rather than silencing it (#18126)
54f3a77 is described below
commit 54f3a77315b733b70ba809fc6795e42cbd8a9938
Author: Ash Berlin-Taylor <as...@firemirror.com>
AuthorDate: Fri Sep 10 00:07:19 2021 +0100
Fix deprecation error message rather than silencing it (#18126)
(cherry picked from commit c9d29467f71060f14863ca3508cb1055572479b5)
---
.../versions/092435bf5d12_add_max_active_runs_column_to_dagmodel_.py | 2 +-
.../versions/ccde3e26fe78_add_index_on_state_dag_id_for_queued_.py | 2 +-
airflow/models/dagrun.py | 4 ++--
3 files changed, 4 insertions(+), 4 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
index 82bb4c2..a9f612d 100644
--- 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
index 7326d73..6a1cbe6 100644
--- 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
index 1e5c2c1..ec4bdfb 100644
--- a/airflow/models/dagrun.py
+++ b/airflow/models/dagrun.py
@@ -103,7 +103,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'"),
),
@@ -113,7 +113,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'"),
),