XComを使用するApache Airflowタスクをテストする方法

Question

XComを使用していくつかのタスクを通信するDAGをテストする方法を理解しようとしています。

コンソールコマンドでは、DAGからタスクを実行できるだけなので、UI経由でDAGを実行しなくても通信をテストする方法はありますか？

ありがとうございました

Answer 1

ここは私のために働いた方法です。

エアフローWebページには、テストコマンドが何の状態も生成しないか、または保持しないと記載されていても、エアフローテストコマンドの実行が順番に実行されます。

は、基本的には、実行します。タスク1が値を返すか、値を取得し、上に移動する値とその後、タスク2の実行xcom_pullを送信するための方法を使用していますxcom_push

Airflow test my_dag task1 date 
Airflow test my_dag task2 date 

。

それは私のために働いた。異なるアプローチやその他の質問がある場合は、ご意見ください。