1. Learn
  2. /
  3. Курси
  4. /
  5. Вступ до Apache Airflow на Python

Connected

вправа

Реалізація функції зворотного виклику

Нещодавно вам доручили додати зворотні виклики на випадок помилки до DAGʼів, які створює ваша команда. Для початку ви хочете додати простий зворотний виклик при помилці, що записуватиме повідомлення до журналу аудиту, коли sales_etl_dag завершується з помилкою.

Обʼєкти dag і task уже імпортовано, а завдання get_sales_data та process_sales_data створено.

Інструкції

100 XP
  • Створіть функцію зворотного виклику з назвою alert_on_failure.
  • Визначте функцію так, щоб вона приймала будь-які обʼєкти, які Airflow їй передає.
  • Вкажіть зворотний виклик на випадок помилки, використавши функцію alert_on_failure.