気流のWebサーバーを再起動する必要なく、気流の中のPython関数を更新する方法

Question

気流を使っていくつかのPython ETLプロセスをスケジュールする方法を学んでいます。私は私のpythonコードを更新するたびに、Webサーバーを再起動し、コードの変更がエアフローによって取得される前にDAGの名前を変更する必要があります。とにかくこれの周りには、特に私は変更を行うたびにDAGの名前を変更する必要はありませんか？

Answer 1

Webサーバーでは、変更が明白ではない場合がありますが、変更するDAGの横にある更新ボタンをクリックすると、手動でDAGが読み込まれます。

スケジューラは、再起動する必要なく常に最新のコードを使用します。

はこちらをご覧ください：https://gtoonstra.github.io/etl-with-airflow/gotchas.html

Answer 2

このURLを： http://airflowhost:8080/admin/airflow/refresh_all

これは、現在のバージョンで問題となっているすべてのDAG

Answer 3

を更新します。私が通常やっているのは、DAGを複製してその名前を変更して、Webサーバーに反映させることです。私が開発を終えるとすぐに私は最後の名前を変更し、古いものを削除します。