气流-将气流脚本安排在一周中的特定日期运行时出错



我正在尝试将一个气流脚本安排在每周二UTC上午9:10运行。下面是我对它的定义。

dag = DAG(
dag_id=DAG_NAME,
default_args=args,
schedule_interval="10 9 * * 2",
catchup=False

然而,我发现,当时机成熟时,脚本不会自动触发。但是,如果我没有在day列(最后一列(中定义值,则调度程序工作正常。知道我哪里错了吗。

感谢

更新:

args = {
'owner': 'admin',
'start_date': airflow.utils.dates.days_ago(9)
}
dag = DAG(
dag_id=DAG_NAME,
default_args=args,
schedule_interval = "10 9 * * 2",
catchup = False
)

这个比Airflow中的任何其他东西都更难缠人,但正如评论和Airflow文档所说,

调度程序在开始日期后的一个schedule_interval,即周期结束时运行作业。

在这种情况下,您可以将DAGstart_date推迟一个schedule_interval,也可以等待下一个schedule_interval完成。

最新更新