Airflow: как сценарий Python может сигнализировать о сбое задачи при запуске с помощью BashOperator

При запуске сценария Python с использованием BashOperator из 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?