python - Airflow :使用 BashOperator 运行时，Python 脚本如何发出失败的任务信号

Question

使用 BashOperator 运行 Python 脚本时 Airflow 1.10.9，

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?

Answer 1

引发应该向 BashOperator 发送退出代码 1 的 Python 异常，该异常应该失败。