手动触发 dag 后气流调度程序不工作

Question

我有一份每日时间表的气流工作。它每天都运行得很好，直到昨天我在预定运行后几个小时手动触发了 dag。第二天（今天）任务没有被执行）。

start date - 31.08.2020 03:00 @daily -> scheduled, all good
01.09.2020 03:00 -> scheduled, all good
01.09.2020 06:00 -> manual trigger
02.09.2020 03:00 -> task was not executed!

我没有更改代码/配置中的任何内容，因此我怀疑昨天的手动触发导致 dag 今天没有按计划运行。难道还有别的原因吗？

default_args = {
    'owner': 'raydex',
    'depends_on_past': False, 
    'start_date': datetime(2020,5,31), 
}

with DAG('task', default_args=default_args, schedule_interval='0 3 * * *', catchup=False) as dag:

有谁知道到底是什么原因造成的？我怎样才能防止这个问题再次发生？由于作业尚未安排，我现在需要再次手动触发它。我希望从明天（03:00）开始再次自动安排。

UI 中的状态一直为“ON”。

Answer 1

也许您使用的是版本 2？这似乎是版本 2 的一个潜在错误，或者至少是未记录的行为更改。您可以在此处了解更多信息。

https://github.com/apache/airflow/issues/13434