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,
*,