diff --git a/airflow-core/src/airflow/ui/src/queries/useClearRun.ts b/airflow-core/src/airflow/ui/src/queries/useClearRun.ts index 1c7a80d2a9903..6d19f10ce843d 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 205f6faa0722a..f0ed037858177 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 6ca008b6dc137..859199a935249 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 8cd6a7c36cb48..988e24c72c24b 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 })));