📑
Airflowの実行時間をcronっぽくしてみる
私もまだまだ理解が追い付いていないですが、下記のように記述することで、cronのように時間指定をして実行できます。
args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2022, 9, 6) #このDAGを作成する日付とする
}
# DAGの設定。実行頻度は1日1回にしてみる。
dag = DAG(
dag_id = 'ssh_dag',
default_args=args,
schedule_interval='0 * * * *') #ここがcronの記述方法で書きます。
環境によりますが、私の場合AirflowのスケジューラがUTC時刻で実行するためschedule_intervalの時間はUTC換算して設定しました。
おそらくDockerの時刻設定はJSTすれば直るかな?
Discussion