python - 重置 Airflow DAG 执行时间

Question

目前我有一个预定的 dag @daily，通常应该在午夜之后触发以运行前一天的数据。

不知何故，它现在已经在上午 11:30 开始运行，因为过去运行有问题并且在那个时间手动重新启动。现在它总是在那个时候触发。这当然是由于调度算法在最后一次执行时间后一天触发它。

但是，并非完全需要在上午 1130 点运行。我希望能够以某种方式让 DAG 在午夜启动。

我有哪些选择？我可以随时更改名称，但是如果/当将来发生这种情况时，有没有一种方法可以让我轻松编写脚本？

Airflow 1.8

DAG代码:

dag = DAG('my_dag_v5',
          catchup=False,
          default_args=args, 
          start_date=datetime.datetime(2018, 1, 30), 
          schedule_interval='@daily',
          max_active_runs=1)

Answer 1

将 schedule_interval='@daily' 更改为 schedule_interval='0 0 * * *'

同时将您的开始日期从 start_date=datetime.datetime(2018, 1, 30, 4, 0) 更改为 start_date=datetime(2018, 1, 30) .

start_date (datetime) – 任务的开始日期，决定了第一个任务实例的执行日期。最佳做法是将 start_date 四舍五入为 DAG 的 schedule_interval。

schedule_interval - 定义 DAG 运行的频率，这个 timedelta 对象被添加到最新任务实例的 execution_date 中以确定下一个时间表。

这将使它使用 CRON 格式每天午夜运行。