You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by pi...@apache.org on 2026/07/27 12:17:05 UTC
(airflow) branch v3-3-test updated: [v3-3-test] Fix DAG details active runs count to exclude queued runs (#69769) (#70511)
This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a commit to branch v3-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-3-test by this push:
new 043b3ab0984 [v3-3-test] Fix DAG details active runs count to exclude queued runs (#69769) (#70511)
043b3ab0984 is described below
commit 043b3ab0984ab2e1b730d293c0dbe1652db25886
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Mon Jul 27 14:16:57 2026 +0200
[v3-3-test] Fix DAG details active runs count to exclude queued runs (#69769) (#70511)
* Fix DAG details active runs count to exclude queued runs
* Remove newsfragment
---------
(cherry picked from commit 66ea88f0bea478aaa10a405603d7f8f52275210d)
Co-authored-by: VishwasPatel <67...@users.noreply.github.com>
Co-authored-by: pierrejeambrun <pi...@gmail.com>
---
airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py | 2 +-
airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dags.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py
index 355ce4ca7a5..69b6b2932f0 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/dags.py
@@ -250,7 +250,7 @@ def get_dag_details(
session.scalar(
select(func.count())
.select_from(DagRun)
- .where(DagRun.dag_id == dag_id, DagRun.state.in_([DagRunState.RUNNING, DagRunState.QUEUED]))
+ .where(DagRun.dag_id == dag_id, DagRun.state == DagRunState.RUNNING)
)
or 0
)
diff --git a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dags.py b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dags.py
index f3a3eef61c0..eb5d4a9f918 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dags.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dags.py
@@ -1249,7 +1249,7 @@ class TestDagDetails(TestDagEndpoint):
# Verify active_runs_count field is present and correct
assert "active_runs_count" in body
assert isinstance(body["active_runs_count"], int)
- assert body["active_runs_count"] == 2 # 1 running + 1 queued
+ assert body["active_runs_count"] == 1 # only running counts, queued does not
# Test with DAG that has no active runs
response = test_client.get(f"/dags/{DAG1_ID}/details")