From 619aaa545e826832ccd49c4370184a590c03f85f Mon Sep 17 00:00:00 2001 From: Omkar P <45419097+omkar-foss@users.noreply.github.com> Date: Wed, 6 Nov 2024 00:56:22 +0530 Subject: [PATCH] Add migration marker --- airflow/api_connexion/endpoints/task_endpoint.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/airflow/api_connexion/endpoints/task_endpoint.py b/airflow/api_connexion/endpoints/task_endpoint.py index 4c5954d2ac5f0..abc28cfee6fbb 100644 --- a/airflow/api_connexion/endpoints/task_endpoint.py +++ b/airflow/api_connexion/endpoints/task_endpoint.py @@ -25,12 +25,14 @@ from airflow.auth.managers.models.resource_details import DagAccessEntity from airflow.exceptions import TaskNotFound from airflow.utils.airflow_flask_app import get_airflow_app +from airflow.utils.api_migration import mark_fastapi_migration_done if TYPE_CHECKING: from airflow import DAG from airflow.api_connexion.types import APIResponse +@mark_fastapi_migration_done @security.requires_access_dag("GET", DagAccessEntity.TASK) def get_task(*, dag_id: str, task_id: str) -> APIResponse: """Get simplified representation of a task."""