ćwiczenie

Dodawanie ponownych prób

Zauważasz, że pewien DAG często kończy się niepowodzeniem na zadaniu pobierającym dane z określonego źródła. Co irytujące, uruchomienie tego zadania kilka minut później zazwyczaj rozwiązuje problem. Po zapoznaniu się z funkcją ponownych prób w DAG-ach Airflow postanawiasz ją zastosować, żeby nie musieć ręcznie restartować zadania.

dag, task i timedelta są już zaimportowane.

Instrukcje

100 XP

Ustaw zadanie extract_data tak, aby wykonało 3 ponowne próby przed zgłoszeniem błędu.
Dodaj 10-minutowe opóźnienie między kolejnymi próbami dla zadania extract_data.

.css-6su6fj{-webkit-flex-shrink:0;-ms-flex-negative:0;flex-shrink:0;}ćwiczenie

Instrukcje

ćwiczenie