airflow-scheduler

0熱

1答えて

bashoperatorが1つだけ再試行され、他のエアフローはないことを確認する方法

次のようにdagファイルがあります。ここでは再試行はありません。しかし、特定のファイル（bash1、bash2）が再試行1.を持つべきであることを確認したいが、他のファイルは再試行しないようにしたい。 以下はデフォルトの引数です。 default_args = { 'owner': 'airflow', 'depends_on_past': False, 'start

airflow apache-airflow airflow-scheduler 2017-05-15

---

1熱

1答えて

ダグ内の関数にds変数を渡すにはどうすればよいですか？

変数{{ds}}にある実行日を渡します。しかし、私はそれを実行日付を取得しない関数を渡しました。 def get_spark_step_2(date): #logic in here return step exec_date = '{{ ds }}' step_adder2 = EmrAddStepsOperator( task_id='create_pa

airflow apache-airflow airflow-scheduler 2017-05-18

---