我无法列出我新创建的 dag。出现导入错误。请帮助我解决以下错误
:/$ airflow list_dags
[2019-12-27 21:07:50,125] {__init__.py:51} INFO - Using executor SequentialExecutor
[2019-12-27 21:07:50,127] {dagbag.py:403} INFO - Filling up the DagBag from /home/muniaraj/airflow/dags
[2019-12-27 21:07:50,134] {dagbag.py:246} ERROR - Failed to import: /home/muniaraj/airflow/dags/myfirstjob.py
Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/airflow/models/dagbag.py", line 243, in process_file
m = imp.load_source(mod_name, filepath)
File "/home/muniaraj/airflow/dags/myfirstjob.py", line 1
Code that goes along with the Airflow tutorial located at:
^
SyntaxError: invalid syntax
最佳答案
你能告诉我你把dag_file.py放在哪里了吗？
您的 dag 文件应位于 airflow-dir/dags 下。
此处，airflow-dir 是您针对环境变量 AIRFLOW_HOME 指定的文件夹。
另外，请确保 dag 的所有者是 dag 文件夹所在的用户，例如，如果它位于 /home/username/ 下的某个位置，则 owner dag 定义的 default_args 应该是 username。
访问FAQs了解更多这样的点。
关于python - Apache Airflow Dag 未列出，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59502960/