You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bb...@apache.org on 2022/08/12 17:34:56 UTC
[airflow] branch main updated: Check for queued states for dags autorefresh (#25695)
This is an automated email from the ASF dual-hosted git repository.
bbovenzi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 378dbfb7b3 Check for queued states for dags autorefresh (#25695)
378dbfb7b3 is described below
commit 378dbfb7b3830c07d3524bc676c33d96711cd380
Author: Brent Bovenzi <br...@gmail.com>
AuthorDate: Fri Aug 12 18:34:45 2022 +0100
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 c6817d038e..85b5e435e7 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) {