You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by je...@apache.org on 2022/02/01 21:46:55 UTC

[airflow] 02/02: Update version to 2.2.4 for things in that release (#21196)

This is an automated email from the ASF dual-hosted git repository.

jedcunningham pushed a commit to branch v2-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git

commit 0e275f1347f21846c22035340535d87f8dd182b4
Author: Jed Cunningham <66...@users.noreply.github.com>
AuthorDate: Tue Feb 1 12:05:04 2022 -0700

    Update version to 2.2.4 for things in that release (#21196)
    
    (cherry picked from commit 093702e9f579ee028a103cdc9acf0e6acccd6d79)
---
 airflow/api/common/experimental/get_code.py          | 2 +-
 airflow/api/common/experimental/get_dag_run_state.py | 2 +-
 airflow/api/common/experimental/get_task.py          | 2 +-
 airflow/api/common/experimental/get_task_instance.py | 2 +-
 airflow/api/common/experimental/pool.py              | 8 ++++----
 airflow/config_templates/config.yml                  | 2 +-
 6 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/airflow/api/common/experimental/get_code.py b/airflow/api/common/experimental/get_code.py
index 1a1fb62..d4232b1 100644
--- a/airflow/api/common/experimental/get_code.py
+++ b/airflow/api/common/experimental/get_code.py
@@ -23,7 +23,7 @@ from airflow.exceptions import AirflowException, DagCodeNotFound
 from airflow.models.dagcode import DagCode
 
 
-@deprecated(reason="Use DagCode().get_code_by_fileloc() instead", version="2.2.3")
+@deprecated(reason="Use DagCode().get_code_by_fileloc() instead", version="2.2.4")
 def get_code(dag_id: str) -> str:
     """Return python code of a given dag_id.
 
diff --git a/airflow/api/common/experimental/get_dag_run_state.py b/airflow/api/common/experimental/get_dag_run_state.py
index b2dedd5..7201186 100644
--- a/airflow/api/common/experimental/get_dag_run_state.py
+++ b/airflow/api/common/experimental/get_dag_run_state.py
@@ -24,7 +24,7 @@ from deprecated import deprecated
 from airflow.api.common.experimental import check_and_get_dag, check_and_get_dagrun
 
 
-@deprecated(reason="Use DagRun().get_state() instead", version="2.2.3")
+@deprecated(reason="Use DagRun().get_state() instead", version="2.2.4")
 def get_dag_run_state(dag_id: str, execution_date: datetime) -> Dict[str, str]:
     """Return the Dag Run state identified by the given dag_id and execution_date.
 
diff --git a/airflow/api/common/experimental/get_task.py b/airflow/api/common/experimental/get_task.py
index fae5fd7..4589cc6 100644
--- a/airflow/api/common/experimental/get_task.py
+++ b/airflow/api/common/experimental/get_task.py
@@ -22,7 +22,7 @@ from airflow.api.common.experimental import check_and_get_dag
 from airflow.models import TaskInstance
 
 
-@deprecated(reason="Use DAG().get_task", version="2.2.3")
+@deprecated(reason="Use DAG().get_task", version="2.2.4")
 def get_task(dag_id: str, task_id: str) -> TaskInstance:
     """Return the task object identified by the given dag_id and task_id."""
     dag = check_and_get_dag(dag_id, task_id)
diff --git a/airflow/api/common/experimental/get_task_instance.py b/airflow/api/common/experimental/get_task_instance.py
index 137f8a3..7361efd 100644
--- a/airflow/api/common/experimental/get_task_instance.py
+++ b/airflow/api/common/experimental/get_task_instance.py
@@ -25,7 +25,7 @@ from airflow.exceptions import TaskInstanceNotFound
 from airflow.models import TaskInstance
 
 
-@deprecated(version="2.2.3", reason="Use DagRun.get_task_instance instead")
+@deprecated(version="2.2.4", reason="Use DagRun.get_task_instance instead")
 def get_task_instance(dag_id: str, task_id: str, execution_date: datetime) -> TaskInstance:
     """Return the task instance identified by the given dag_id, task_id and execution_date."""
     dag = check_and_get_dag(dag_id, task_id)
diff --git a/airflow/api/common/experimental/pool.py b/airflow/api/common/experimental/pool.py
index 0b9c3a5..fe4f161 100644
--- a/airflow/api/common/experimental/pool.py
+++ b/airflow/api/common/experimental/pool.py
@@ -23,7 +23,7 @@ from airflow.models import Pool
 from airflow.utils.session import provide_session
 
 
-@deprecated(reason="Use Pool.get_pool() instead", version="2.2.3")
+@deprecated(reason="Use Pool.get_pool() instead", version="2.2.4")
 @provide_session
 def get_pool(name, session=None):
     """Get pool by a given name."""
@@ -37,14 +37,14 @@ def get_pool(name, session=None):
     return pool
 
 
-@deprecated(reason="Use Pool.get_pools() instead", version="2.2.3")
+@deprecated(reason="Use Pool.get_pools() instead", version="2.2.4")
 @provide_session
 def get_pools(session=None):
     """Get all pools."""
     return session.query(Pool).all()
 
 
-@deprecated(reason="Use Pool.create_pool() instead", version="2.2.3")
+@deprecated(reason="Use Pool.create_pool() instead", version="2.2.4")
 @provide_session
 def create_pool(name, slots, description, session=None):
     """Create a pool with a given parameters."""
@@ -75,7 +75,7 @@ def create_pool(name, slots, description, session=None):
     return pool
 
 
-@deprecated(reason="Use Pool.delete_pool() instead", version="2.2.3")
+@deprecated(reason="Use Pool.delete_pool() instead", version="2.2.4")
 @provide_session
 def delete_pool(name, session=None):
     """Delete pool by a given name."""
diff --git a/airflow/config_templates/config.yml b/airflow/config_templates/config.yml
index e061568..98baa2f 100644
--- a/airflow/config_templates/config.yml
+++ b/airflow/config_templates/config.yml
@@ -1666,7 +1666,7 @@
     - name: stuck_queued_task_check_interval
       description: |
         How often to check for stuck queued task (in seconds)
-      version_added: 2.3.0
+      version_added: 2.2.4
       type: integer
       example: ~
       default: "300"