Size: a a a

2020 October 30

ДН

Дмитрий Негреев... in Airflow
Pavel G
запустить из CLI
А чем это отличаться от запуска из UI будет?
Смысл в том что расчет за прошлое обычно сильно дольше, max_active_runs=1 держит Даг ран от расписания, но если мануальный упадёт, то тот что по расписанию стартанет и затрет например часть долгих расчетов
источник

ДН

Дмитрий Негреев... in Airflow
Хочется проконтролировать, убедится что все ок, и потом обратно зашедулить
источник

PG

Pavel G in Airflow
trigger_dag создаст запись в мета бд аирфлоу и можно будет в UI мониторить процесс. Если тригернуть даг из UI то он создать dag_run с текущей меткой времени.
источник

🚀Г

🚀Юрий Гагарин... in Airflow
Yuri S
Как правильно сделать даг, чтобы его можно было перезапускать задним числом?
их и так можно перезапускать задним числом =))
У каждого дага есть execution_date, start_date и ещё какие-то *_date

вот эту дату можно передать в оператор и от неё плясать в своих вычислениях
источник

ДН

Дмитрий Негреев... in Airflow
Yuri S
Как правильно сделать даг, чтобы его можно было перезапускать задним числом?
источник

ДН

Дмитрий Негреев... in Airflow
Pavel G
trigger_dag создаст запись в мета бд аирфлоу и можно будет в UI мониторить процесс. Если тригернуть даг из UI то он создать dag_run с текущей меткой времени.
Да можно и в UI создать дагран на любой execution_date
источник

ДН

Дмитрий Негреев... in Airflow
Но мою проблему это не решает
источник

YS

Yuri S in Airflow
🚀Юрий Гагарин
их и так можно перезапускать задним числом =))
У каждого дага есть execution_date, start_date и ещё какие-то *_date

вот эту дату можно передать в оператор и от неё плясать в своих вычислениях
Спасибо!
источник

YS

Yuri S in Airflow
Супер, спасибо!
источник
2020 October 31

SG

Sergey Gavrilov in Airflow
О, нас уже больше тысячи человек. Поздравляю всех!
источник
2020 November 01

ME

Max Efremov in Airflow
А у mysql operator можно включить фейл на warning в логах?
источник

ME

Max Efremov in Airflow
А то по дефолту он всякие обрезания данных глотает, а это чревато потерей)
источник

АЖ

Андрей Жуков... in Airflow
Max Efremov
А у mysql operator можно включить фейл на warning в логах?
ну перегрузи его/сделай свой, кто мешает?
источник

АЖ

Андрей Жуков... in Airflow
я так s3 hook и s3 sensor переписывал под minio
источник

ME

Max Efremov in Airflow
Андрей Жуков
ну перегрузи его/сделай свой, кто мешает?
Лень немного, думал штатное есть, просто не вижу)
источник

ME

Max Efremov in Airflow
Но наверное да
источник
2020 November 02

ДН

Дмитрий Негреев... in Airflow
подскажите, где про airflow_local_settings.py почитать можно?
в доках вижу только примеры локальные, а на что еще способен и как правильно оформить примеры не вижу(
толи методы с такими названиями надо всегда иметь, толи в каком-то листе их перечислять
источник

СГ

Станислав Горчаков... in Airflow
скажите, плиз, а почему может в настройках дага не срабатывать catchup=False? или какая настройка останавливает запуск по шедулеру, когда даг был выключен и включается заново, и сразу несколько запусков срабатывает
источник

E

Edya in Airflow
Станислав Горчаков
скажите, плиз, а почему может в настройках дага не срабатывать catchup=False? или какая настройка останавливает запуск по шедулеру, когда даг был выключен и включается заново, и сразу несколько запусков срабатывает
max_active_runs вроде может позволить такое, если поставить 1 не должно быть такого
источник

СГ

Станислав Горчаков... in Airflow
Edya
max_active_runs вроде может позволить такое, если поставить 1 не должно быть такого
ок, спасибо за идею и важно вставлять его не в default_args
источник