🌌[
Так-же в логах airflow
Size: a a a
2021 May 28
🌌[
О, благодарю
DK
хм, а если они там не выводятся, значит падает до момента принта?
🌌[
Кстати, а как там отмечать в скрипте, что всё пропало.
Хочу сделать exeption, и если ошибка, чтобы залетало в БД, там нужно, для отчётности.
Но ведь тогда, оно пойдёт работать дальше, отработает как есть, а мне надо, чтобы и airflow загнулся
Хочу сделать exeption, и если ошибка, чтобы залетало в БД, там нужно, для отчётности.
Но ведь тогда, оно пойдёт работать дальше, отработает как есть, а мне надо, чтобы и airflow загнулся
🌌[
Можешь на pastebin, или скрин функции прислать, если на питоне, могу глянуть в чём дело
🌌[
но воообще, там же и ошибка должна быть
🌌[
в логах
AA
Если хочется питона без оператора- можно сразу оператора функцию достать
https://airflow.apache.org/docs/apache-airflow/stable/_modules/airflow/operators/email.html#EmailOperator
https://airflow.apache.org/docs/apache-airflow/stable/_modules/airflow/operators/email.html#EmailOperator
🌌[
Оо, это как тогда в него переменные передавать :?
🌌[
просто забивать
to='', subject ='', и т.д. :?
to='', subject ='', и т.д. :?
AA
Как параметры при вызове функции
AA
Потому что это вызываемая функция)
ME
Подскажите, а можно задержать дагран на какое-то время? У меня кейс, когда данные по кварталам, но они готовые не сразу в конце квартала, а через 1.5 месяца после завершения
ME
т.е. 1 квартал обработает в середине второго
ME
т.е. да, можно сдвинуть всё на 1.5 месяца, но тогда дата запуска будет серединой квартала, не совсем понятно может быть
🌌[
Поставь sleep на полтора месяца )
🌌[
sleep(60 * 60 * 24 * 90)
ME
Это совсем костыль)) Вдруг ещё чего упадёт там за это время)