import DAGfrom datetime import datetime='echo Hello, This is my first DAG in Airflow!'/operators/bash_operator.py", line 135, in execute
raise AirflowException("Bash</e
在开发新功能的过程中,我正在尝试使用命令行界面测试我的DAG,但我无法做到这一点。在DAG中有一些BASH操作符调用,并且每个脚本都被正确执行,并产生记录的输出。但是,我无法通过命令行访问从相同文件夹运行的相同DAG的功能,例如: airflow render sample_dag all 2019-01-14T06:04:05 上面命令的输出是: Test Dagdag不存在或解析失败。* 执行DAG内的调试打印,但不调用Bash脚本(不生成脚本日志)。import
我试图通过传入一个不起作用的Bash line (thisshouldnotrun)来故意使Airflow任务失败并出错。Airflow正在输出以下内容:
[2017-06-15 17:44:17,869] {bash_operator.py:94} INFO - /tmp/airflowtmpLFTMX7/run_bashm2MEsS/operators/bash_operator.py", line 100, in exec
您好,我刚刚开始使用Airflow,但我无法在快速入门run:airflow run example_bash_operator runme_0 2015-01-01中完成任务。我刚刚使用Python2.7.6创建了一个conda环境,并通过安装了airflow==1.8.0的pip安装了airflow。然后,我运行了中列出的命令。以下是该命令的输出:
(airflow) ✔ se7entyse7en in ~/Projects/