此错误通常出现在尝试访问列表或迭代器之类的对象之前,但该对象为None的情况下。如果在使用Airflow和TaskFlow API时出现此错误,请检查是否正确配置了DAG和task。例如,确保任务有关联的Operator,且DAG有从任务到Operator的依赖关系。以下是一个例子:
from datetime import timedelta from airflow import DAG from airflow.operators.python_operator import PythonOperator
def hello_world(): print("Hello, world!")
dag = DAG( 'tutorial', description='Simple tutorial DAG', schedule_interval=timedelta(days=1), start_date=datetime(2017, 3, 20), catchup=False )
t1 = PythonOperator( task_id='hello_world_task', python_callable=hello_world, dag=dag )
改正上述代码中的错误将有助于避免“'NoneType'对象不可迭代”的错误。