You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by pi...@apache.org on 2025/07/09 12:19:58 UTC
(airflow) branch v3-0-test updated: [v3-0-test] Invalidate grid runs and summaries and TI/Runs actions (#53081) (#53086)
This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new c078597575a [v3-0-test] Invalidate grid runs and summaries and TI/Runs actions (#53081) (#53086)
c078597575a is described below
commit c078597575ae00ba7fb692d3e4a75edc5bd68217
Author: github-actions[bot] <41...@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 <pi...@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 })));