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 <[email protected]>
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 })));