V
Size: a a a
2020 October 26
ME
кто-нибудь прикручивал заведение багов в джире на падение дага? это можно сделать какой-то лаконичней чем через onfailurecallback?
Куда уж лаконичнее, 1 функция)
VS
кто-нибудь прикручивал заведение багов в джире на падение дага? это можно сделать какой-то лаконичней чем через onfailurecallback?
Sentry
VS
Выше обсуждали его, говорят, он уже нормально работает
2020 October 27
SU
Ребят привет, подскажите плиз, у меня dag почему-то игнорирует расписание, и просто нонстоп выполняется
default_args = {
'owner': 'me',
'depends_on_past': False,
'start_date': datetime(2020, 1, 27),
'email': ['me@me.me'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5)
}
dag = DAG('send_time_to_tg_user', max_active_runs=1, default_args=default_args, schedule_interval=timedelta(minutes=5))z
Ребят привет, подскажите плиз, у меня dag почему-то игнорирует расписание, и просто нонстоп выполняется
default_args = {
'owner': 'me',
'depends_on_past': False,
'start_date': datetime(2020, 1, 27),
'email': ['me@me.me'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5)
}
dag = DAG('send_time_to_tg_user', max_active_runs=1, default_args=default_args, schedule_interval=timedelta(minutes=5))catchup=False добавьте
SU
Окей, а что кетчуп делает? а то так не понятно из названия))
FS
Даг пытается догнать все даты начиная с 2020, 1, 27
SU
А, понял спасибо
ДС
Привет!
Ищем себе команду ETL-разработчика (DWH Mail.ru Games): https://hh.ru/vacancy/40055978
Пишите мне или отзывайтесь 🙂
Ищем себе команду ETL-разработчика (DWH Mail.ru Games): https://hh.ru/vacancy/40055978
Пишите мне или отзывайтесь 🙂
GB
Привет. Подскажите, я хочу взять airflow для обработки документов. Будет несколько шагов с ветвлением.
Но! Мне надо, чтобы юзер мог зайти в результаты работы любого шага, что-то поправить руками и перезапустить следующие шаги соответственно.
Подойдёт ли для этого AirFlow?
Но! Мне надо, чтобы юзер мог зайти в результаты работы любого шага, что-то поправить руками и перезапустить следующие шаги соответственно.
Подойдёт ли для этого AirFlow?
Всё зависит от логики ветвления и того, насколько этот даг идемпотентен
T
Всё зависит от логики ветвления и того, насколько этот даг идемпотентен
Планируется, что все идемпотентно. Скорее всего будет глубина 2-3 обработчика и на каждом шаге все будет просто ветвиться
GB
Планируется, что все идемпотентно. Скорее всего будет глубина 2-3 обработчика и на каждом шаге все будет просто ветвиться
Даг раны по расписанию, тасков много?