You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/07/25 13:50:18 UTC

[airflow] branch main updated: Fix ExternalTaskSensor not working with dynamic task (#25215)

This is an automated email from the ASF dual-hosted git repository.

potiuk 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 d7f4ee1786 Fix ExternalTaskSensor not working with dynamic task (#25215)
d7f4ee1786 is described below

commit d7f4ee1786ed09a804bfa4af45858ea0406f48a8
Author: YenchenLiu <ye...@users.noreply.github.com>
AuthorDate: Mon Jul 25 21:50:03 2022 +0800

    Fix ExternalTaskSensor not working with dynamic task (#25215)
    
    * Make operator_extra_links a class variable
    
    * Make operator_extra_links a class variable of ExternalTaskMarker
---
 airflow/sensors/external_task.py | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git a/airflow/sensors/external_task.py b/airflow/sensors/external_task.py
index 1b85d7a021..7081651a68 100644
--- a/airflow/sensors/external_task.py
+++ b/airflow/sensors/external_task.py
@@ -103,11 +103,7 @@ class ExternalTaskSensor(BaseSensorOperator):
 
     template_fields = ['external_dag_id', 'external_task_id', 'external_task_ids']
     ui_color = '#19647e'
-
-    @property
-    def operator_extra_links(self):
-        """Return operator extra links"""
-        return [ExternalDagLink()]
+    operator_extra_links = [ExternalDagLink()]
 
     def __init__(
         self,
@@ -316,15 +312,11 @@ class ExternalTaskMarker(EmptyOperator):
 
     template_fields = ['external_dag_id', 'external_task_id', 'execution_date']
     ui_color = '#19647e'
+    operator_extra_links = [ExternalDagLink()]
 
     # The _serialized_fields are lazily loaded when get_serialized_fields() method is called
     __serialized_fields: Optional[FrozenSet[str]] = None
 
-    @property
-    def operator_extra_links(self):
-        """Return operator extra links"""
-        return [ExternalDagLink()]
-
     def __init__(
         self,
         *,