Size: a a a

2020 October 01

Ж

Жмака in Airflow
Max Efremov
Не нужно стараться всгё одной строчкой написать
start_pipeline >> [start_em, start_ec2]
   start_emr >> spark_app_ias >> ml_app_ias
   start_emr >> spark_app_dv >> ml_app_dv
   start_ec2 >> [ml_app_ias, ml_app_dv]
   [spark_app_ias, spar_app_dv] >> terminate_emr
   [ml_app_ias, ml_app_dv] >> terminate_ec2
   [terminate_emr, terminate_ec2] >> finish_pipeline >> notify_users_by_email
источник

ME

Max Efremov in Airflow
Жмака
Плюс надо сэкономить деньги на emr чтобы зря не бежал
А step functions тут не подойдут?
источник

Ж

Жмака in Airflow
Max Efremov
Не нужно стараться всгё одной строчкой написать
Так?
источник

Ж

Жмака in Airflow
Max Efremov
А step functions тут не подойдут?
Не. Отвергли
источник

ME

Max Efremov in Airflow
Жмака
Так?
Наверное) оно верный граф рисует?
источник

Ж

Жмака in Airflow
Я не могу запустить отдельно пока что потому что тут закрутили с кубернетесом всю эту кухню. Попробую на отдельно ec2 airflow
источник

Ж

Жмака in Airflow
Поэтому спросил у знатоков)
источник

ME

Max Efremov in Airflow
Сделай дамми операторы и посмотри, какой даг будет в итоге
источник

ME

Max Efremov in Airflow
Чисто для проверки, как оно
работает
источник

Ж

Жмака in Airflow
Да. Вот как раз пробую на докере с эйрфлоу. Спасибо!
источник

GB

Georgy Borodin in Airflow
Подскажите, пожалуйста: запустил airflow в ecs, логи таска недоступны, когда воркера убивает скалирование за ненадобностью. Если настроить сохранение логов в S3, их можно будет дёргать через веб-интерфейс?
источник

А

Андрей in Airflow
Georgy Borodin
Подскажите, пожалуйста: запустил airflow в ecs, логи таска недоступны, когда воркера убивает скалирование за ненадобностью. Если настроить сохранение логов в S3, их можно будет дёргать через веб-интерфейс?
В конфиге же есть настройка такая.
источник

GB

Georgy Borodin in Airflow
Андрей
В конфиге же есть настройка такая.
Это да, но они будут сдёргиваться через Web UI?
источник

А

Андрей in Airflow
А про веб это же к s3 вопрос
источник

GB

Georgy Borodin in Airflow
Андрей
А про веб это же к s3 вопрос
Да, в итоге дёргает с s3, супер
источник
2020 October 02

YL

Yevhenii Lukashov in Airflow
Тоже настроил логи на с3, работает норм
источник

ДН

Дмитрий Негреев... in Airflow
как можно проверить, стартанул dagrun по-расписанию или нет?
пока из вариантов вижу только смотреть что runid начинается на scheduled
источник

ИХ

Ильяс Хакиев... in Airflow
Я должен сжедать это😀
Поехали 🚀
источник

I

Igor in Airflow
Дмитрий Негреев
как можно проверить, стартанул dagrun по-расписанию или нет?
пока из вариантов вижу только смотреть что runid начинается на scheduled
У объекта dagrun есть булевое поле external_trigger
источник

ДН

Дмитрий Негреев... in Airflow
Igor
У объекта dagrun есть булевое поле external_trigger
спасибо, то что нужно
источник