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 })));