Блог

Главная - Вопросы по программированию - Воздушный поток — Остановить засыпку

Воздушный поток — Остановить засыпку

#python #python-3.x #airflow

#python #python-3.x #воздушный поток

Вопрос:

Я использую воздушный поток 1.10.12, и у меня есть база данных, которая запускается ежедневно со следующими параметрами :

 default_args = {
    'start_date': days_ago(365),
    'end_date': days_ago(1),
    'depends_on_past': False,
}

Когда я запускаю dag, будет выполнено 365 запусков DAG.

Кажется, я вижу только активные прогоны DAG. Когда я удаляю текущие прогоны DAG, запускаются следующие прогоны DAG, пока я не достигну 365 прогонов DAG…

Есть ли способ остановить засыпку? (Я имею в виду удалить все прогоны DAG)

Хорошего дня

Комментарии:

1. Вы хотите удалить 365 запусков базы данных, которые выполнялись при запуске? или вообще не запускать базу данных 365 при ее включении?

2. На обед. Я столкнулся с проблемой, когда запустил обратную засыпку, а затем удивился, что в запущенном коде была ошибка.

3. хм, я не совсем понимаю, но catchup=False не буду автоматически засыпать при запуске. Вы можете выполнить обратную засыпку с помощью cli еще после запуска, если вам нужно. Или, если вы хотите запускать 365 дней после запуска, но хотите удалить все после запуска, тогда вам не следует устанавливать catchup . Тогда есть способ удалить уже запущенные базы данных, но я хотел бы сначала уточнить, что вы ищете. airflow.apache.org/docs/apache-airflow/stable /…

4. Дело не в том, чтобы установить catchup на 0 или 1. Если я засыпаю с помощью cli, есть ли способ остановить это?