通常情况下,这是因为您的代码中使用了相对导入,而Airflow默认为绝对导入,因此无法找到模块。为了解决这个问题,您可以在您的代码中使用明确的绝对导入路径,或者将您的代码放在Airflow DAG文件夹内。例如,如果您的代码文件名为“my_code.py”,您可以将其放在“/path/to/airflow/dags/my_code.py”中,并使用以下方式导入模块:
from dags.my_code import my_function
这将告诉Airflow从“dags”文件夹中导入相应的模块。