Remove internal_api_call from models/serialized_dag (apache#44501)

astronomer · Nov 30, 2024 · 288a18c · 288a18c
1 parent 8e7797f
commit 288a18c
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/airflow/models/serialized_dag.py b/airflow/models/serialized_dag.py
@@ -31,7 +31,6 @@
 from sqlalchemy.sql.expression import func, literal
 from sqlalchemy_utils import UUIDType
 
-from airflow.api_internal.internal_api_call import internal_api_call
 from airflow.exceptions import TaskNotFound
 from airflow.models.base import ID_LEN, Base
 from airflow.models.dag import DagModel
@@ -456,7 +455,6 @@ def get_dag_dependencies(cls, session: Session = NEW_SESSION) -> dict[str, list[
         return {dag_id: [DagDependency(**d) for d in (deps_data or [])] for dag_id, deps_data in iterator}
 
     @staticmethod
-    @internal_api_call
     @provide_session
     def get_serialized_dag(dag_id: str, task_id: str, session: Session = NEW_SESSION) -> Operator | None:
         try: