This is an automated email from the ASF dual-hosted git repository.
gopidesu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new b5efb47161a Cleanup _OPERATOR_EXTRA_LINKS in serialized_objects
(#49445)
b5efb47161a is described below
commit b5efb47161ada24819201bdd3977e2032dbe7170
Author: GPK <[email protected]>
AuthorDate: Fri Apr 25 17:20:37 2025 +0100
Cleanup _OPERATOR_EXTRA_LINKS in serialized_objects (#49445)
---
.../src/airflow/serialization/serialized_objects.py | 21 ---------------------
1 file changed, 21 deletions(-)
diff --git a/airflow-core/src/airflow/serialization/serialized_objects.py
b/airflow-core/src/airflow/serialization/serialized_objects.py
index 948111b2c17..d77d992d739 100644
--- a/airflow-core/src/airflow/serialization/serialized_objects.py
+++ b/airflow-core/src/airflow/serialization/serialized_objects.py
@@ -51,7 +51,6 @@ from airflow.models.taskinstance import SimpleTaskInstance,
TaskInstance
from airflow.models.taskinstancekey import TaskInstanceKey
from airflow.models.xcom import XComModel
from airflow.models.xcom_arg import SchedulerXComArg, deserialize_xcom_arg
-from airflow.providers_manager import ProvidersManager
from airflow.sdk.bases.operator import BaseOperator as TaskSDKBaseOperator
from airflow.sdk.definitions._internal.expandinput import EXPAND_INPUT_EMPTY
from airflow.sdk.definitions.asset import (
@@ -118,26 +117,6 @@ if TYPE_CHECKING:
log = logging.getLogger(__name__)
-_OPERATOR_EXTRA_LINKS: set[str] = {
- "airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunLink",
- "airflow.providers.standard.sensors.external_task.ExternalDagLink",
- # Deprecated names, so that existing serialized dags load straight away.
- "airflow.providers.standard.sensors.external_task.ExternalTaskSensorLink",
- "airflow.operators.dagrun_operator.TriggerDagRunLink",
-
"airflow.providers.standard.sensors.external_task_sensor.ExternalTaskSensorLink",
-}
-
-
-@cache
-def get_operator_extra_links() -> set[str]:
- """
- Get the operator extra links.
-
- This includes both the built-in ones, and those come from the providers.
- """
- _OPERATOR_EXTRA_LINKS.update(ProvidersManager().extra_links_class_names)
- return _OPERATOR_EXTRA_LINKS
-
@cache
def _get_default_mapped_partial() -> dict[str, Any]:
