英文:
Airflow DAG does not start
问题
我已经创建了一对几乎相同的DAG，只是为了测试调度。
在2023年6月21日凌晨1:22和1:57（乌克兰当地时间）创建了DAG文件。
它们的开始时间分别为：
start_date = datetime(2023, 6, 21, 10, 0, 0) 和 start_date = datetime(2023, 6, 21, 9, 30, 0)
以及schedule_interval = ' @daily '都是一样的。
所以，它们应该在2023年6月22日上午10:00和9:30开始运行，即start_date + schedule_interval。
现在是2023年6月22日，下午2:20（当地时间），这两个DAG都没有启动。
UI中的“下一次运行”显示为2023-06-22 00:00:00（无论如何，这是错误的）。
我使用Udemy上的一个课程中的docker-compose示例在Docker中启动AirFlow，AirFlow的版本是2.4.2（我知道，这不是最新版本）。
我有遗漏什么，我不知道的东西，还是Airflow的调度根本不起作用？
英文:
I have created a couple of DAGs, almost identical, just to test scheduling.
Created the DAG files on 21 June 2023, at 1:22 and 1:57 AM (night, local time in Ukraine).
Their start times:
start_date = datetime(2023, 6, 21, 10, 0, 0) and start_date = datetime(2023, 6, 21, 9, 30, 0)
and schedule_interval = '@daily' for both.
So, they should run on 22 June 2023 at 10:00 AM and 9:30 AM, that is start_date + schedule_interval.
Now is 22 June 2023, 14:20 (local time), none of these DAGS has started.
The "Next run" in the UI shows 2023-06-22 00:00:00 (this is wrong anyway).
I use a docker-compose example from a course on Udemy to launch AirFlow in Docker, and the version of AirFlow is 2.4.2 (I know, this is not the last one).
Did I miss something, am I unaware of something, or Airflow scheduling does not work at all?
答案1
得分: 1
“@daily”计划间隔始终为午夜，这就是你看到“下一个DAG运行”在午夜时分的原因。
为了设置所需的运行小时，您需要提供一个类似于“cron”的表达式，而不是“@daily”。
例如：
- 在上午10点运行 -
0 10 * * * - 在上午9:30运行 -
30 9 * * *
英文:
The @daily schedule interval is always for midnight, that's why you see the "next dag run" at midnight
In order to set the required run hour, you need to provide a "cron" like expression instead of @daily
for example:
- Run at 10AM -
0 10 * * * - Run at 9:30AM -
30 9 * * *
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论