1. 学ぶ
  2. /
  3. コース
  4. /
  5. Python で学ぶ Apache Airflow 入門

Connected

演習

子 DAG のトリガー

いくつかのワークフローで同じようなコンポーネントが使われていることに気づき、共通のタスクをそれぞれ独立した DAG として切り出せると判断しました。こうすることで、複数のコピーを管理することなく、必要なときに該当コンポーネントを実行できるようになります。現在のワークフロー内のタスクから子 DAG を実行してみましょう。

dag、task、datetime はあらかじめインポートされています。

指示

100 XP
  • ワークフロー内から DAG を起動するために必要なオペレーターをインポートしてください。
  • child_pipeline という名前の DAG をトリガーするようにオペレーターを設定してください。
  • 親 DAG がトリガーした DAG の完了を待ってから次の処理に進むようにしてください。
  • 子 DAG が完了したかどうかをオペレーターが確認する頻度を設定してください。