Fixing tests

lestatmq · Oct 24, 2015 · b6a8cb3 · b6a8cb3
1 parent 7808ebc
commit b6a8cb3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airflow/jobs.py b/airflow/jobs.py
@@ -650,7 +650,8 @@ def _execute(self):
         while tasks_to_run:
             for key, ti in list(tasks_to_run.items()):
                 ti.refresh_from_db()
-                if ti.state == State.SUCCESS and key in tasks_to_run:
+                if ti.state in (
+                        State.SUCCESS, State.SKIPPED) and key in tasks_to_run:
                     succeeded.append(key)
                     del tasks_to_run[key]
                 elif ti.is_runnable():