Airflow :为什么运营商会有起始日期？

Question

我不明白为什么我们需要运算符(operator)(任务实例)的“开始日期”。我们传递给DAG的那个不足够吗？

另外，如果当前时间是UTC的2018年2月7日上午8:30，现在我将dag的start_date设置为2018年2月7日0.00 am，我的cron表达式的计划间隔为30 9 * * *(每天在9.30 am，即期望在接下来的1小时内运行)。我的DAG是在今天上午9.30还是明天(2月8日上午9.30)运行？

Answer 1

关于任务实例上的start_date，我个人从未使用过它，我始终只有一个DAG start_date。

但是，从我可以看到的角度来看，这将使您可以指定某些任务，这些任务在与主DAG不同的时间开始。看来，这是一项旧功能，通过阅读FAQ，他们建议使用时间传感器代替这种类型的事物，并且对于通过DAG传递的所有任务仅具有一个start_date。

您的第二个问题:

运行的执行日期始终是基于计划的上一个期间。

从文档(Airflow Docs)

Note that if you run a DAG on a schedule_interval of one day, the run stamped 2016-01-01 will be trigger soon after 2016-01-01T23:59. In other words, the job instance is started once the period it covers has ended.

澄清:

如果按每日时间表设置，则在8号执行7号。

如果设置为每周计划以在星期日运行，则该星期日的执行日期为最后一个星期日。