hterik opened a new pull request, #37613:
URL: https://github.com/apache/airflow/pull/37613
When a task is terminated, it get sent a SIGTERM signal, (through
standard_task_runner.terminate).
This signal is picked up by taskinstance.py, where it injects an
AirflowException into the current running task.
The exception raised there is now changed into a new AirflowTaskTerminated
exception.
This new exception inherits BaseException, so that it is not caught and
ignored accidentally by code that tries to perform ordinary error handling.
Because termination requests should not be ignored.
This will improve reliability of cancelling tasks and will make error logs
and error categorization more clear about the reason for failure.
(The terminate function does eventually send SIGKILL if the
SIGTERM is ignored, but waiting for that should not be necessary)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
