📑

Airflowの実行時間をcronっぽくしてみる

2022/09/07に公開

私もまだまだ理解が追い付いていないですが、下記のように記述することで、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の記述方法で書きます。

\textcolor{red}{注意事項}
環境によりますが、私の場合AirflowのスケジューラがUTC時刻で実行するためschedule_intervalの時間はUTC換算して設定しました。
おそらくDockerの時刻設定はJSTすれば直るかな?

Discussion