【问题标题】:Airflow DAG even with hardcode datetime never runs即使使用硬编码日期时间,Airflow DAG 也永远不会运行
【发布时间】:2021-08-17 12:49:50
【问题描述】:

我在 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似乎很好,有什么想法吗?

【问题讨论】:

  • 你试过直接在DAG实例化中设置start_date吗?
  • 您共享的代码运行良好。你还有其他问题。首先尝试更改 dag_id 以获得“干净”的启动,看看它是否已解决。
  • @JoshFell 直接在 DAG 实例化中是什么意思?
  • @LucasSaito with DAG('instagram', default_args=default_args, start_date=...)

标签: python airflow airflow-scheduler


【解决方案1】:

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

【讨论】:

    猜你喜欢
    • 2021-12-27
    • 1970-01-01
    • 1970-01-01
    • 2022-11-14
    • 1970-01-01
    • 1970-01-01
    • 2014-10-29
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多