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 2066812960018ce0d7ba774dd2f9fe5c0d8b52a4 Author: Jed Cunningham <66968678+jedcunning...@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 ++++---- 5 files changed, 8 insertions(+), 8 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."""