【发布时间】: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