(airflow) branch main updated: Fetch only the most recent dagrun value for list display. (#50834)

[bbovenzi]

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 bca010b3a83 Fetch only the most recent dagrun value for list display. 
(#50834)
bca010b3a83 is described below

commit bca010b3a837008858b1a3c44d6b068c8d2517bb
Author: Karthikeyan Singaravelan <tir.kar...@gmail.com>
AuthorDate: Fri May 23 02:07:34 2025 +0530

    Fetch only the most recent dagrun value for list display. (#50834)
---
 airflow-core/src/airflow/ui/src/pages/DagsList/DagsList.tsx | 3 ++-
 airflow-core/src/airflow/ui/src/queries/useDags.tsx         | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/airflow-core/src/airflow/ui/src/pages/DagsList/DagsList.tsx 
b/airflow-core/src/airflow/ui/src/pages/DagsList/DagsList.tsx
index 075011c0d73..6bb098516f4 100644
--- a/airflow-core/src/airflow/ui/src/pages/DagsList/DagsList.tsx
+++ b/airflow-core/src/airflow/ui/src/pages/DagsList/DagsList.tsx
@@ -163,6 +163,7 @@ const DAGS_LIST_DISPLAY = "dags_list_display";
 export const DagsList = () => {
   const [searchParams, setSearchParams] = useSearchParams();
   const [display, setDisplay] = useLocalStorage<"card" | 
"table">(DAGS_LIST_DISPLAY, "card");
+  const dagRunsLimit = display === "card" ? 14 : 1;
 
   const hidePausedDagsByDefault = 
Boolean(useConfig("hide_paused_dags_by_default"));
   const defaultShowPaused = hidePausedDagsByDefault ? false : undefined;
@@ -206,7 +207,7 @@ export const DagsList = () => {
     paused = false;
   }
 
-  const { data, error, isLoading } = useDags({
+  const { data, error, isLoading } = useDags(dagRunsLimit, {
     dagDisplayNamePattern: Boolean(dagDisplayNamePattern) ? 
`${dagDisplayNamePattern}` : undefined,
     lastDagRunState,
     limit: pagination.pageSize,
diff --git a/airflow-core/src/airflow/ui/src/queries/useDags.tsx 
b/airflow-core/src/airflow/ui/src/queries/useDags.tsx
index d4f58dc985e..608ccedd5b8 100644
--- a/airflow-core/src/airflow/ui/src/queries/useDags.tsx
+++ b/airflow-core/src/airflow/ui/src/queries/useDags.tsx
@@ -25,6 +25,7 @@ export type DagWithLatest = {
 } & DAGWithLatestDagRunsResponse;
 
 export const useDags = (
+  dagRunsLimit: number,
   searchParams: {
     dagDisplayNamePattern?: string;
     dagIdPattern?: string;
@@ -51,7 +52,7 @@ export const useDags = (
   } = useDagsServiceRecentDagRuns(
     {
       ...runsParams,
-      dagRunsLimit: 14,
+      dagRunsLimit,
     },
     undefined,
     {