DAGに引数を渡し、タスクのApacheのエアフロー

Question

私はapache airflow 1.8を調べています。私は、DAGsまたはtasksに引数を渡す方法があるか、backfillingのどちらかが好きですか？ここで

のようなもので、私は

airflow backfill My_DAG -s some_date -e end_date argument_for_t1 argument_for_t2 

、探していますか、それは引数のarrayことができること。

引数を渡す方法はありますか？私は多くを検索しましたが、何も見つけることができませんでした。

Answer 1

を埋める当時、私は私がairflow variables -s my_var="some value"

を使用して変数を設定することができソリューションに出くわしました

今すぐどこからでもmy_varにアクセスできます。より多くのオプションのための

では、一度に単一の実行を持っている場合、これは許容可能であるcli

Answer 2

バックフィルは、失敗した/逃した/誤って構成されたDAGを再実行するためのもので、コマンドライン引数を与える手段はありません。

しかし、あなたはDagBagフォルダに移動し、DAGオブジェクトへのparamsを与えることができます（変更/既存のDAGを修正）DAG