Airflow Dag 运行 开始日期推迟 8 小时
Airflow Dag run start date off by 8 hours
我的 DAG 配置是
{
'schedule_interval': '7 15 * * *',
'default_args': {
'start_date': datetime(2020, 8, 1),
},
}
气流运行宁配置:
default_timezone=utc
然而,DAG 的每个 运行 都有 ("Task Instance Details")
start_date: 2020-mm-dd 15:07:07`。
我错过了什么?这个 DAG 是我 Google Cloud Composer 实例上唯一 运行ning 的东西。
Version : 1.10.9+composer
编辑
一切正常。我的问题是我的 cron 表达式与我的预期不同。我想要 7:15,所以正确的 cron 表达式应该是 15 7 * * *
.
解决方案:Airflow 的 schedule_interval
的 cron 表达式按预期工作。我的问题是我的表达式中 minute/hour 倒置了,所以我的预期写错了。
因为我希望 DAG 每天在 7:15 运行,表达式应该是
'schedule_interval': '15 7 * * *'
有关 cron 计划表达式的更多信息,请参阅 https://crontab.guru/
我的 DAG 配置是
{
'schedule_interval': '7 15 * * *',
'default_args': {
'start_date': datetime(2020, 8, 1),
},
}
气流运行宁配置:
default_timezone=utc
然而,DAG 的每个 运行 都有 ("Task Instance Details")
start_date: 2020-mm-dd 15:07:07`。
我错过了什么?这个 DAG 是我 Google Cloud Composer 实例上唯一 运行ning 的东西。
Version : 1.10.9+composer
编辑
一切正常。我的问题是我的 cron 表达式与我的预期不同。我想要 7:15,所以正确的 cron 表达式应该是 15 7 * * *
.
解决方案:Airflow 的 schedule_interval
的 cron 表达式按预期工作。我的问题是我的表达式中 minute/hour 倒置了,所以我的预期写错了。
因为我希望 DAG 每天在 7:15 运行,表达式应该是
'schedule_interval': '15 7 * * *'
有关 cron 计划表达式的更多信息,请参阅 https://crontab.guru/