diff --git a/airflow/serialization/serialized_objects.py b/airflow/serialization/serialized_objects.py index b7f928916de9..2b4ee8396c3a 100644 --- a/airflow/serialization/serialized_objects.py +++ b/airflow/serialization/serialized_objects.py @@ -119,7 +119,7 @@ log = logging.getLogger(__name__) _OPERATOR_EXTRA_LINKS: set[str] = { - "airflow.operators.trigger_dagrun.TriggerDagRunLink", + "airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunLink", "airflow.sensors.external_task.ExternalDagLink", # Deprecated names, so that existing serialized dags load straight away. "airflow.sensors.external_task.ExternalTaskSensorLink", diff --git a/tests/operators/test_trigger_dagrun.py b/tests/operators/test_trigger_dagrun.py index cfd925c24b94..ad1fca15ea46 100644 --- a/tests/operators/test_trigger_dagrun.py +++ b/tests/operators/test_trigger_dagrun.py @@ -107,7 +107,9 @@ def assert_extra_link(self, triggered_dag_run, triggering_task, session): ) .one() ) - with mock.patch("airflow.operators.trigger_dagrun.build_airflow_url_with_query") as mock_build_url: + with mock.patch( + "airflow.providers.standard.operators.trigger_dagrun.build_airflow_url_with_query" + ) as mock_build_url: triggering_task.get_extra_links(triggering_ti, "Triggered DAG") assert mock_build_url.called args, _ = mock_build_url.call_args