Телеграмм чат группы ruairflow страница 1372

и дальше только по одному дню всё сбрасывать руками так)

12:23пожаловаться #1

Никита in Airflow

Всем привет, кто-нибудь знает как достать schedule_interval определенного дага в скрипте, описывающем другой даг?
Вот так получается достать в PythonOperator:
from airflow.models import DagBag
target_si = DagBag().get_dag(target_dag_id).schedule_interval
Но это не работает в скрипте, который формирует даги, т.к. видимо это зацикливает процедуру.

12:30пожаловаться #2

Max Efremov

А можно сделать, что если прошлый зафейлился, новый бы не стартовал штатно? А то я туда добавил проверку флага окончания прошлого первой таской, но это костыль, конечно

Depends_on_past

12:31пожаловаться #3

Nikita Blagodarnyy

Depends_on_past

Уже есть, но оно доходит до прошлой зафейленной таски

12:32пожаловаться #4

А не весь даг ждёт

12:32пожаловаться #5

Тогда max_active_runs

12:34пожаловаться #6

Nikita Blagodarnyy

Тогда max_active_runs

Ну, там 1 тоже, он ждёт, когда зафейлится прошлый, да)

12:35пожаловаться #7

В чем тогда проблема? Не понимаю.

12:36пожаловаться #8

Nikita Blagodarnyy

В чем тогда проблема? Не понимаю.

Т.е. я хочу, чтобы следующий ран начинался, если прошлый прошёл до конца. Сейчас у меня он в 7 таске падает и если бы не мой костыль, он бы дошёл до 6 таски следующего рана, выполнил бы её и встал бы там, ожидая прошлого

12:37пожаловаться #9

А я хочу, чтобы он дагран новый вообще не начинал, если прошлый не выполнен весь с успехом

12:37пожаловаться #10

Max Efremov

А я хочу, чтобы он дагран новый вообще не начинал, если прошлый не выполнен весь с успехом

Для этого и есть max_active_runs=1