1. Apprendre
  2. /
  3. Cours
  4. /
  5. Introduction à Apache Airflow en Python

Connected

Exercice

Ajouter des nouvelles tentatives

Vous avez remarqué qu'un certain Dag échoue souvent sur une tâche qui extrait des données d'une source donnée. Frustrant : exécuter la tâche quelques minutes plus tard semble régler le problème. Après avoir appris la fonctionnalité de nouvelles tentatives (retries) dans les Dags Airflow, vous décidez de l'implanter sur cette tâche pour éviter de la relancer manuellement.

Les objets dag, task et timedelta sont déjà importés pour vous.

Instructions

100 XP
  • Configurez la tâche extract_data pour qu'elle effectue 3 nouvelles tentatives avant d'échouer.
  • Ajoutez un délai de 10 minutes entre les tentatives pour la tâche extract_data.