From 5e87232fb34cfa61858d941649345ef7fa928a1b Mon Sep 17 00:00:00 2001 From: John Date: Wed, 20 Jan 2021 19:38:29 -0500 Subject: [PATCH] Scheduler should acknowledge active runs properly This commit fixes the scheduler to acknowledge active runs properly when comparing against max_active_runs for unscheduled DAG runs. --- airflow/jobs/scheduler_job.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py index b72e2b11bb4cd..39abc20167ffb 100644 --- a/airflow/jobs/scheduler_job.py +++ b/airflow/jobs/scheduler_job.py @@ -792,6 +792,7 @@ def _process_task_instances(self, dag, task_instances_list, session=None): run.verify_integrity(session=session) ready_tis = run.update_state(session=session) if run.state == State.RUNNING: + active_dag_runs.append(run) self.log.debug("Examining active DAG run: %s", run) for ti in ready_tis: self.log.debug('Queuing task: %s', ti)