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

Exercice

Déclencher un Dag enfant

Vous remarquez que certains de vos flux de travail utilisent des composants similaires et réalisez que vous pourriez extraire les tâches communes dans leur propre Dag. Cela vous permettrait d'exécuter ces composants au besoin sans entretenir plusieurs copies. Vous décidez d'exécuter un Dag enfant au moyen d'une tâche au sein de votre flux de travail actuel.

Les composants dag, task et datetime ont été importés pour vous.

Instructions

100 XP
  • Importez l'opérateur nécessaire pour démarrer un Dag à partir de votre flux de travail.
  • Configurez l'opérateur pour déclencher le Dag nommé child_pipeline.
  • Assurez-vous que le Dag parent attend la fin du Dag déclenché avant de continuer.
  • Définissez la fréquence à laquelle l'opérateur vérifie si le Dag enfant est terminé.