From 378dbfb7b3830c07d3524bc676c33d96711cd380 Mon Sep 17 00:00:00 2001 From: Brent Bovenzi Date: Fri, 12 Aug 2022 18:34:45 +0100 Subject: [PATCH] Check for queued states for dags autorefresh (#25695) --- airflow/www/static/js/dags.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/www/static/js/dags.js b/airflow/www/static/js/dags.js index c6817d038e268..85b5e435e7f0c 100644 --- a/airflow/www/static/js/dags.js +++ b/airflow/www/static/js/dags.js @@ -424,7 +424,7 @@ let refreshInterval; function checkActiveRuns(json) { // filter latest dag runs and check if there are still running dags const activeRuns = Object.keys(json).filter((dagId) => { - const dagRuns = json[dagId].filter((s) => s.state === 'running').filter((r) => r.count > 0); + const dagRuns = json[dagId].filter(({ state }) => state === 'running' || state === 'queued').filter((r) => r.count > 0); return (dagRuns.length > 0); }); if (activeRuns.length === 0) {