Repository: incubator-airflow Updated Branches: refs/heads/master 53b8ddd2a -> 9d5cc6ef5
[AIRFLOW-2173] Don't check task IDs for concurrency reached check Closes #3099 from aoen/ddavydov--ddavydov-- remove_unecessary_in_clause_in_dep_check Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/9d5cc6ef Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/9d5cc6ef Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/9d5cc6ef Branch: refs/heads/master Commit: 9d5cc6ef5fe18055395ab671d602d70ab18dcbd2 Parents: 53b8ddd Author: Dan Davydov <dan.davy...@airbnb.com> Authored: Tue Mar 6 10:35:07 2018 +0100 Committer: Fokko Driesprong <fokkodriespr...@godatadriven.com> Committed: Tue Mar 6 10:35:07 2018 +0100 ---------------------------------------------------------------------- airflow/models.py | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/9d5cc6ef/airflow/models.py ---------------------------------------------------------------------- diff --git a/airflow/models.py b/airflow/models.py index ae0f68e..98e9fcd 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -3331,7 +3331,6 @@ class DAG(BaseDag, LoggingMixin): TI = TaskInstance qry = session.query(func.count(TI.task_id)).filter( TI.dag_id == self.dag_id, - TI.task_id.in_(self.task_ids), TI.state == State.RUNNING, ) return qry.scalar() >= self.concurrency
