This is an automated email from the ASF dual-hosted git repository.

jscheffl 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 671d5614626 Reset grid dagrun query cache on trigger so that the new 
dagrun is fetched. (#52918)
671d5614626 is described below

commit 671d561462685c7c17af4e2051ed972db623200c
Author: Karthikeyan Singaravelan <tir.kar...@gmail.com>
AuthorDate: Sun Jul 6 01:22:17 2025 +0530

    Reset grid dagrun query cache on trigger so that the new dagrun is fetched. 
(#52918)
---
 airflow-core/src/airflow/ui/src/queries/useTrigger.ts | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/airflow-core/src/airflow/ui/src/queries/useTrigger.ts 
b/airflow-core/src/airflow/ui/src/queries/useTrigger.ts
index 3009ecbfc81..99f0a381c0e 100644
--- a/airflow-core/src/airflow/ui/src/queries/useTrigger.ts
+++ b/airflow-core/src/airflow/ui/src/queries/useTrigger.ts
@@ -26,6 +26,7 @@ import {
   useDagServiceGetDagsUiKey,
   UseGridServiceGridDataKeyFn,
   UseTaskInstanceServiceGetTaskInstancesKeyFn,
+  UseGridServiceGetGridRunsKeyFn,
 } from "openapi/queries";
 import type { DagRunTriggerParams } from 
"src/components/TriggerDag/TriggerDAGForm";
 import { toaster } from "src/components/ui";
@@ -40,6 +41,7 @@ export const useTrigger = ({ dagId, onSuccessConfirm }: { 
dagId: string; onSucce
       UseDagRunServiceGetDagRunsKeyFn({ dagId }, [{ dagId }]),
       UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagRunId: "~" }, [{ 
dagId, dagRunId: "~" }]),
       UseGridServiceGridDataKeyFn({ dagId }, [{ dagId }]),
+      UseGridServiceGetGridRunsKeyFn({ dagId }, [{ dagId }]),
     ];
 
     await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ 
queryKey: key })));

Reply via email to