Remove unnecessary list conversion (apache#13407)

soltanianalytics · Jan 2, 2021 · 4a84834 · 4a84834
1 parent a893656
commit 4a84834
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py
@@ -1478,7 +1478,7 @@ def _do_scheduling(self, session) -> int:
                 guard.commit()
                 # END: create dagruns
 
-            dag_runs = list(DagRun.next_dagruns_to_examine(session))
+            dag_runs = DagRun.next_dagruns_to_examine(session)
 
             # Bulk fetch the currently active dag runs for the dags we are
             # examining, rather than making one query per DagRun