Skip to content

Commit fba7b51

Browse files
committed
Fix ClearTaskInstanceConfirmationDialog to support clearing all mapped instances
1 parent aec5f7f commit fba7b51

1 file changed

Lines changed: 9 additions & 1 deletion

File tree

airflow-core/src/airflow/ui/src/components/Clear/TaskInstance/ClearTaskInstanceConfirmationDialog.tsx

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,14 @@ const ClearTaskInstanceConfirmationDialog = ({
5151
preventRunningTask,
5252
}: Props) => {
5353
const { t: translate } = useTranslation();
54+
55+
// Build task_ids based on whether mapIndex is defined
56+
// If mapIndex is undefined, use [taskId] to clear all mapped instances
57+
// If mapIndex is defined, use [[taskId, mapIndex]] to clear specific instance
58+
const taskIds = dagDetails?.mapIndex !== undefined
59+
? [[dagDetails.taskId ?? "", dagDetails.mapIndex]]
60+
: [dagDetails?.taskId ?? ""];
61+
5462
const { data, isFetching } = useClearTaskInstancesDryRun({
5563
dagId: dagDetails?.dagId ?? "",
5664
options: {
@@ -67,7 +75,7 @@ const ClearTaskInstanceConfirmationDialog = ({
6775
include_past: dagDetails?.past,
6876
include_upstream: dagDetails?.upstream,
6977
only_failed: dagDetails?.onlyFailed,
70-
task_ids: [[dagDetails?.taskId ?? "", dagDetails?.mapIndex ?? 0]],
78+
task_ids: taskIds,
7179
},
7280
});
7381

0 commit comments

Comments
 (0)