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