出现该问题的原因是因为在DAG的default_args中设置的start_date和schedule_interval与实际执行的时间不匹配,导致Airflow无法正确执行任务。
解决该问题的一种方法是将DAG的start_date设置为当前时间(例如:datetime.datetime.now()),以确保在当前时间开始执行任务。同时,需要将schedule_interval设置为None,以便手动触发任务。
示例代码:
default_args = { 'owner': 'airflow', 'start_date': datetime.datetime.now(), 'email_on_failure': False, 'email_on_retry': False, 'catchup': False, 'retries': 1, 'retry_delay': datetime.timedelta(minutes=5), 'schedule_interval': None }
with DAG('my_dag', default_args=default_args, schedule_interval=None) as dag: # tasks go here...