[AIRFLOW-649] Support non-sched DAGs in LatestOnlyOp

Closes apache#1956 from r39132/master
ming-wu · Dec 22, 2016 · 3cec728 · 3cec728
1 parent edf55cd
commit 3cec728
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/airflow/operators/latest_only_operator.py b/airflow/operators/latest_only_operator.py
@@ -32,6 +32,13 @@ class LatestOnlyOperator(BaseOperator):
     ui_color = '#e9ffdb'  # nyanza
 
     def execute(self, context):
+        # If the DAG Run is externally triggered, then return without
+        # skipping downstream tasks
+        if context['dag_run'].external_trigger:
+            logging.info("""Externally triggered DAG_Run:
+                         allowing execution to proceed.""")
+            return
+
         now = datetime.datetime.now()
         left_window = context['dag'].following_schedule(
             context['execution_date'])