Implications pour l'exécuteur testamentaire
Vous avez appris beaucoup de choses sur le fonctionnement d'Airflow DAGs et vous avez acquis une certaine confiance dans le développement de nouveaux flux de travail. Cela dit, votre responsable vous a signalé que certains jours, les flux de travail prenaient beaucoup plus de temps à se terminer et vous a demandé d'enquêter. Elle mentionne également que le fichier salesdata_ready.csv
prend plus de temps à générer ces jours-ci et que le moment de la journée où il est complété est variable.
Cet exercice requiert des informations provenant des deux leçons précédentes - souvenez-vous des implications des arguments disponibles et modifiez le flux de travail en conséquence. Notez que pour cet exercice, vous devez modifier une ligne de code, et non ajouter du code supplémentaire.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Déterminez le niveau de parallélisme disponible sur ce système. Vous pouvez le faire en vérifiant la configuration du flux d'air (vous pouvez lancer
airflow info
dans le terminal). - Consultez la source du fichier DAG et déterminez quelle entrée est à l'origine du problème.
Exercice interactif pratique
Passez de la théorie à la pratique avec l’un de nos exercices interactifs
