Airflowでキャッチアップジョブの「予定時刻」を取得するにはどうすればよいですか？

Question

エアフローダグを構築するときは、通常、定期的に実行する簡単なスケジュールを指定します。これが最も一般的に使用されると思います。

dag = DAG('my_dag', 
     description='this is what it does', 
     schedule_interval='0 12 * * *', 
     start_date=datetime(2017, 10, 1), 
     catchup=False) 

実際のプロセスでは「日付」をパラメータとして使用する必要があるため、現在の日付を確認するだけです。

date = datetime.date.today() 
# do some date-sensitive stuff 
operator = MyOperator(..., params=[date, ...]) 

私の理解では、catchup=Trueを設定するとエアフローstart_dateとなりました（またはend_date）の間のすべてのスケジュール間隔のための私のダグのスケジュールを持っているということです。例えば毎日。

私のdagインスタンスでscheduled_dateを使用するにはどうすればよいですか？

Answer 1

ここに実行日があると思いますが、演算子の中でマクロを使用することができます。詳細はhttps://airflow.apache.org/code.html#macrosでご覧いただけます。だから、空気の流れは、あなたがあなたのdateオペレータの内部動的

生成されている、あなたはオペレータの外で直接

strの中で{{ ds }}を呼び出すことができますする必要はありませんので、たとえばPythonOperatorのために、あなたがprovide_context=Trueが必要になります、それを尊重しますまず関数の最後の引数として**kwargsを渡すと、kwargs['ds']