Repository: incubator-airflow Updated Branches: refs/heads/master 972086aeb -> 2d50ba433
[AIRFLOW-1472] Fix SLA misses triggering on skipped tasks. Closes #3370 from milliburn/airflow-1472-master Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/2d50ba43 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/2d50ba43 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/2d50ba43 Branch: refs/heads/master Commit: 2d50ba43366f646e9391a981083623caa12e8967 Parents: 972086a Author: Roberth Kulbin <robe...@winter-weht.net> Authored: Thu May 24 21:14:32 2018 +0100 Committer: Kaxil Naik <kaxiln...@apache.org> Committed: Thu May 24 21:14:32 2018 +0100 ---------------------------------------------------------------------- airflow/jobs.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/2d50ba43/airflow/jobs.py ---------------------------------------------------------------------- diff --git a/airflow/jobs.py b/airflow/jobs.py index 0391750..6c9caef 100644 --- a/airflow/jobs.py +++ b/airflow/jobs.py @@ -617,7 +617,9 @@ class SchedulerJob(BaseJob): func.max(TI.execution_date).label('max_ti')) .with_hint(TI, 'USE INDEX (PRIMARY)', dialect_name='mysql') .filter(TI.dag_id == dag.dag_id) - .filter(TI.state == State.SUCCESS) + .filter(or_( + TI.state == State.SUCCESS, + TI.state == State.SKIPPED)) .filter(TI.task_id.in_(dag.task_ids)) .group_by(TI.task_id).subquery('sq') )
