This is an automated email from the ASF dual-hosted git repository. kaxilnaik pushed a commit to branch v3-0-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 1fc4c781b69bab0255fb11aa430da4e8f0b1dc3c Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Wed Jul 9 14:19:52 2025 +0200 [v3-0-test] Invalidate grid runs and summaries and TI/Runs actions (#53081) (#53086) (cherry picked from commit 3eaf4e90b69588e5022a0ead63ba0bc8c6382ed1) Co-authored-by: Pierre Jeambrun <pierrejb...@gmail.com> --- airflow-core/src/airflow/ui/src/queries/useClearRun.ts | 4 ++++ airflow-core/src/airflow/ui/src/queries/useClearTaskInstances.ts | 4 ++++ airflow-core/src/airflow/ui/src/queries/usePatchDagRun.ts | 4 ++++ airflow-core/src/airflow/ui/src/queries/usePatchTaskInstance.ts | 4 ++++ 4 files changed, 16 insertions(+) diff --git a/airflow-core/src/airflow/ui/src/queries/useClearRun.ts b/airflow-core/src/airflow/ui/src/queries/useClearRun.ts index 1c7a80d2a99..6d19f10ce84 100644 --- a/airflow-core/src/airflow/ui/src/queries/useClearRun.ts +++ b/airflow-core/src/airflow/ui/src/queries/useClearRun.ts @@ -25,6 +25,8 @@ import { UseDagServiceGetDagDetailsKeyFn, UseGridServiceGridDataKeyFn, useTaskInstanceServiceGetTaskInstancesKey, + UseGridServiceGetGridRunsKeyFn, + UseGridServiceGetGridTiSummariesKeyFn, } from "openapi/queries"; import { toaster } from "src/components/ui"; @@ -57,6 +59,8 @@ export const useClearDagRun = ({ [useDagRunServiceGetDagRunsKey], [useClearDagRunDryRunKey, dagId], UseGridServiceGridDataKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridRunsKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridTiSummariesKeyFn({ dagId, runId: dagRunId }, [{ dagId, runId: dagRunId }]), ]; await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ queryKey: key }))); diff --git a/airflow-core/src/airflow/ui/src/queries/useClearTaskInstances.ts b/airflow-core/src/airflow/ui/src/queries/useClearTaskInstances.ts index 205f6faa072..f0ed0378581 100644 --- a/airflow-core/src/airflow/ui/src/queries/useClearTaskInstances.ts +++ b/airflow-core/src/airflow/ui/src/queries/useClearTaskInstances.ts @@ -24,6 +24,8 @@ import { UseGridServiceGridDataKeyFn, UseTaskInstanceServiceGetMappedTaskInstanceKeyFn, useTaskInstanceServicePostClearTaskInstances, + UseGridServiceGetGridRunsKeyFn, + UseGridServiceGetGridTiSummariesKeyFn, } from "openapi/queries"; import type { ClearTaskInstancesBody, TaskInstanceCollectionResponse } from "openapi/requests/types.gen"; import { toaster } from "src/components/ui"; @@ -82,6 +84,8 @@ export const useClearTaskInstances = ({ [useClearTaskInstancesDryRunKey, dagId], [usePatchTaskInstanceDryRunKey, dagId, dagRunId], UseGridServiceGridDataKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridRunsKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridTiSummariesKeyFn({ dagId, runId: dagRunId }, [{ dagId, runId: dagRunId }]), ]; await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ queryKey: key }))); diff --git a/airflow-core/src/airflow/ui/src/queries/usePatchDagRun.ts b/airflow-core/src/airflow/ui/src/queries/usePatchDagRun.ts index 6ca008b6dc1..859199a9352 100644 --- a/airflow-core/src/airflow/ui/src/queries/usePatchDagRun.ts +++ b/airflow-core/src/airflow/ui/src/queries/usePatchDagRun.ts @@ -24,6 +24,8 @@ import { useDagRunServicePatchDagRun, UseGridServiceGridDataKeyFn, useTaskInstanceServiceGetTaskInstancesKey, + UseGridServiceGetGridRunsKeyFn, + UseGridServiceGetGridTiSummariesKeyFn, } from "openapi/queries"; import { toaster } from "src/components/ui"; @@ -55,6 +57,8 @@ export const usePatchDagRun = ({ [useTaskInstanceServiceGetTaskInstancesKey, { dagId, dagRunId }], [useClearDagRunDryRunKey, dagId], UseGridServiceGridDataKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridRunsKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridTiSummariesKeyFn({ dagId, runId: dagRunId }, [{ dagId, runId: dagRunId }]), ]; await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ queryKey: key }))); diff --git a/airflow-core/src/airflow/ui/src/queries/usePatchTaskInstance.ts b/airflow-core/src/airflow/ui/src/queries/usePatchTaskInstance.ts index 8cd6a7c36cb..988e24c72c2 100644 --- a/airflow-core/src/airflow/ui/src/queries/usePatchTaskInstance.ts +++ b/airflow-core/src/airflow/ui/src/queries/usePatchTaskInstance.ts @@ -24,6 +24,8 @@ import { UseTaskInstanceServiceGetTaskInstanceKeyFn, useTaskInstanceServiceGetTaskInstancesKey, useTaskInstanceServicePatchTaskInstance, + UseGridServiceGetGridRunsKeyFn, + UseGridServiceGetGridTiSummariesKeyFn, } from "openapi/queries"; import { toaster } from "src/components/ui"; @@ -61,6 +63,8 @@ export const usePatchTaskInstance = ({ [usePatchTaskInstanceDryRunKey, dagId, dagRunId, { mapIndex, taskId }], [useClearTaskInstancesDryRunKey, dagId], UseGridServiceGridDataKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridRunsKeyFn({ dagId }, [{ dagId }]), + UseGridServiceGetGridTiSummariesKeyFn({ dagId, runId: dagRunId }, [{ dagId, runId: dagRunId }]), ]; await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ queryKey: key })));