yuqian90 commented on a change in pull request #6633: [AIRFLOW-2279] Clear
tasks across DAGs if marked by ExternalTaskMarker
URL: https://github.com/apache/airflow/pull/6633#discussion_r358843729
##########
File path: airflow/sensors/external_task_sensor.py
##########
@@ -161,3 +164,49 @@ def poke(self, context, session=None):
session.commit()
return count == len(dttm_filter)
+
+
+class ExternalTaskMarker(DummyOperator):
+ """
+ Use this operator to indicate that a task on a different DAG depends on
this task.
+ When this task is cleared with "Recursive" selected, Airflow will clear
the task on
+ the other DAG and its downstream tasks recursively. Transitive
dependencies is followed
+ until the recursion_depth is reached.
+ """
Review comment:
Thanks for pointing out. I made this change as suggested.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
