python - 当尝试运行 dag 和 Airflow 返回状态代码2时

Question

嘿，我真的在这方面遇到了 Airflow 问题。我还有另外两个 dags 运行没有问题，但是由于某些原因这些 dags 失败了，我在日志中没有得到太多对我有意义的信息。作为 Airflow 用户，我可以通过命令行毫无问题地运行此任务，但由于某种原因，当我尝试通过 dag 执行此任务时，我得到退出代码 2。有人对此有一些指示吗？谢谢

[2018-09-18 20:08:18,886] {base_task_runner.py:95} INFO - Subtask: airflow: error: unrecognized arguments: run pull_dcm_today_data pull_dcm_today_data 2018-09-18T19:00:00 --job_id 8 --raw -sd DAGS_FOLDER/run_pull_dcm_today.py

[2018-09-18 20:08:22,579] {jobs.py:2083} INFO - Task exited with return code 2

Answer 1

尝试使用 airflow test 命令按顺序测试每一项任务。如果所有任务都成功运行，但 DAG 不断失败，您可能需要重新启动整个项目(网络服务器、调度程序和工作人员)，因为您可能在某处有过时的代码。