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"，过去为"ON(打开("。

Answer 1

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

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