clear

Елена Костюченко

Описание

Удаляет информацию о запусках задач, возвращая их к состоянию как до первого запуска.

Использование

$ airflow tasks clear [-h] [-R] [-d] [-e END_DATE] [-X] [-x] [-f] [-r]
                    [-s START_DATE] [-S SUBDIR] [-t TASK_REGEX] [-u] [-v] [-y]
                    dag_id

Аргументы

Параметр Описание

dag_id

Идентификатор DAG

-R, --dag-regex

Рассматривать значение dag_id как регулярное выражение

-d, --downstream

Включить последующие задачи

-e, --end-date

Переопределить end_date. Формат даты YYYY-MM-DD

-X, --exclude-parentdag

Исключить родительские DAG, если задача является частью sub-DAG

-x, --exclude-subdags

Исключить sub-DAG

-f, --only-failed

Включить только задания со статусом failed

-r, --only-running

Включить только запущенные задачи

-s, --start-date

Переопределить start_date. Формат даты — YYYY-MM-DD

-S, --subdir

Расположение файла или каталога, в котором следует искать DAG. По умолчанию — [AIRFLOW_HOME]/dags, где [AIRFLOW_HOME] — это значение, которое задано для конфигурации AIRFLOW_HOME в airflow.cfg

-t, --task-regex

Регулярное выражение для фильтрации определенных task_ids

-u, --upstream

Включить upstream-задачи

-y, --yes

Не запрашивать подтверждение

-h, --help

Вывести справку для команды

-v, --verbose

Более подробный вывод команды

Примеры

Чтобы удалить все невыполненные задачи для указанного DAG, воспользуйтесь командой:

$ airflow tasks clear example_dag_decorator --only-failed

Пример вывода:

[2025-04-03T04:50:11.935+0000] {dagbag.py:541} INFO - Filling up the DagBag from /opt/airflow/dags
You are about to delete these 1 tasks:
<TaskInstance: example_dag_decorator.send_email manual__2025-04-03T11:27:54.722760+00:00 [failed]>

Are you sure? [y/n]
Нашли ошибку? Выделите текст и нажмите Ctrl+Enter чтобы сообщить о ней