Body
Handle the part where we stop all remaining tasks for while marking a task as failed.
Usage:
|
if task and fail_stop: |
|
_stop_remaining_tasks(task_instance=ti, session=session) |
My thinking here is that we introduce the "fail_stop" property in the serialised dag and while executing a task (marking it running -- done in the /run endpoint in execution API), if that property is set, we just fail.
Body
Handle the part where we stop all remaining tasks for while marking a task as failed.
Usage:
airflow/airflow/models/taskinstance.py
Lines 3086 to 3087 in aaf29ee
My thinking here is that we introduce the "fail_stop" property in the serialised dag and while executing a task (marking it running -- done in the /run endpoint in execution API), if that property is set, we just fail.