1. Learn
    2. /
  2. Курси
    3. /
  3. Вступ до Apache Airflow на Python
Connected

вправа

Запуск дочірнього Dag

Ви помічаєте, що деякі ваші робочі процеси використовують подібні компоненти, і розумієте, що можна виділити спільні завдання в окремий Dag. Це дасть змогу запускати ці компоненти за потреби без підтримки кількох копій. Ви вирішуєте виконати дочірній Dag через завдання у вашому поточному робочому процесі.

Компоненти dag, task і datetime вже імпортовано для вас.

Інструкції

100 XP
  • Імпортуйте оператор, потрібний для запуску Dag зсередини вашого робочого процесу.
  • Налаштуйте оператор так, щоб він запускав Dag з назвою child_pipeline.
  • Переконайтеся, що батьківський Dag чекає завершення запущеного Dag, перш ніж продовжити.
  • Вкажіть, як часто оператор перевіряє, чи завершився дочірній Dag.