Skip all downstream tasks when using SkipMixin

magnuschill · Sep 15, 2017 · 9ba1190 · 9ba1190
1 parent 6632b0c
commit 9ba1190
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/airflow/models.py b/airflow/models.py
@@ -1939,6 +1939,9 @@ def skip(self, dag_run, execution_date, tasks):
             session.commit()
         session.close()
 
+        for task in tasks:
+            self.skip(dag_run, execution_date, task.downstream_list)
+
 
 @functools.total_ordering
 class BaseOperator(LoggingMixin):