我有一个bash脚本,它创建了一个文件(如果它不存在的话),我想在airlow中运行,但是当我尝试它时失败了。我该怎么做?
#!/bin/bash
#create_file.sh
file=filename.txt
if [ ! -e "$file" ] ; then
touch "$file"
fi
if [ ! -w "$file" ] ; then
echo cannot write to $file
exit 1
fi
以下是我如何在Airflow中称之为:
create_command = """
./scripts/create_file.sh
"""
t1 = BashOperator(
task_id= 'create_file',
bash_command=create_command,
dag=dag
)
lib/python2.7/site-packages/airflow/operators/bash_operator.py", line 83, in execute
raise AirflowException("Bash command failed")
airflow.exceptions.AirflowException: Bash command failed
从教程中可以看出:
但是你要传递一个多行命令给它
应该是
此外,还必须确保您位于正确的目录中,以避免出现隐藏错误。这样做例如:
相关问题 更多 >
编程相关推荐