Airflow：当 运行 使用 BashOperator 时，Python 脚本如何发出任务失败的信号
Airflow: How can Python script signal a failed task when run using BashOperator
当 运行 使用 Airflow 1.10.9 的 BashOperator 的 Python 脚本时，
task_1 = BashOperator(
task_id='task_1',
bash_command='/path/to/env/python /path/to/task_1.py'
dag=dag)
在 Python 脚本中可以做什么来向 Airflow 发出任务失败的信号？
task_1.py
if __name__ == '__main__':
print('Task failed!')
# How do we tell Airflow that the `task_1` has failed?
引发一个 Python 异常，应该将退出代码 1 发送到 BashOperator，这应该会失败。
当 运行 使用 Airflow 1.10.9 的 BashOperator 的 Python 脚本时，
task_1 = BashOperator(
task_id='task_1',
bash_command='/path/to/env/python /path/to/task_1.py'
dag=dag)
在 Python 脚本中可以做什么来向 Airflow 发出任务失败的信号？
task_1.py
if __name__ == '__main__':
print('Task failed!')
# How do we tell Airflow that the `task_1` has failed?
引发一个 Python 异常，应该将退出代码 1 发送到 BashOperator，这应该会失败。