1. Learn
    2. /
  2. Courses
    3. /
  3. Вступ до Apache Airflow на Python
Connected

Exercise

Реалізація правила спрацювання (Trigger Rule)

Після створення робочого процесу ви розумієте, що вашому Dag стане в пригоді інформування, якщо принаймні одне з завдань завершиться помилкою. Ви вирішуєте додати завдання, яке реалізує перевірку one failed у вашому Dag, щоб сповіщати вас, якщо будь-яке завдання в Dag падає.

Усі інші завдання вже визначено, а об'єкти task і dag імпортовано для вас.

Instructions

100 XP
  • Імпортуйте відповідну бібліотеку для використання правил спрацювання (trigger rules).
  • Додайте потрібний атрибут правила спрацювання до завдання notify_on_failure.
  • Налаштуйте атрибут так, щоб завдання спрацьовувало, коли один або більше вхідних (upstream) завдань завершуються помилкою.
  • Задайте notify_on_failure як залежність униз за потоком (downstream) для двох завдань перетворення.