我已经创建了一个以PythonOperator作为操作员的任务。它使用参数调用另一个文件夹中的函数。但是运算符不接受参数dag=dag,而实际上它是必须的,因为它用于指向dag上下文。它们将从子文件夹中调用该函数,并将一个参数传递给print。my_dag.py import datetime as dt
from airf
我刚接触Airflow,只是为了练习在DAG中做一个简单的数据转换。然而,我不确定为什么第一个任务总是意外失败。有人能给我一些关于如何在DAG中调试失败的任务或指出错误部分的提示吗?非常感谢。import pandas as pdfrom airflow import DAG
from airflow.operators.dumm