Airflow DAG 即使使用硬编码日期时间也永远不会运行

Question

我在 Airflow 中遇到 DAG 问题，我已经尝试在今天之前的一周内更改 start_date 两次，但它仍然没有运行。计划间隔设置为“5 9 * * *”。这是代码

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta
//code
default_args = {
    'owner': 'Lucas',
    'email': ['//email'],
    'email_on_failure': True,
    'start_date': datetime(2021, 7, 9),
    'retry_delay': timedelta(minutes=5)
}

with DAG('instagram', default_args=default_args, schedule_interval='5 9 * * *', catchup=False) as dag:
    token = get_token()
    //code

这真的很奇怪，因为这不是 dag 本身的问题，我可以手动触发 dag 而不会出现任何错误并且 start_date 和 schedule_interval 看起来很好，有什么想法吗？

Answer 1

解决方案是删除 dag 并创建另一个名称不同、代码相同的 dag。我仍然不知道是什么气流问题导致的。

Airflow DAG 即使使用硬编码日期时间也永远不会运行

Airflow DAG even with hardcode datetime never runs

python

airflow

airflow-scheduler