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)