testing-dags

DAG テストスキル

Airflow VS Code 拡張機能のツールを使用して、DAG のテスト、デバッグ、修正を反復的に行います。

最初のアクション：DAG をトリガーする

ユーザーから DAG のテストを依頼された場合、最初に次の操作を行います。

• 指定された DAG ID と設定を使って trigger_dag_run を実行する

ユーザーから依頼されない限り、事前確認は行わないでください。

テストワークフローの概要

1. トリガーして監視する
2. 成功した場合は要約する
3. 失敗した場合はデバッグする
4. 修正して再テストする

フェーズ 1：トリガーして監視する

1. トリガー：trigger_dag_run
2. 監視：
   • get_dag_runs を使用して状態を確認する
   • 特定の実行 ID がわかっている場合は、get_dag_run_detail を使用する

結果の解釈

• 成功：所要時間と結果を要約する
• 失敗：フェーズ 2 に進む
• 実行中：ポーリングを続けるか確認する

フェーズ 2：失敗をデバッグする

1. analyse_dag_latest_run を使用して、最新の実行を詳細に分析する
2. 特定の実行 ID がわかっている場合は、get_dag_run_detail を使用する
3. タスクログが必要な場合は、go_to_dag_log_view を開く

フェーズ 3：修正して再テストする

1. DAG または関連システムに修正を適用する
2. trigger_dag_run で再度トリガーする
3. get_dag_runs または get_dag_run_detail で再確認する

注意事項

• 迅速な初期調査には analyse_dag_latest_run を優先して使用する
• 日をまたいで比較する場合は get_dag_history を使用する