19

何が起こっても、毎日指定された時間に実行するように Airflow ダグを構成する方法、まさに cron のようなもの。

TimeSensor を使用して同様の動作が得られることはわかっていますが、この場合はセンサー タスクに依存し、dag の実行時間と競合する可能性があります。

例: センサー アプローチでは、0 時 15 分に実行するセンサーがありますが、dag が後で実行されるとタスクが遅延するため、センサー アプローチであっても、Dag が適切な時間に実行されるようにする必要があります。

では、指定された時間に Dag が実行されるようにするにはどうすればよいでしょうか?

4

3 に答える 3

-1

DAG をインスタンス化するときに、schedule_interval を文字列の cron 式に設定できます。

schedule_interval='0 * * * *'

BaseOperator ドキュメント

于 2016-03-11T22:22:46.720 に答える