Додавання повторних спроб

Ви помітили, що певний Dag часто завершується помилкою на завданні, яке дістає дані з джерела. Дратує те, що якщо запустити це завдання через кілька хвилин, проблема зникає. Ознайомившись із механізмом повторних спроб (retries) в Airflow Dags, ви вирішили додати їх до цього завдання, щоб не запускати його вручну щоразу.

dag, task і timedelta уже імпортовано для вас.

Ця вправа є частиною курсу

Вступ до Apache Airflow на Python

Переглянути курс

Інструкції до вправи

Налаштуйте, щоб завдання extract_data виконувало 3 повторні спроби перед остаточним падінням.
Додайте затримку 10 хвилин між повторними спробами для завдання extract_data.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

@dag(schedule="@daily", start_date=datetime(2026, 5, 1))
def etl_pipeline():

  # Set retries and retry delay on extract_data
  @task(____=3, ____=____(minutes=10))
  def extract_data():
    print("Extracting data from source...")
  
  @task()
  def process_source_data():
    print("Now processing data...")

  extract_data() >> process_source_data()
  
etl_pipeline()

Редагувати та запускати код