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: us...@infra.apache.org With regards, Apache Git Services