2017-12-26 65 views
0

エアフローDAGをgit repoにプッシュし、ジェンキンジョブをWebhookを使用して実行したい場合は、そこから新しいDAGを取得するために何をすればいいですか?エアフローCIセットアップダグ

gitリポジトリからdagbagを埋めるユーティリティ/演算子はありますか?そうでない場合、誰かが新しいDAGでdagbagsをどのように設定するのかを教えてください。

答えて

0

私の具体的なケースでは、supervisordを使用して、エアフロースケジューラとウェブサーバを維持しています。

私のJenkinsジョブの最後のコマンドは、両方のエアフロープロセスをリフレッシュするsupervisord restart airflow_scheduler;supervisord restart airflow_webserverです。

Airflowはプロセスの現在の状態をデータベースに保存しているため、スケジューラまたはWebサーバーをリセットするため、何も壊れません。

これがAirflow-yの最良の方法であるかどうかはわかりませんが、私は今まで私のために働いていました。